{ "info": { "author": "igorcoding", "author_email": "igorcoding@gmail.com", "bugtrack_url": null, "classifiers": [ "Intended Audience :: Developers", "License :: OSI Approved :: Apache Software License", "Programming Language :: Python :: 3.5", "Programming Language :: Python :: 3.6", "Programming Language :: Python :: 3 :: Only", "Topic :: Database :: Front-Ends", "Topic :: Software Development :: Libraries :: Python Modules" ], "description": "asynctnt-queue\n==============\n\n|Build Status| |Coverage Status| |PyPI|\n\nasynctnt-queue is a python/asyncio bindings library for\n`tarantool-queue `__ package in\n`Tarantool Database `__, integrated with\n`asynctnt `__ module.\n\nDocumentation\n-------------\n\nDocumentation is available\n`here `__.\n\nInstallation\n------------\n\nUse pip to install:\n\n.. code:: bash\n\n $ pip install asynctnt-queue\n\nBasic Usage\n-----------\n\nTarantool config:\n\n.. code:: lua\n\n box.cfg {\n listen = '127.0.0.1:3301'\n }\n\n box.once('v1', function()\n box.schema.user.grant('guest', 'read,write,execute', 'universe')\n end)\n\n queue = require('queue')\n queue.create_tube('test_tube', 'fifottl')\n\nPython code:\n\n.. code:: python\n\n import asyncio\n import asynctnt\n import asynctnt_queue\n\n\n async def run():\n conn = asynctnt.Connection(host='127.0.0.1', port=3301)\n await conn.connect()\n \n queue = asynctnt_queue.Queue(conn)\n test_tube = queue.tube('test_tube')\n \n # Add a task to queue\n task = await test_tube.put({\n 'key': 'value'\n })\n \n print('Task id: {}'.format(task.task_id))\n print('Task status: {}'.format(task.status))\n \n # Retrieve a task from queue\n task = await test_tube.take(1)\n \n # ... do some work with task\n \n await task.ack()\n await conn.disconnect()\n\n loop = asyncio.get_event_loop()\n loop.run_until_complete(run())\n\nReferences\n----------\n\n1. `Tarantool `__ - in-memory database and\n application server.\n2. `asynctnt `__ - fast\n Tarantool database connector for Python/asyncio\n3. `aiotarantool `__ -\n alternative Python/asyncio connector\n\n.. |Build Status| image:: https://travis-ci.org/igorcoding/asynctnt-queue.svg?branch=master\n :target: https://travis-ci.org/igorcoding/asynctnt-queue\n.. |Coverage Status| image:: https://coveralls.io/repos/github/igorcoding/asynctnt-queue/badge.svg?branch=master\n :target: https://coveralls.io/github/igorcoding/asynctnt-queue?branch=master\n.. |PyPI| image:: https://img.shields.io/pypi/v/asynctnt-queue.svg\n :target: https://pypi.python.org/pypi/asynctnt-queue", "description_content_type": null, "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/igorcoding/asynctnt-queue", "keywords": "", "license": "Apache Software License", "maintainer": "", "maintainer_email": "", "name": "asynctnt-queue", "package_url": "https://pypi.org/project/asynctnt-queue/", "platform": "", "project_url": "https://pypi.org/project/asynctnt-queue/", "project_urls": { "Homepage": "https://github.com/igorcoding/asynctnt-queue" }, "release_url": "https://pypi.org/project/asynctnt-queue/0.0.5/", "requires_dist": null, "requires_python": "", "summary": "Tarantool Queue python/asyncio bindings", "version": "0.0.5" }, "last_serial": 3277913, "releases": { "0.0.1": [ { "comment_text": "", "digests": { "md5": "083c485c0924402a8451272e85cabf1b", "sha256": "e41f8da452a9e541c590029c654a62a43b2cb9267cafab60152072edfb26f760" }, "downloads": -1, "filename": "asynctnt-queue-0.0.1.tar.gz", "has_sig": false, "md5_digest": "083c485c0924402a8451272e85cabf1b", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 8252, "upload_time": "2017-08-15T17:49:51", "url": "https://files.pythonhosted.org/packages/6b/46/4b7a2b9f18bf5c34ae75e71802cf6a96609e2b46b6b32e5233d2bcc8774d/asynctnt-queue-0.0.1.tar.gz" } ], "0.0.2": [ { "comment_text": "", "digests": { "md5": "94fa9a131d876c71825016ee5d678ad9", "sha256": "1d7d1af4b576540bb2f4d02102e293dcb25cbfefe145c286af9b393602975fa6" }, "downloads": -1, "filename": "asynctnt-queue-0.0.2.tar.gz", "has_sig": false, "md5_digest": "94fa9a131d876c71825016ee5d678ad9", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 10542, "upload_time": "2017-08-15T22:02:37", "url": "https://files.pythonhosted.org/packages/48/97/98b4375eba5cf9ab340890d5c789cec59f82b8fda3e393d18d56209c2897/asynctnt-queue-0.0.2.tar.gz" } ], "0.0.3": [ { "comment_text": "", "digests": { "md5": "5ee485fa56034f7dd9bb9caae5a2205a", "sha256": "70a32be3f5b4dbac57f04f4919c7f6c83c902feb5a5f304c53af17bdf7bbbe35" }, "downloads": -1, "filename": "asynctnt-queue-0.0.3.tar.gz", "has_sig": false, "md5_digest": "5ee485fa56034f7dd9bb9caae5a2205a", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 10680, "upload_time": "2017-08-23T21:25:52", "url": "https://files.pythonhosted.org/packages/e8/a7/5bcc173676068470942c6489dc78d344c404eaf839ead0a66451aa84b0a4/asynctnt-queue-0.0.3.tar.gz" } ], "0.0.4": [ { "comment_text": "", "digests": { "md5": "d329823ab67318e9e7c99ad308c6dab7", "sha256": "60f168e62de0c20512323922ea3c5b3bb7b9cec1336567692088d54e2a91cccf" }, "downloads": -1, "filename": "asynctnt-queue-0.0.4.tar.gz", "has_sig": false, "md5_digest": "d329823ab67318e9e7c99ad308c6dab7", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 10798, "upload_time": "2017-09-13T11:00:19", "url": "https://files.pythonhosted.org/packages/43/29/9e11e2c1ca0465dec2c9b486df6425d0960b3a66314e9f7ea2aadfef3563/asynctnt-queue-0.0.4.tar.gz" } ], "0.0.5": [ { "comment_text": "", "digests": { "md5": "1347f72fe28a40a84ee4d13d7ee514dc", "sha256": "052ce40e031d1e8549242d11c7bd9dd8e84a43cdbb58efcc2bbf9c1fe5e84de5" }, "downloads": -1, "filename": "asynctnt-queue-0.0.5.tar.gz", "has_sig": false, "md5_digest": "1347f72fe28a40a84ee4d13d7ee514dc", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 11459, "upload_time": "2017-10-25T12:52:40", "url": "https://files.pythonhosted.org/packages/d4/cc/578937f323d3950ad758008c123a7d35c3c23de0116e4de6e78cecad0fa4/asynctnt-queue-0.0.5.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "1347f72fe28a40a84ee4d13d7ee514dc", "sha256": "052ce40e031d1e8549242d11c7bd9dd8e84a43cdbb58efcc2bbf9c1fe5e84de5" }, "downloads": -1, "filename": "asynctnt-queue-0.0.5.tar.gz", "has_sig": false, "md5_digest": "1347f72fe28a40a84ee4d13d7ee514dc", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 11459, "upload_time": "2017-10-25T12:52:40", "url": "https://files.pythonhosted.org/packages/d4/cc/578937f323d3950ad758008c123a7d35c3c23de0116e4de6e78cecad0fa4/asynctnt-queue-0.0.5.tar.gz" } ] }