{ "info": { "author": "Ungi Kim", "author_email": "ungi@ungikim.me", "bugtrack_url": null, "classifiers": [ "Development Status :: 3 - Alpha", "Environment :: No Input/Output (Daemon)", "Intended Audience :: Developers", "Programming Language :: Python :: 3.6", "Programming Language :: Python :: 3 :: Only", "Topic :: Software Development :: Libraries :: Python Modules" ], "description": "kinsumer\n========\n\nHigh level [Amazon Kinesis Streams](https://aws.amazon.com/kinesis/streams/) consumer.\n\nSome features\n-------------\n\n* Automatically detect shard count changes\n* Checkpoints/sequences persistence can be customized\n* Provided Checkpointer implementation for memory, and file\n* Memory bucket for temporary saving records\n\nUsage\n-----\n\n```python\nfrom kinsumer import Consumer\n\nSTREAM_REGION = 'ap-south-1'\nSTREAM_NAME = 'my-stream'\nconsumer = Consumer(__name__)\nconsumer.config.from_object(__name__)\n\n@consumer.transform\ndef transform(data, shard_id, last_sequence_number, last_arrival_timestamp):\n \"\"\"do transform and return\"\"\"\n return data\n\n@consumer.after_consume\ndef after(data, shard_id, last_sequence_number, last_arrival_timestamp):\n \"\"\"after transform and do something\"\"\"\n\nif __name__ == '__main__':\n consumer.process()\n```\n\nAuthor and license\n------------------\n\nkinsumer is written by [Ungi Kim](https://ungikim.me/), maintained by [Balance Hero](http://truebalance.io/), and licensed under the MIT license. You can find the source code from [Github](https://github.com/balancehero/kinsumer):\n\n```\n$ git clone git@github.com:balancehero/kinsumer.git\n```\n\nMissing features\n----------------\n\n* Redis Checkpointer\n* Consumer Heartbeat\n\n(Contributions would be appreciated!)", "description_content_type": null, "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "", "keywords": "", "license": "", "maintainer": "", "maintainer_email": "", "name": "kinsumer", "package_url": "https://pypi.org/project/kinsumer/", "platform": "", "project_url": "https://pypi.org/project/kinsumer/", "project_urls": null, "release_url": "https://pypi.org/project/kinsumer/0.5.3/", "requires_dist": null, "requires_python": "", "summary": "High level Amazon Kinesis Streams consumer", "version": "0.5.3" }, "last_serial": 3449256, "releases": { "0.5.0": [ { "comment_text": "", "digests": { "md5": "5fc2bb6abf03669f53ba9539f9529d49", "sha256": "bc94332d82f0e561d5c4113c708ccfb0a7ada912e7dbe79c3dfb23f464b3c240" }, "downloads": -1, "filename": "kinsumer-0.5.0.tar.gz", "has_sig": false, "md5_digest": "5fc2bb6abf03669f53ba9539f9529d49", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 12868, "upload_time": "2017-10-23T07:29:57", "url": "https://files.pythonhosted.org/packages/f5/27/5feedae2d28e6a1ea9c3c19cf610550bc885c868845630b4919e946583ca/kinsumer-0.5.0.tar.gz" } ], "0.5.1": [ { "comment_text": "", "digests": { "md5": "1c35bd6ad593749087599c3135bc8451", "sha256": "21cd336073d3e55467e30198781706a5e9dba960272bae3950567a691b4c49c7" }, "downloads": -1, "filename": "kinsumer-0.5.1.tar.gz", "has_sig": false, "md5_digest": "1c35bd6ad593749087599c3135bc8451", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 12859, "upload_time": "2017-10-24T10:12:34", "url": "https://files.pythonhosted.org/packages/19/98/e43220e59ab524fadd265b92aecb90632192da7649be572df8bce874da8a/kinsumer-0.5.1.tar.gz" } ], "0.5.2": [ { "comment_text": "", "digests": { "md5": "322563ef3b6553780635667efd970038", "sha256": "f310988d756d76df31549b093b01afa6062dd0564dd1d7a9c9e88c6f4265b426" }, "downloads": -1, "filename": "kinsumer-0.5.2.tar.gz", "has_sig": false, "md5_digest": "322563ef3b6553780635667efd970038", "packagetype": "sdist", "python_version": "source", "requires_python": ">=3.6.0", "size": 13040, "upload_time": "2017-11-10T01:59:00", "url": "https://files.pythonhosted.org/packages/ef/a8/8e43193df4171ed817815ba6efe78fb8dc5fe816fa888a9ae0ae186aceaa/kinsumer-0.5.2.tar.gz" } ], "0.5.3": [ { "comment_text": "", "digests": { "md5": "4b1186506317482f651d6a95cf9e9bff", "sha256": "a330bb47da69a769d58eb2aab2def90a7f7657dd5bd9840363fc6ed25c304d7f" }, "downloads": -1, "filename": "kinsumer-0.5.3.tar.gz", "has_sig": false, "md5_digest": "4b1186506317482f651d6a95cf9e9bff", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 13075, "upload_time": "2017-12-29T04:58:00", "url": "https://files.pythonhosted.org/packages/40/dc/c67dab02aa0270742c8a8665ce82aa6bd55cf1ec981e5aef3f3dcf5e954e/kinsumer-0.5.3.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "4b1186506317482f651d6a95cf9e9bff", "sha256": "a330bb47da69a769d58eb2aab2def90a7f7657dd5bd9840363fc6ed25c304d7f" }, "downloads": -1, "filename": "kinsumer-0.5.3.tar.gz", "has_sig": false, "md5_digest": "4b1186506317482f651d6a95cf9e9bff", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 13075, "upload_time": "2017-12-29T04:58:00", "url": "https://files.pythonhosted.org/packages/40/dc/c67dab02aa0270742c8a8665ce82aa6bd55cf1ec981e5aef3f3dcf5e954e/kinsumer-0.5.3.tar.gz" } ] }