Description:

disq 0.0.4

# disqA [disque](https://github.com/antirez/disque) Python client.[ ](https://codeship.com/projects/76941)Under the hood, this used redis-py's HiRedis implementation and switches outRedis commands with the disque ones.## Usage```from disq import Disquec = Disque() # connects to localhost:7711 by defaultc.addjob('queuename', 'body') # takes all ADDJOB arguments# b'DI... job id ...SQ'c.getjob('queuename')# [[b'queue', b'DI3971f14a850d9e5b3ca5c881e3dd1ba2a34277b505a0SQ', b'body']]```## StatusThis library is ready to use with single or multi-node clusters. All commandsare implemented except for `QSTAT` and `SCAN`, which don't exist in the disqueserver yet.## Features### Connection BalancingAs specified in the [disque README][clients], disq directs read and ackoperations (GETJOB, ACKJOB, FASTACK) to whichever member of the cluster it hasreceived the most jobs from in the last N seconds.To change the length of the job count window, use the `job_origin_ttl_secs`argument when creating the disque client.## LicenseThis code is released under the ASL2.0, see the `LICENSE` file for details.## ThanksEnormous thanks to Salvatore Sanfilippo (antirez) for writing[disque](https://github.com/antirez/disque) and[Andy McCurdy](https://github.com/andymccurdy), author of the[redis-py](https://github.com/andymccurdy/redis-py) module.[clients]: https://github.com/antirez/disque#client-libraries

License

For personal and professional use. You cannot resell or redistribute these repositories in their original state.

Share

• Share on Facebook
• Share on Twitter