{
"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"
}
]
}