{ "info": { "author": "Xiongfei Shi", "author_email": "jenson.shixf@gmail.com", "bugtrack_url": null, "classifiers": [ "Intended Audience :: Developers", "License :: OSI Approved :: Apache Software License", "Operating System :: OS Independent", "Programming Language :: Python", "Topic :: Software Development :: Libraries :: Python Modules", "Topic :: Software Development :: Object Brokering", "Topic :: System :: Distributed Computing" ], "description": "redque\n======\n\nA distributed queue based on Redis\n\nInstallation\n------------\n\n.. code-block:: python\n\n pip install redque\n\nExample\n-------\n\n.. code-block:: python\n\n import time\n import random\n import threading\n import redis\n import redque\n\n\n def productor(redis_conn):\n other_queue = redque.Queue(redis_conn, \"__test\", \"bp__test\")\n\n for _ in range(100):\n other_queue.push(\"e_{0}\".format(random.randint(1, 100)))\n time.sleep(0.1)\n\n\n if __name__ == \"__main__\":\n pool = redis.ConnectionPool(\n host=\"127.0.0.1\",\n port=6379,\n password=\"123456\"\n )\n\n queue = redque.Queue(\n redis.Redis(connection_pool=pool),\n \"__test\",\n \"bp__test\"\n )\n queue.clear(True)\n\n # non-blocking\n for _ in range(100):\n queue.push(random.randint(1, 100))\n\n queue.process(lambda x: (print(x), True), False)\n\n # blocking\n t = threading.Thread(target=productor,\n args=(redis.Redis(connection_pool=pool),))\n t.start()\n\n queue.process(lambda x: (print(x), True), timeout=3)\n\n t.join()\n\n\n", "description_content_type": "", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/shixiongfei/redque", "keywords": "Redis,Queue", "license": "", "maintainer": "Xiongfei Shi", "maintainer_email": "jenson.shixf@gmail.com", "name": "redque", "package_url": "https://pypi.org/project/redque/", "platform": "", "project_url": "https://pypi.org/project/redque/", "project_urls": { "Homepage": "https://github.com/shixiongfei/redque" }, "release_url": "https://pypi.org/project/redque/0.1.0/", "requires_dist": [ "redis" ], "requires_python": "", "summary": "A distributed queue based on Redis.", "version": "0.1.0" }, "last_serial": 5749403, "releases": { "0.1.0": [ { "comment_text": "", "digests": { "md5": "b8ee31cebadacdbbd0f52865c77fa788", "sha256": "9398b35dab574b2300a756503f9db8418ef250ef54e9ca4940dd9439125464d3" }, "downloads": -1, "filename": "redque-0.1.0-py3-none-any.whl", "has_sig": false, "md5_digest": "b8ee31cebadacdbbd0f52865c77fa788", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 6642, "upload_time": "2019-08-29T06:49:18", "url": "https://files.pythonhosted.org/packages/8d/9b/6162fd0fb3934c2a008d1ef58ec9e4461f03e3d1d986801e1e63591a5281/redque-0.1.0-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "d3a5d17f766eb49bba3faf5d282416ff", "sha256": "1e2dac63d8453b6d5f49aa7ec3a085e6a8356ae63d05bdcbe41fbfc3276fdb16" }, "downloads": -1, "filename": "redque-0.1.0.tar.gz", "has_sig": false, "md5_digest": "d3a5d17f766eb49bba3faf5d282416ff", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 2573, "upload_time": "2019-08-29T06:49:20", "url": "https://files.pythonhosted.org/packages/27/4c/3259e7da7395d765cda5cc50dcb9718dacf7b575ca9526d9362bf8145af2/redque-0.1.0.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "b8ee31cebadacdbbd0f52865c77fa788", "sha256": "9398b35dab574b2300a756503f9db8418ef250ef54e9ca4940dd9439125464d3" }, "downloads": -1, "filename": "redque-0.1.0-py3-none-any.whl", "has_sig": false, "md5_digest": "b8ee31cebadacdbbd0f52865c77fa788", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 6642, "upload_time": "2019-08-29T06:49:18", "url": "https://files.pythonhosted.org/packages/8d/9b/6162fd0fb3934c2a008d1ef58ec9e4461f03e3d1d986801e1e63591a5281/redque-0.1.0-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "d3a5d17f766eb49bba3faf5d282416ff", "sha256": "1e2dac63d8453b6d5f49aa7ec3a085e6a8356ae63d05bdcbe41fbfc3276fdb16" }, "downloads": -1, "filename": "redque-0.1.0.tar.gz", "has_sig": false, "md5_digest": "d3a5d17f766eb49bba3faf5d282416ff", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 2573, "upload_time": "2019-08-29T06:49:20", "url": "https://files.pythonhosted.org/packages/27/4c/3259e7da7395d765cda5cc50dcb9718dacf7b575ca9526d9362bf8145af2/redque-0.1.0.tar.gz" } ] }