{ "info": { "author": "Ryan Brown", "author_email": "sb@ryansb.com", "bugtrack_url": null, "classifiers": [ "License :: OSI Approved :: Apache Software License", "Natural Language :: English", "Operating System :: POSIX :: Linux", "Programming Language :: Python :: 2.7", "Programming Language :: Python :: 3", "Programming Language :: Python :: 3.3", "Programming Language :: Python :: 3.4" ], "description": "# disq\n\nA [disque](https://github.com/antirez/disque) Python client.\n\n[ ![Codeship Status for ryansb/disq](https://codeship.com/projects/d4928e10-d02e-0132-8d50-1a50b84b9184/status?branch=master)](https://codeship.com/projects/76941)\n\nUnder the hood, this used redis-py's HiRedis implementation and switches out\nRedis commands with the disque ones.\n\n## Usage\n\n```\nfrom disq import Disque\n\nc = Disque() # connects to localhost:7711 by default\nc.addjob('queuename', 'body') # takes all ADDJOB arguments\n# b'DI... job id ...SQ'\nc.getjob('queuename')\n# [[b'queue', b'DI3971f14a850d9e5b3ca5c881e3dd1ba2a34277b505a0SQ', b'body']]\n```\n\n## Status\n\nThis library is ready to use with single or multi-node clusters. All commands\nare implemented except for `QSTAT` and `SCAN`, which don't exist in the disque\nserver yet.\n\n## Features\n\n### Connection Balancing\n\nAs specified in the [disque README][clients], disq directs read and ack\noperations (GETJOB, ACKJOB, FASTACK) to whichever member of the cluster it has\nreceived the most jobs from in the last N seconds.\n\nTo change the length of the job count window, use the `job_origin_ttl_secs`\nargument when creating the disque client.\n\n## License\n\nThis code is released under the ASL2.0, see the `LICENSE` file for details.\n\n## Thanks\n\nEnormous thanks to Salvatore Sanfilippo (antirez) for writing\n[disque](https://github.com/antirez/disque) and\n[Andy McCurdy](https://github.com/andymccurdy), author of the\n[redis-py](https://github.com/andymccurdy/redis-py) module.\n\n[clients]: https://github.com/antirez/disque#client-libraries", "description_content_type": null, "docs_url": null, "download_url": "UNKNOWN", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/ryansb/disq", "keywords": "disque\ndisq\nredis", "license": "ASL2.0", "maintainer": null, "maintainer_email": null, "name": "disq", "package_url": "https://pypi.org/project/disq/", "platform": "UNKNOWN", "project_url": "https://pypi.org/project/disq/", "project_urls": { "Download": "UNKNOWN", "Homepage": "https://github.com/ryansb/disq" }, "release_url": "https://pypi.org/project/disq/0.0.4/", "requires_dist": null, "requires_python": null, "summary": "Python Disque client (very very alpha, as is Disque itself)", "version": "0.0.4" }, "last_serial": 1528744, "releases": { "0.0.0.post1": [], "0.0.1": [ { "comment_text": "", "digests": { "md5": "c9018baf30d92793a3ecb4b81dd357b8", "sha256": "c15291ef7670eeeaf6cd0ff1df67639c74b02fdd3069b853228887cb7effe123" }, "downloads": -1, "filename": "disq-0.0.1.tar.gz", "has_sig": false, "md5_digest": "c9018baf30d92793a3ecb4b81dd357b8", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 9235, "upload_time": "2015-04-28T18:04:06", "url": "https://files.pythonhosted.org/packages/a2/0a/819e82dec662fd53bd238e6673c0fb6edfcea6e454f9142982e033f187bb/disq-0.0.1.tar.gz" } ], "0.0.2": [ { "comment_text": "", "digests": { "md5": "d8c36ba1d01df321b284e94436503696", "sha256": "0a8f02c9372dd26cfa447ba20555577a61082f01744696148cc7cd1db3ac4887" }, "downloads": -1, "filename": "disq-0.0.2.tar.gz", "has_sig": false, "md5_digest": "d8c36ba1d01df321b284e94436503696", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 12547, "upload_time": "2015-04-29T13:29:00", "url": "https://files.pythonhosted.org/packages/e5/db/c7492a55c1f41726c93eddd1cc79f015b96c6674c3487f8b9cf2472d2090/disq-0.0.2.tar.gz" } ], "0.0.3": [ { "comment_text": "", "digests": { "md5": "c187d2222b4d09b0ee8daea88523c10e", "sha256": "bb4b0184c151ba38431a9865b9ba23cbb9ba7088b9f028048d8468fa7aeef600" }, "downloads": -1, "filename": "disq-0.0.3.tar.gz", "has_sig": false, "md5_digest": "c187d2222b4d09b0ee8daea88523c10e", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 15490, "upload_time": "2015-04-30T02:19:53", "url": "https://files.pythonhosted.org/packages/88/55/9c398b9e6b87bacc46a81acb635da3f9e04c8fc0da32b445ef8d7ba857ef/disq-0.0.3.tar.gz" } ], "0.0.4": [ { "comment_text": "", "digests": { "md5": "56801e8f68abd31b63d58e1520c28ea4", "sha256": "9507f49ecb11cb24cbe97c407151b410d06263bc36be8b741ae5cfab8fbfa5e5" }, "downloads": -1, "filename": "disq-0.0.4.tar.gz", "has_sig": false, "md5_digest": "56801e8f68abd31b63d58e1520c28ea4", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 17071, "upload_time": "2015-05-01T00:06:20", "url": "https://files.pythonhosted.org/packages/f3/26/02e0139a12292f0a7a50ca18ba096355e9d415093d84e8bff5e70300b48c/disq-0.0.4.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "56801e8f68abd31b63d58e1520c28ea4", "sha256": "9507f49ecb11cb24cbe97c407151b410d06263bc36be8b741ae5cfab8fbfa5e5" }, "downloads": -1, "filename": "disq-0.0.4.tar.gz", "has_sig": false, "md5_digest": "56801e8f68abd31b63d58e1520c28ea4", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 17071, "upload_time": "2015-05-01T00:06:20", "url": "https://files.pythonhosted.org/packages/f3/26/02e0139a12292f0a7a50ca18ba096355e9d415093d84e8bff5e70300b48c/disq-0.0.4.tar.gz" } ] }