{ "info": { "author": "Nik Liolios", "author_email": "nik@asktetra.com", "bugtrack_url": null, "classifiers": [ "Development Status :: 4 - Beta", "Framework :: AsyncIO", "Intended Audience :: Developers", "License :: OSI Approved :: MIT License", "Operating System :: OS Independent", "Programming Language :: Python :: 3", "Programming Language :: Python :: 3.3", "Programming Language :: Python :: 3.4", "Programming Language :: Python :: 3.5", "Programming Language :: Python :: 3.6", "Topic :: System :: Distributed Computing", "Topic :: System :: Networking" ], "description": "AIOKinesis\n==========\n\nAsyncio client library for AWS Kinesis\n\nInstallation\n------------\n```\npip install aiokinesis\n```\n\nAIOKinesisProducer\n------------------\nUsage:\n```python\n import asycio\n from aiokinesis import AIOKinesisProducer\n\n async def send_message():\n loop = asyncio.get_event_loop()\n producer = AIOKinesisProducer('my-stream-name', loop, region_name='us-east-1')\n await producer.start()\n\n await producer.send('partition-key', {'data': 'blah'})\n\n await asyncio.sleep(1)\n await producer.stop()\n\n loop.run_until_complete(send_message())\n```\nLimitations:\n - Stopping the producer before all messages are sent will prevent in flight messages from being sent\n - AIOKinesis only supports one shard so the producer is rate limited to 5 requests per rolling second\n\nAIOKinesisConsumer\n------------------\nUsage:\n```python\n import asyncio\n from aiokinesis import AIOKinesisConsumer\n\n async def get_messages():\n loop = asyncio.get_event_loop()\n consumer = AIOKinesisConsumer('my-stream-name', loop, region_name='us-east-1')\n await consumer.start()\n\n try:\n async for message in consumer:\n print(\"Consumed message: \", message)\n except KeyboardInterrupt:\n await consumer.stop()\n\n loop.run_until_complete()\n```\nLimitations:\n - AIOKinesis only supports one shard so the consumer is rate limited to 5 requests per rolling second\n\n", "description_content_type": "", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "", "keywords": "", "license": "", "maintainer": "", "maintainer_email": "", "name": "aiokinesis", "package_url": "https://pypi.org/project/aiokinesis/", "platform": "", "project_url": "https://pypi.org/project/aiokinesis/", "project_urls": null, "release_url": "https://pypi.org/project/aiokinesis/0.0.4/", "requires_dist": [ "boto3 (==1.7.29)" ], "requires_python": "", "summary": "Asyncio kinesis client", "version": "0.0.4" }, "last_serial": 3937372, "releases": { "0.0.1": [ { "comment_text": "", "digests": { "md5": "9c6f18467828132df063b9d8e3082c33", "sha256": "5615726ba6d049d394286cb1e1c5a376342394f0cb8eeba9ec80e86732fb46aa" }, "downloads": -1, "filename": "aiokinesis-0.0.1-py3.6.egg", "has_sig": false, "md5_digest": "9c6f18467828132df063b9d8e3082c33", "packagetype": "bdist_egg", "python_version": "3.6", "requires_python": null, "size": 9027, "upload_time": "2018-05-31T00:05:41", "url": "https://files.pythonhosted.org/packages/0f/03/4b747b4df5102e70bf196661be0373451e64b5cdf8321b105b9a2c9f3201/aiokinesis-0.0.1-py3.6.egg" }, { "comment_text": "", "digests": { "md5": "e9157f3a6c71363ca880bbc468e823ee", "sha256": "21cfed12656cc92c38848308864517a49696b1143e8c0efd241702dae5a207eb" }, "downloads": -1, "filename": "aiokinesis-0.0.1-py3-none-any.whl", "has_sig": false, "md5_digest": "e9157f3a6c71363ca880bbc468e823ee", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 4682, "upload_time": "2018-05-31T00:05:39", "url": "https://files.pythonhosted.org/packages/fd/6e/bb1cfee5d2b5a153c90829d4bef5645b0af72d9576c8a0ad9a24b61962a3/aiokinesis-0.0.1-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "8300d2a0c06b8ac48d39a0f5df60300e", "sha256": "e22f7dcf7e0bcf78cc37b311195b4757fd575247b8ed586ec46e1d23db0ea9a2" }, "downloads": -1, "filename": "aiokinesis-0.0.1.tar.gz", "has_sig": false, "md5_digest": "8300d2a0c06b8ac48d39a0f5df60300e", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3575, "upload_time": "2018-05-31T00:05:42", "url": "https://files.pythonhosted.org/packages/21/ec/fe6badd8d9505496baf83bc2a33892ec4f21d117a7c0bed79eeeac39145d/aiokinesis-0.0.1.tar.gz" } ], "0.0.2": [ { "comment_text": "", "digests": { "md5": "6dd9e7295455f409abdac1e51b6b8c32", "sha256": "64afb5259ae0a7b6f28fa3e7e48598a02b5a3d3098b96622baa0b98a5af41a94" }, "downloads": -1, "filename": "aiokinesis-0.0.2-py3-none-any.whl", "has_sig": false, "md5_digest": "6dd9e7295455f409abdac1e51b6b8c32", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 4705, "upload_time": "2018-05-31T20:19:54", "url": "https://files.pythonhosted.org/packages/b4/07/347e54d0823df298c7c620219de187e2f037273eb1838c8c4a85a4895aa4/aiokinesis-0.0.2-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "a8af3a201deedcfff673e172e4d1e1af", "sha256": "2a305598f6c354e2eb4f1647fe2f239baa18a133bcb96c9bf1f88d7f15919810" }, "downloads": -1, "filename": "aiokinesis-0.0.2.tar.gz", "has_sig": false, "md5_digest": "a8af3a201deedcfff673e172e4d1e1af", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3611, "upload_time": "2018-05-31T20:19:55", "url": "https://files.pythonhosted.org/packages/00/8b/c6368b7fe679876c931675c42aa99ab40352772e27ebb4442dbd19b704bf/aiokinesis-0.0.2.tar.gz" } ], "0.0.3": [ { "comment_text": "", "digests": { "md5": "5cf5fff5c612927f7ea69e0b0821ebb6", "sha256": "6fa90b8fbcf5f6020625dfa520124ecfcac6c4d507e90c2233d4ff204580637f" }, "downloads": -1, "filename": "aiokinesis-0.0.3-py3-none-any.whl", "has_sig": false, "md5_digest": "5cf5fff5c612927f7ea69e0b0821ebb6", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 4707, "upload_time": "2018-05-31T22:20:45", "url": "https://files.pythonhosted.org/packages/c9/d9/f1348a0945e43c666c26296a1fac4fcc1159d368088dfad907649645365a/aiokinesis-0.0.3-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "a87f4aed2e998ed53c1977b878f9a49e", "sha256": "eca72023150ea07a905e086530059c8f01df88e32210d40ac3a0363fd94d7291" }, "downloads": -1, "filename": "aiokinesis-0.0.3.tar.gz", "has_sig": false, "md5_digest": "a87f4aed2e998ed53c1977b878f9a49e", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3610, "upload_time": "2018-05-31T22:20:46", "url": "https://files.pythonhosted.org/packages/d5/5e/4c9a565fb2fc6151f8d545983151f57c4e8f7f855c851968451bca45e868/aiokinesis-0.0.3.tar.gz" } ], "0.0.4": [ { "comment_text": "", "digests": { "md5": "6ad1aa4320e516c6a5291721c27799a9", "sha256": "ca6e73a13aac3e5ee0c48ddd95b5239e01d3169a995ef9a9ce7e97965d9d1101" }, "downloads": -1, "filename": "aiokinesis-0.0.4-py3-none-any.whl", "has_sig": false, "md5_digest": "6ad1aa4320e516c6a5291721c27799a9", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 4833, "upload_time": "2018-06-06T20:31:40", "url": "https://files.pythonhosted.org/packages/03/05/00ae1898c467b19720389cb5e6d71c0ee8aa2d05cb9d79165172526fc586/aiokinesis-0.0.4-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "4af0b1135413797b7d1cdd357c96bfba", "sha256": "d0fc0c7341a23cb4d933d1e891cfbe8ae41075c674cdd7795c8b756c29ec97a2" }, "downloads": -1, "filename": "aiokinesis-0.0.4.tar.gz", "has_sig": false, "md5_digest": "4af0b1135413797b7d1cdd357c96bfba", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3682, "upload_time": "2018-06-06T20:31:41", "url": "https://files.pythonhosted.org/packages/97/af/1f5a0ee5f2cb3a00ab838ff998cc03bc5ae76a574856549e8bdae48dda93/aiokinesis-0.0.4.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "6ad1aa4320e516c6a5291721c27799a9", "sha256": "ca6e73a13aac3e5ee0c48ddd95b5239e01d3169a995ef9a9ce7e97965d9d1101" }, "downloads": -1, "filename": "aiokinesis-0.0.4-py3-none-any.whl", "has_sig": false, "md5_digest": "6ad1aa4320e516c6a5291721c27799a9", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 4833, "upload_time": "2018-06-06T20:31:40", "url": "https://files.pythonhosted.org/packages/03/05/00ae1898c467b19720389cb5e6d71c0ee8aa2d05cb9d79165172526fc586/aiokinesis-0.0.4-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "4af0b1135413797b7d1cdd357c96bfba", "sha256": "d0fc0c7341a23cb4d933d1e891cfbe8ae41075c674cdd7795c8b756c29ec97a2" }, "downloads": -1, "filename": "aiokinesis-0.0.4.tar.gz", "has_sig": false, "md5_digest": "4af0b1135413797b7d1cdd357c96bfba", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3682, "upload_time": "2018-06-06T20:31:41", "url": "https://files.pythonhosted.org/packages/97/af/1f5a0ee5f2cb3a00ab838ff998cc03bc5ae76a574856549e8bdae48dda93/aiokinesis-0.0.4.tar.gz" } ] }