{ "info": { "author": "German Gomez-Herrero, FindHotel BV", "author_email": "german@findhotel.net", "bugtrack_url": null, "classifiers": [ "Programming Language :: Python :: 3" ], "description": "Kinesis utilities\n=================\n\n|PyPI|\n\nMiscellaneous utilities for `AWS\nKinesis `__.\n\nInstallation\n------------\n\n::\n\n pip install kinesisutils\n\nTo install the development version:\n\n::\n\n pip install git+https://github.com/findhotel/kinesisutils\n\nUsage\n-----\n\nAt the moment there is only one utility implemented: a Python generator\nthat reads records from a Kinesis stream. You can use it like this:\n\n::\n\n import json\n\n from kinesisutils.kinesisutils import KinesisGenerator\n\n # Hit Kinesis with at most 10 requests per second, usin json.loads to\n # deserialize the Kinesis records (the default). You could deactivate record\n # deserialization by setting des=None.\n kg = KinesisGenerator(\"stream_name\", rqs=10, des=json.loads)\n\n for rec in kg:\n print(rec)\n\nBy default the generator will keep pulling records from Kinesis for 60\nseconds. You can customize this timeout if you want:\n\n::\n\n from kinesisutils.kinesisutils import KinesisGenerator\n\n kg = KinesisGenerator(\"stream_name\", timeout=30)\n\n for rec in kg:\n print(rec)\n\nIf you are using the Kinesis generator to read Cloudwatch log events\nthat are being forwarded to a Kinesis stream using a [logs\nsubscription][logsubs] you will need to decompress the Cloudwatch\nrecords before deserializing them:\n\n::\n\n import decompress\n import json\n\n kg = KinesisGenerator(\"stream_name\", rqs=10, des=json.loads,\n preprocess=gzip.decompress)\n\n for rec in kg:\n print(rec)\n\nContact\n-------\n\nIf you have questions, bug reports, suggestions, etc. please create an\nissue on the `GitHub project\npage `__. PRs are also\nwelcome.\n\nLicense\n-------\n\nThis software is licensed under the `MIT\nlicense `__.\n\nSee `License\nfile `__.\n\n\u00a9 2017 German Gomez-Herrero, `Find\nHotel `__ and others.\n\n.. |PyPI| image:: https://img.shields.io/pypi/v/kinesisutils.svg?style=flat\n :target: https://pypi.python.org/pypi/kinesisutils\n", "description_content_type": null, "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/findhotel/kinesisutils", "keywords": "", "license": "MIT", "maintainer": "", "maintainer_email": "", "name": "kinesisutils", "package_url": "https://pypi.org/project/kinesisutils/", "platform": "", "project_url": "https://pypi.org/project/kinesisutils/", "project_urls": { "Homepage": "https://github.com/findhotel/kinesisutils" }, "release_url": "https://pypi.org/project/kinesisutils/0.0.6/", "requires_dist": null, "requires_python": "", "summary": "Kinesis utilities", "version": "0.0.6" }, "last_serial": 2904777, "releases": { "0.0.1": [ { "comment_text": "", "digests": { "md5": "185f59519f9faf05f96c3a3eac3ecb32", "sha256": "0daf40710ab54c058c429a085ced35fadfe6fc7b78065b81cd4fe92206d77109" }, "downloads": -1, "filename": "kinesisutils-0.0.1.tar.gz", "has_sig": false, "md5_digest": "185f59519f9faf05f96c3a3eac3ecb32", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 2467, "upload_time": "2017-05-26T14:59:53", "url": "https://files.pythonhosted.org/packages/7f/96/700abbc67d52184e89c35cdc6445724171a6aeb714b5b8232f0fe2c1a432/kinesisutils-0.0.1.tar.gz" } ], "0.0.2": [ { "comment_text": "", "digests": { "md5": "9a69bc37e84b57e4e09897545ee84699", "sha256": "9e472b6da77c8220caf34acc705fb51afce0fb5fc596820efdb864e9ed76346b" }, "downloads": -1, "filename": "kinesisutils-0.0.2.tar.gz", "has_sig": false, "md5_digest": "9a69bc37e84b57e4e09897545ee84699", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3324, "upload_time": "2017-05-26T15:28:09", "url": "https://files.pythonhosted.org/packages/af/8c/7e1b106d3a1cb4bbdc5c15e877ebbb5b905b4ecdcbd75bf537b869e1391e/kinesisutils-0.0.2.tar.gz" } ], "0.0.3": [ { "comment_text": "", "digests": { "md5": "970199e69d58b96539d19d7e43a3efd1", "sha256": "228c0f1f5676543d4c6328cf6e5fef7e85231163217380291ca562445ce45a9b" }, "downloads": -1, "filename": "kinesisutils-0.0.3.tar.gz", "has_sig": false, "md5_digest": "970199e69d58b96539d19d7e43a3efd1", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3337, "upload_time": "2017-05-26T16:04:02", "url": "https://files.pythonhosted.org/packages/88/29/aaefba795cdc2dd506d5cf3e79218311f89b26b105fb0b972eacd1713174/kinesisutils-0.0.3.tar.gz" } ], "0.0.4": [ { "comment_text": "", "digests": { "md5": "444fb99b9f7a350fd1a3ed7de58eedc6", "sha256": "b27e2e31f4f2b4f9b61ce1be53042425075cb804842c1a7233a8336a48ca3447" }, "downloads": -1, "filename": "kinesisutils-0.0.4.tar.gz", "has_sig": false, "md5_digest": "444fb99b9f7a350fd1a3ed7de58eedc6", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3315, "upload_time": "2017-05-26T19:06:43", "url": "https://files.pythonhosted.org/packages/14/4f/abaf68d34fe0eb67b616ace48591249ae64b3e2e03135ac8a3151306af17/kinesisutils-0.0.4.tar.gz" } ], "0.0.5": [ { "comment_text": "", "digests": { "md5": "caa6e9ccb776f17eb4b93316984fc8c5", "sha256": "f3de8a3075c2bd3ea7fe13faa2402c2b7e018c3105fbc44c787940d24ea3cd93" }, "downloads": -1, "filename": "kinesisutils-0.0.5.tar.gz", "has_sig": false, "md5_digest": "caa6e9ccb776f17eb4b93316984fc8c5", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3309, "upload_time": "2017-05-27T09:43:04", "url": "https://files.pythonhosted.org/packages/80/37/1b316eccd67f7d20829d45a1dcfdef3732baa77027e9038676ee49896d9f/kinesisutils-0.0.5.tar.gz" } ], "0.0.6": [ { "comment_text": "", "digests": { "md5": "167ecd584376774a48935451f3ba7ce2", "sha256": "9b986ff10ba9393a538105351e2aff6632300055f74ae489f45ab06886fd105f" }, "downloads": -1, "filename": "kinesisutils-0.0.6.tar.gz", "has_sig": false, "md5_digest": "167ecd584376774a48935451f3ba7ce2", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3493, "upload_time": "2017-05-28T15:54:33", "url": "https://files.pythonhosted.org/packages/19/13/037cd178d63a09199111e4370a84b03e70a0ee0cfdb3ba152fae01928658/kinesisutils-0.0.6.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "167ecd584376774a48935451f3ba7ce2", "sha256": "9b986ff10ba9393a538105351e2aff6632300055f74ae489f45ab06886fd105f" }, "downloads": -1, "filename": "kinesisutils-0.0.6.tar.gz", "has_sig": false, "md5_digest": "167ecd584376774a48935451f3ba7ce2", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3493, "upload_time": "2017-05-28T15:54:33", "url": "https://files.pythonhosted.org/packages/19/13/037cd178d63a09199111e4370a84b03e70a0ee0cfdb3ba152fae01928658/kinesisutils-0.0.6.tar.gz" } ] }