{ "info": { "author": "David Francos Cuartero", "author_email": "opensource@davidfrancos.net", "bugtrack_url": null, "classifiers": [ "Development Status :: 4 - Beta", "Environment :: Console", "Intended Audience :: Information Technology", "License :: OSI Approved :: GNU General Public License (GPL)", "Operating System :: POSIX :: Linux", "Programming Language :: Python" ], "description": "TQueues\n=======\n\nTQueues (reThinkdb Queues) is a simple python3.5+\nlibrary for queueing jobs and processing them in workers using rethinkdb.\n\n\nFeatures\n--------\n\n- Accepts *coroutines* as jobs\n- Distributed\n- Handles everything in a *rethinkdb database object* that can be reused\n at the worker\n- Exposes changes via websockets\n- Uses rethinkdb streaming \"changes\" method, wich is pretty efficient\n- Uses asyncio, implements an async context manager for jobs and\n async iterator for the workers\n\n::\n\n +--> Worker\n |\n Rethindb --> Dispatcher ---> Worker\n |\n +--> Worker\n\n\n\n\nUsage\n=====\n\nTQueues provides two entry points, tqueues_dispatcher and tqueues_worker.\n\nTQueues dispatcher must be accesible from all workers, and you need to start\none worker per parallel task you need. They may be distributed (as long as\nthey can reach the dispatcher)\n\nTQueues worker\n--------------\n\n::\n\n Usage:\n \ttqueues_worker -h | --help\n \ttqueues_worker --version\n \ttqueues_worker --endpoint_url \n \ttqueues_worker --queue \n\n Options:\n \t-h --help Show this screen\n \t-v --version Show version\n \t--endpoint_url TQueues dispatcher endpoint\n \t--queue Endpoint queue to listen on\n\n Examples:\n \ttqueues_worker --endpoint_url http://127.0.0.1:800/ --queue testqueue\n\n\nTQueues job dispatcher\n----------------------\n\n::\n\n Usage:\n tqueues_dispatcher --db \"db\" --host \"127.0.0.1\" --port 28015\n tqueues_dispatcher --db \"db\" --host \"127.0.0.1\"\n tqueues_dispatcher --db \"db\" --port 28015\n tqueues_dispatcher --db \"db\" --user 'user'\n tqueues_dispatcher --db \"db\" --password 'password'\n tqueues_dispatcher -h | --help\n tqueues_dispatcher --version\n\n Options:\n --host \"127.0.0.1\" Rethinkdb host\n --db \"db\" Rethinkdb databaes\n --port 28015 Rethinkdb port\n --user 'user' Rethinkdb user\n --password 'password' Rethinkdb password\n --allowed_domains 'foo.com,bar.com' Allowed domains\n --loglevel (DEBUG|INFO) Loglevel\n -h --help Show this screen\n --version Show version\n\n Examples:\n tqueues_dispatcher --host localhost --db foo --port 28015 --user foo --password bar --loglevel INFO --allowed_domains 'foo.com,bar.com'", "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/XayOn/tqueues", "keywords": "jobs\nrethinkdb\nqueues", "license": "Apache-2", "maintainer": null, "maintainer_email": null, "name": "tqueues", "package_url": "https://pypi.org/project/tqueues/", "platform": "UNKNOWN", "project_url": "https://pypi.org/project/tqueues/", "project_urls": { "Download": "UNKNOWN", "Homepage": "https://github.com/XayOn/tqueues" }, "release_url": "https://pypi.org/project/tqueues/0.1.7/", "requires_dist": null, "requires_python": null, "summary": "Rethinkdb job queues", "version": "0.1.7" }, "last_serial": 2176223, "releases": { "0.0.1.dev10": [ { "comment_text": "", "digests": { "md5": "1591baf8ec479d32675c8d0694f6ea1f", "sha256": "e062ca96df20727b37da703fdde7f0a40303ca1de5bcc68a6edbfe39364c77c0" }, "downloads": -1, "filename": "tqueues-0.0.1.dev10.tar.gz", "has_sig": false, "md5_digest": "1591baf8ec479d32675c8d0694f6ea1f", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3286, "upload_time": "2016-04-18T23:51:04", "url": "https://files.pythonhosted.org/packages/36/51/d4decb80dfe5b0c67f455ea6b96fb64bc6922070d644a5458fb95a4abda5/tqueues-0.0.1.dev10.tar.gz" } ], "0.0.1.dev6": [], "0.1.1.dev1": [ { "comment_text": "", "digests": { "md5": "2ed391c2b412066fdcebdb0f8c7337a3", "sha256": "e0f0f439a0892f2c31e4798a304dbfbbda36dc127521f0a0d68dda71fea4b3a5" }, "downloads": -1, "filename": "tqueues-0.1.1.dev1.tar.gz", "has_sig": false, "md5_digest": "2ed391c2b412066fdcebdb0f8c7337a3", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3293, "upload_time": "2016-04-18T23:55:54", "url": "https://files.pythonhosted.org/packages/3a/79/5875732df51f8d99dab84310f0d7c4f67a22def2a2b7d9cd32043090c00a/tqueues-0.1.1.dev1.tar.gz" } ], "0.1.2": [ { "comment_text": "", "digests": { "md5": "3ada0a3148fdb5c566840be176d20dda", "sha256": "92990051cc685144c5fdb6863027d11c09232e97fa5e9da6620ae7fde823821e" }, "downloads": -1, "filename": "tqueues-0.1.2.tar.gz", "has_sig": false, "md5_digest": "3ada0a3148fdb5c566840be176d20dda", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3327, "upload_time": "2016-04-24T15:13:45", "url": "https://files.pythonhosted.org/packages/e8/48/948e1fd1d47fd8f33564664e428b3611ed6398e9f8c7e84ee5d84ca282b0/tqueues-0.1.2.tar.gz" } ], "0.1.3.dev1": [ { "comment_text": "", "digests": { "md5": "be49303af79ee70cac62d63ca76f9dc9", "sha256": "496a961bc529c712d3522a9808ef91bf9dae3a0498fb2ff41e85e66095598d1c" }, "downloads": -1, "filename": "tqueues-0.1.3.dev1.tar.gz", "has_sig": false, "md5_digest": "be49303af79ee70cac62d63ca76f9dc9", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3340, "upload_time": "2016-04-24T15:11:41", "url": "https://files.pythonhosted.org/packages/0b/05/e779ef08a46851ffdce1aac89757d3881fa2911d72abca3b95cee677fd4f/tqueues-0.1.3.dev1.tar.gz" } ], "0.1.7": [ { "comment_text": "", "digests": { "md5": "f916822ac706fbd8a09d9473426a8ded", "sha256": "e01aa651686adbc4de8c0f45bb73e7ece339b234c08594d1e34832688071639c" }, "downloads": -1, "filename": "tqueues-0.1.7.tar.gz", "has_sig": false, "md5_digest": "f916822ac706fbd8a09d9473426a8ded", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 15401, "upload_time": "2016-06-19T20:13:49", "url": "https://files.pythonhosted.org/packages/ea/2e/6c32f4d9e927ddd607b0648f67e76cc276b3e16003811592a38cca9a1fe5/tqueues-0.1.7.tar.gz" } ], "0.1.8.dev1": [ { "comment_text": "", "digests": { "md5": "ef335c6d17f1c83b74a047bec30492ef", "sha256": "b5fc48348f0d9792cadd027d91e03aef87c387bde5b2cba0b8cfaa002bae8f6d" }, "downloads": -1, "filename": "tqueues-0.1.8.dev1.tar.gz", "has_sig": false, "md5_digest": "ef335c6d17f1c83b74a047bec30492ef", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 15413, "upload_time": "2016-06-19T20:13:44", "url": "https://files.pythonhosted.org/packages/d3/5b/fa66e5703eeee2c044d4d0d3e5c77902eab0cb347e448e12f13df73d2493/tqueues-0.1.8.dev1.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "f916822ac706fbd8a09d9473426a8ded", "sha256": "e01aa651686adbc4de8c0f45bb73e7ece339b234c08594d1e34832688071639c" }, "downloads": -1, "filename": "tqueues-0.1.7.tar.gz", "has_sig": false, "md5_digest": "f916822ac706fbd8a09d9473426a8ded", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 15401, "upload_time": "2016-06-19T20:13:49", "url": "https://files.pythonhosted.org/packages/ea/2e/6c32f4d9e927ddd607b0648f67e76cc276b3e16003811592a38cca9a1fe5/tqueues-0.1.7.tar.gz" } ] }