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 empty1 maintainer
Metadata
1 maintainer
Release files for moonqueue 0.3.1
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| moonqueue-0.3.1.tar.gz | 4.0 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| moonqueue-0.3.1-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 21.2 kB
Release files / moonqueue-0.3.1.tar.gz
| Download URL | moonqueue-0.3.1.tar.gz |
|---|---|
| Size | 4.0 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
b3c43c902d6b57e6e38f74c3dc1d832d8f609fc71b141286ff239577af31f8f4
|
|
BLAKE2b-256 checksum How to use checksums |
c2149741b42796efbbd3dd456b8880bdb78384d94456ffc4503ffe52c6142d74
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
Python-urllib/3.7
|
Release files / moonqueue-0.3.1-py3-none-any.whl
| Download URL | moonqueue-0.3.1-py3-none-any.whl |
|---|---|
| Size | 17.2 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
6b66c3d5e64b69cf31ba7f21c7ecc7143ec9e11de75aaa58a124b6cd0ed64299
|
|
BLAKE2b-256 checksum How to use checksums |
3f6a78492cf98d040028140f9fad4f464888e9417bd8acd13a6c79c0f3355b9e
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
Python-urllib/3.7
|
