{
    "info": {
        "author": "Francisco Alejandro Jurado P\u00e9rez",
        "author_email": "yo@franciscoalejandro.tech",
        "bugtrack_url": null,
        "classifiers": [
            "Development Status :: 2 - Pre-Alpha",
            "License :: OSI Approved :: MIT License",
            "Programming Language :: Python :: 3.7"
        ],
        "description": "# Influmy Kinesis\n\nBecause we \u2764\ufe0f sexy docker images. Avoid to add a heavy Java daemon when you are using a KCL language other than Java. So this python package allow you to publish a message in a stream, and consume it with two shard iterator types. LATEST and TRIM_HORIZON\n\n## Publisher\n\nSimply import it!\n\n    from influmy_kinesis import Publisher\n    \n    p = Publisher()\n    \n\tp.publish(\n\t\tpayload={\n\t\t\t'message': 'Hello World',\n\t\t},\n\t\tstream_name='foo_stream',\n\t\tassert_stream=True,\n\t)\n    \nBy the moment payload should be a JSON serializable dict. With assert_stream to true, if stream does not exist it will be created before put records on it.\n\n## Consumer\n\nEeeeasy!\n\n    from influmy_kinesis import Consumer\n\t\n\tdef callback(records):\n\t\tprint(records)\n\t\n\tc = Consumer(\n\t\tstream_name='foo_stream',\n\t\tcallback_function=callback,\n\t\tperiod=10,\n\t\tshard_iterator_type='LATEST',\n\t)\n\t\n\tdef main():\n     loop = asyncio.get_event_loop()\n     loop.run_until_complete(\n          asyncio.wait(c.consume())\n     )\n     loop.close()\n\n\tif __name__ == '__main__':\n\t     main()\n\n\nWith period, in seconds, you define how often consumer gets records. Shard iterator type should be 'LATEST' | 'TRIM_HORIZON'\n\n\n## Credentials\nBefore you can begin using this outstandable package, you should set up authentication credentials. It uses bot3 so ...\n[Read me \ud83d\ude44](https://boto3.amazonaws.com/v1/documentation/api/latest/guide/quickstart.html)",
        "description_content_type": "text/markdown",
        "docs_url": null,
        "download_url": "",
        "downloads": {
            "last_day": -1,
            "last_month": -1,
            "last_week": -1
        },
        "home_page": "https://gitlab.influmy.com/alejandro.jurado/kinesis",
        "keywords": "",
        "license": "MIT",
        "maintainer": "",
        "maintainer_email": "",
        "name": "influmy-kinesis",
        "package_url": "https://pypi.org/project/influmy-kinesis/",
        "platform": "",
        "project_url": "https://pypi.org/project/influmy-kinesis/",
        "project_urls": {
            "Homepage": "https://gitlab.influmy.com/alejandro.jurado/kinesis"
        },
        "release_url": "https://pypi.org/project/influmy-kinesis/0.1.3/",
        "requires_dist": null,
        "requires_python": "",
        "summary": "Make kinesis simple",
        "version": "0.1.3"
    },
    "last_serial": 5978430,
    "releases": {
        "0.1.0": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "b536be5ce96468e2fd0b950717ff728d",
                    "sha256": "e976fc4416826c60cd0e2165f8c1564b3cde517751a9c749e6c1d7eb3aec5bf4"
                },
                "downloads": -1,
                "filename": "influmy_kinesis-0.1.0.tar.gz",
                "has_sig": false,
                "md5_digest": "b536be5ce96468e2fd0b950717ff728d",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 2625,
                "upload_time": "2019-10-14T18:26:36",
                "url": "https://files.pythonhosted.org/packages/e3/d6/0cb3b659199b3a521a3d53f0220b97255df28d933dee7b9b253a752baaac/influmy_kinesis-0.1.0.tar.gz"
            }
        ],
        "0.1.1": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "d5ed19942a8de08e3703adcd3a1ea763",
                    "sha256": "339746fc00c92174f8a64e7d2f523b600ecea344238a457c892b06a4b9003349"
                },
                "downloads": -1,
                "filename": "influmy_kinesis-0.1.1.tar.gz",
                "has_sig": false,
                "md5_digest": "d5ed19942a8de08e3703adcd3a1ea763",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 3822,
                "upload_time": "2019-10-14T19:22:19",
                "url": "https://files.pythonhosted.org/packages/01/c3/6231d0fd6ecf676ed8fe5fe25068487448c4e80714c5328cb1bba065af50/influmy_kinesis-0.1.1.tar.gz"
            }
        ],
        "0.1.2": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "50812efacb0a42430a1642e3d4701d5e",
                    "sha256": "34cf996ded0d1cfd4b1b5ffce0c3d57906d1eceaeb892bb711232df29c800bbc"
                },
                "downloads": -1,
                "filename": "influmy_kinesis-0.1.2.tar.gz",
                "has_sig": false,
                "md5_digest": "50812efacb0a42430a1642e3d4701d5e",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 3999,
                "upload_time": "2019-10-15T16:52:58",
                "url": "https://files.pythonhosted.org/packages/24/63/0aeec25e99b9f32164e61b68d0f4a68d156e1a4b2687f29890c36db2b587/influmy_kinesis-0.1.2.tar.gz"
            }
        ],
        "0.1.3": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "a4e432916623fe8d7352525515107010",
                    "sha256": "041b47a373c3599697aaa4a182f2f937f18d56672e30953b3b80cb2c807558ae"
                },
                "downloads": -1,
                "filename": "influmy_kinesis-0.1.3.tar.gz",
                "has_sig": false,
                "md5_digest": "a4e432916623fe8d7352525515107010",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 3981,
                "upload_time": "2019-10-15T16:54:52",
                "url": "https://files.pythonhosted.org/packages/52/9e/fd889446a7db3bca4b07b3f570438bee7b9ccde97bc66d48100d602dc5e8/influmy_kinesis-0.1.3.tar.gz"
            }
        ]
    },
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "md5": "a4e432916623fe8d7352525515107010",
                "sha256": "041b47a373c3599697aaa4a182f2f937f18d56672e30953b3b80cb2c807558ae"
            },
            "downloads": -1,
            "filename": "influmy_kinesis-0.1.3.tar.gz",
            "has_sig": false,
            "md5_digest": "a4e432916623fe8d7352525515107010",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": null,
            "size": 3981,
            "upload_time": "2019-10-15T16:54:52",
            "url": "https://files.pythonhosted.org/packages/52/9e/fd889446a7db3bca4b07b3f570438bee7b9ccde97bc66d48100d602dc5e8/influmy_kinesis-0.1.3.tar.gz"
        }
    ]
}