A persistent, (mostly) atomic queue (like deque or Queue) implemented with redis backing.
Project description
- redis_queue is useful for implementing a multi-producer,
multi-consumer job queue. While it doesn’t have all the handy blocking and locking features of Queue, it does have the advantages of being multi-process safe and persistant.
- Example Usage:::
>>> from redis import Redis >>> from redis_queue import Queue >>> redis = Redis(host='127.0.0.1', port=6379) >>> queue = Queue(redis, 'test_queue') >>> queue.append('one') >>> queue.append('two') >>> queue.append('three') >>> queue.pop() 'three' >>> queue.pop() 'two' >>> queue.pop() 'one' >>> queue.append('one') >>> queue.append('two') >>> queue.append('three') >>> queue.popleft() 'one' >>> queue.popleft() 'two' >>> queue.popleft() 'three'
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
redis_queue-0.5.tar.gz
(7.5 kB
view details)
File details
Details for the file redis_queue-0.5.tar.gz
.
File metadata
- Download URL: redis_queue-0.5.tar.gz
- Upload date:
- Size: 7.5 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | beccfd48e19e7c0603a7cbdf4bfce23e449470ba2d4a2bc79cfe9733ab0ff842 |
|
MD5 | 786cc7999ba721c6c60b271b2dbec471 |
|
BLAKE2b-256 | 6ff704822d1dd353740d6066481c733691277d2497d08e84fb7431668b7e38d7 |