Queue Implementation with Redis
Project description
moonqueue
MoonQueue is another Queue Library using Redis as storage.
How to Install
pip install moonqueueHow To Use
RedisQueueList - One Queue
>>> from moonqueue import RedisQueueList
>>> r = RedisQueueList('list:myqueue')
# push one message
>>> r.push(['apple'])
(('list:myqueue', 1),)
>>> r.pop()
('list:myqueue', b'apple')
# push multiple messages
>>> r.push(['apple', 'banana'])
(('list:myqueue', 2),)
>>> r.pop()
('list:myqueue', b'apple')
>>> r.pop()
('list:myqueue', b'banana')
>>> r.pop()
Traceback (most recent call last):
File "<stdin>", line 1, in <module>
File "/home/web/moonqueue/moonqueue/redis_queue_list.py", line 52, in pop
raise EmptyQueueException(excep_msg)
moonqueue.excep.EmptyQueueException: list:myqueue is emptyRedisQueueList - Two Queues
>>> from moonqueue import RedisQueueList
>>> r = RedisQueueList(['list:myqueue1', 'list:myqueue2'])
>>> r.get_queues()
['list:myqueue1', 'list:myqueue2']
# push one message - it will be pused to all queues
>>> r.push(['apple'])
(('list:myqueue1', 1), ('list:myqueue2', 1))
# pop from queues
>>> r.pop()
('list:myqueue1', b'apple')
>>> r.pop()
('list:myqueue2', b'apple')
>>> r.pop()
Traceback (most recent call last):
File "<stdin>", line 1, in <module>
File "/home/web/moonqueue/moonqueue/redis_queue_list.py", line 52, in pop
raise EmptyQueueException(excep_msg)
moonqueue.excep.EmptyQueueException: ['list:myqueue1', 'list:myqueue2'] is empty
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
moonqueue-0.3.1.tar.gz
(4.0 kB
view hashes)
Built Distribution
moonqueue-0.3.1-py3-none-any.whl
(17.2 kB
view hashes)
Close
Hashes for moonqueue-0.3.1-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 6b66c3d5e64b69cf31ba7f21c7ecc7143ec9e11de75aaa58a124b6cd0ed64299 |
|
| MD5 | 37b9b5cd8521cd1b9b49a471e61624ce |
|
| BLAKE2b-256 | 3f6a78492cf98d040028140f9fad4f464888e9417bd8acd13a6c79c0f3355b9e |
