{
    "info": {
        "author": "IBM Streams @ github.com",
        "author_email": "rolef.heinrich@de.ibm.com",
        "bugtrack_url": null,
        "classifiers": [
            "Development Status :: 5 - Production/Stable",
            "License :: OSI Approved :: Apache Software License",
            "Programming Language :: Python :: 3",
            "Programming Language :: Python :: 3.5",
            "Programming Language :: Python :: 3.6"
        ],
        "description": "Overview\n========\n\nProvides functions to read messages from Event Streams as a stream\nand publish tuples to Event Streams as messages.\n\n`IBM\u00ae Event Streams <https://www.ibm.com/cloud/event-streams>`_ is a fully managed, cloud-based messaging service. Built on Apache Kafka, IBM Event Streams is a high-throughput, fault-tolerant, event management platform that helps you build intelligent, responsive, event-driven applications.\n\nSample\n======\n\nA simple hello world example of a Streams application publishing to a topic and the same application consuming the same topic::\n\n    from streamsx.topology.topology import Topology\n    from streamsx.topology.schema import CommonSchema\n    from streamsx.topology.context import submit, ContextTypes\n    import streamsx.eventstreams as eventstreams\n    import time\n\n    def delay(v):\n        time.sleep(5.0)\n        return True\n\n    topology = Topology('EventStreamsHelloWorld')\n\n    to_evstr = topology.source(['Hello', 'World!'])\n    to_evstr = to_evstr.as_string()\n    # delay tuple by tuple\n    to_evstr = to_evstr.filter(delay)\n\n    # Publish a stream to Event Streams using HELLO topic\n    eventstreams.publish(to_evstr, topic='HELLO')\n\n    # Subscribe to same topic as a stream\n    from_evstr = eventstreams.subscribe(topology, schema=CommonSchema.String, topic='HELLO')\n\n    # You'll find the Hello World! in stdout log file:\n    from_evstr.print()\n\n    # finally submit the topology to a Streaming  Analytics Service instance\n    submit(ContextTypes.STREAMING_ANALYTICS_SERVICE, topology)\n\nDocumentation\n=============\n\n* `streamsx.eventstreams package documentation <http://streamsxeventstreams.readthedocs.io/>`_\n",
        "description_content_type": "",
        "docs_url": null,
        "download_url": "",
        "downloads": {
            "last_day": -1,
            "last_month": -1,
            "last_week": -1
        },
        "home_page": "https://github.com/IBMStreams/pypi.streamsx.eventstreams",
        "keywords": "streams",
        "license": "Apache License - Version 2.0",
        "maintainer": "",
        "maintainer_email": "",
        "name": "streamsx.eventstreams",
        "package_url": "https://pypi.org/project/streamsx.eventstreams/",
        "platform": "",
        "project_url": "https://pypi.org/project/streamsx.eventstreams/",
        "project_urls": {
            "Homepage": "https://github.com/IBMStreams/pypi.streamsx.eventstreams"
        },
        "release_url": "https://pypi.org/project/streamsx.eventstreams/1.3.1/",
        "requires_dist": null,
        "requires_python": "",
        "summary": "IBM Streams Event Streams integration",
        "version": "1.3.1"
    },
    "last_serial": 5781000,
    "releases": {
        "1.0.0": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "64faff1cbf28ca33eff2370aae0b96eb",
                    "sha256": "7e35281d130e2e56f93805488438c4bc057e1198998b5ff6fa3f29b67d52011e"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.0.0-py2.py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "64faff1cbf28ca33eff2370aae0b96eb",
                "packagetype": "bdist_wheel",
                "python_version": "3.5",
                "requires_python": null,
                "size": 9437,
                "upload_time": "2019-02-05T12:47:17",
                "url": "https://files.pythonhosted.org/packages/ce/62/2bd8af86070fd21600036296589e9b8cae056b43784e676156dda125034e/streamsx.eventstreams-1.0.0-py2.py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "7856e90ec40e7434622d2598a231ecdf",
                    "sha256": "2e357e779b7a7ee7ee96ab708208bcd7ca7c12bc8ee85b2da8797fd050ef453d"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.0.0.tar.gz",
                "has_sig": false,
                "md5_digest": "7856e90ec40e7434622d2598a231ecdf",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 4197,
                "upload_time": "2019-02-05T12:47:14",
                "url": "https://files.pythonhosted.org/packages/4d/18/5c333d857f837a64f2e2d58c715d63c4ba86660acca49f8f84ea98b19039/streamsx.eventstreams-1.0.0.tar.gz"
            }
        ],
        "1.1.0": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "b7cc6d06e434f68cca90bd4601eaf39a",
                    "sha256": "4076aa7bc8bd2909b2bf4a5a8c06a1d49c4169300f45540fc74bb5063a9c550e"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.1.0-py2.py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "b7cc6d06e434f68cca90bd4601eaf39a",
                "packagetype": "bdist_wheel",
                "python_version": "3.6",
                "requires_python": null,
                "size": 10122,
                "upload_time": "2019-05-08T12:10:46",
                "url": "https://files.pythonhosted.org/packages/98/dd/aa6cee750cb2514a6996ae4df66b6e5c29c3e6508ffa4326a6ff7ddc63ba/streamsx.eventstreams-1.1.0-py2.py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "dd5c4d8ed001994238dc092403c0a679",
                    "sha256": "5620ab12a238ac0886bc5c84d364e8ef1b1898dcb29e9167a59a7fa26d612f0c"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.1.0.tar.gz",
                "has_sig": false,
                "md5_digest": "dd5c4d8ed001994238dc092403c0a679",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 8817,
                "upload_time": "2019-05-08T12:10:44",
                "url": "https://files.pythonhosted.org/packages/83/6b/458f8f2c185ee720ab4099652e49a86dcea57667b56e421fb8fe44538b45/streamsx.eventstreams-1.1.0.tar.gz"
            }
        ],
        "1.2.0": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "59cec0bea63870df8a0997584c2f6bdf",
                    "sha256": "4290cf9861ab18f61d2d5234fcbc45116d935ddb13ed2fababcff9b9854fbea3"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.2.0-py2.py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "59cec0bea63870df8a0997584c2f6bdf",
                "packagetype": "bdist_wheel",
                "python_version": "3.6",
                "requires_python": null,
                "size": 13295,
                "upload_time": "2019-05-22T07:36:13",
                "url": "https://files.pythonhosted.org/packages/87/76/44a6eb5e78d03082a543a4f9842aa810f8f84771fd461ea2d1aa1cf35b4c/streamsx.eventstreams-1.2.0-py2.py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "32f0c75de51217e9005f75aca8edc370",
                    "sha256": "e2e7dba772a281a747ca68274e0e6755062ce9e780f6cd771072bf7d8c44027a"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.2.0.tar.gz",
                "has_sig": false,
                "md5_digest": "32f0c75de51217e9005f75aca8edc370",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 11366,
                "upload_time": "2019-05-22T07:36:11",
                "url": "https://files.pythonhosted.org/packages/aa/5f/26017b8b6eac1911e2dadaca36dc4d0ea715a3c41a71f334475a2f5b01e6/streamsx.eventstreams-1.2.0.tar.gz"
            }
        ],
        "1.2.1": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "959e83f3ba561b3cab4f87e71485a3bb",
                    "sha256": "08b76a1b51fe6403868c1ab590457be549badcdb5260a072e5d1317cd8efd1c4"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.2.1-py2.py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "959e83f3ba561b3cab4f87e71485a3bb",
                "packagetype": "bdist_wheel",
                "python_version": "3.6",
                "requires_python": null,
                "size": 13371,
                "upload_time": "2019-05-23T08:57:09",
                "url": "https://files.pythonhosted.org/packages/0c/8c/381e5e3ec1fe806e2922a7d8c34999e4a10495a51af0405d1cf93d5e3e31/streamsx.eventstreams-1.2.1-py2.py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "4868b75f6f8140a29d02aeef03db71a0",
                    "sha256": "32d45fbd0bb4c87987eb34e376039093db9e39c1690a7ece20023a405863ce84"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.2.1.tar.gz",
                "has_sig": false,
                "md5_digest": "4868b75f6f8140a29d02aeef03db71a0",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 11467,
                "upload_time": "2019-05-23T08:57:07",
                "url": "https://files.pythonhosted.org/packages/4f/d6/3f6cf87bf1d1e530176b8a179cd09065acbb5b8365c4ff012c1f0ea72179/streamsx.eventstreams-1.2.1.tar.gz"
            }
        ],
        "1.2.2": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "a6f66862a33b60630b68a30f478ff9b0",
                    "sha256": "92e7f28a44501a4c802fc8a96660668cedfb189c696352e422649dc838ee722e"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.2.2-py2.py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "a6f66862a33b60630b68a30f478ff9b0",
                "packagetype": "bdist_wheel",
                "python_version": "3.6",
                "requires_python": null,
                "size": 13391,
                "upload_time": "2019-06-03T11:04:32",
                "url": "https://files.pythonhosted.org/packages/ff/8c/f19b3e49aad16710fc2eed62366c852fbe0619f02ad690c7cd9497ccbd57/streamsx.eventstreams-1.2.2-py2.py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "4e65c685ff2b77c1efb04132ba3bbc2b",
                    "sha256": "f07befab5624973bc824ed9d025739edb1fd4154c89bd053b5c362f8d38d89fe"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.2.2.tar.gz",
                "has_sig": false,
                "md5_digest": "4e65c685ff2b77c1efb04132ba3bbc2b",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 11474,
                "upload_time": "2019-06-03T11:04:30",
                "url": "https://files.pythonhosted.org/packages/95/10/993d06678a6f5b7bc12ebe5bd56d6ecc4b11efed5df11f726ad35bfc1b13/streamsx.eventstreams-1.2.2.tar.gz"
            }
        ],
        "1.2.4": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "babfc118336dcad3255a6bda69927876",
                    "sha256": "d5fea5324e4fbed5e6c53f8850ce3bfde40d5c53bd74a189e0b0b28304df263b"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.2.4-py2.py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "babfc118336dcad3255a6bda69927876",
                "packagetype": "bdist_wheel",
                "python_version": "3.6",
                "requires_python": null,
                "size": 13391,
                "upload_time": "2019-06-11T09:48:07",
                "url": "https://files.pythonhosted.org/packages/13/55/4e276e5ff453a483543387fd0815da9748efcbd8111c96805a48bd8b1ee8/streamsx.eventstreams-1.2.4-py2.py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "a632ed6d79b6aefdb955e57c950f1d0a",
                    "sha256": "c2b0430d4abcc16705c20352eb11292f8a1d5163691df02f3571dab777f4487a"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.2.4.tar.gz",
                "has_sig": false,
                "md5_digest": "a632ed6d79b6aefdb955e57c950f1d0a",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 11490,
                "upload_time": "2019-06-11T09:48:04",
                "url": "https://files.pythonhosted.org/packages/41/16/bdf0b7e4e14d4781e8570cba1375374774db0e86c2af949a09bf69b4b4de/streamsx.eventstreams-1.2.4.tar.gz"
            }
        ],
        "1.3.0": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "660a7dea3555ed2941e97c7d5c7b2665",
                    "sha256": "698182bcb1456f31ace90ccbbe4983c8dd35b0a963a79f69daf74a3dd9528417"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.3.0-py2.py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "660a7dea3555ed2941e97c7d5c7b2665",
                "packagetype": "bdist_wheel",
                "python_version": "3.6",
                "requires_python": null,
                "size": 13936,
                "upload_time": "2019-09-02T13:59:25",
                "url": "https://files.pythonhosted.org/packages/82/4d/105c521547249e2f8fd836568950c4302f1a9fd90e0a92846fddedd5bdff/streamsx.eventstreams-1.3.0-py2.py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "3b2f646c616febb91e52eabfa184b9d5",
                    "sha256": "747f7a63f03fab8fd91b518c7dada6850608683510f388b504f1524ddb3d8b6f"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.3.0.tar.gz",
                "has_sig": false,
                "md5_digest": "3b2f646c616febb91e52eabfa184b9d5",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 12080,
                "upload_time": "2019-09-02T13:59:23",
                "url": "https://files.pythonhosted.org/packages/eb/cf/386eb8bcb53026fbb32c317e7c58a13e9a4de99e69b4e63234e2132121d3/streamsx.eventstreams-1.3.0.tar.gz"
            }
        ],
        "1.3.1": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "4195358cdca3c959703c44cddbd76e89",
                    "sha256": "71868cde01684726755bd931cd8261dd53732ef804a6a4751a8f133a3525dfd6"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.3.1-py2.py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "4195358cdca3c959703c44cddbd76e89",
                "packagetype": "bdist_wheel",
                "python_version": "3.6",
                "requires_python": null,
                "size": 13937,
                "upload_time": "2019-09-04T12:40:30",
                "url": "https://files.pythonhosted.org/packages/27/a4/bde7dae7d0adba391c8fdedd04a4babcbea2ac8f4e3c2a10532db8d8302f/streamsx.eventstreams-1.3.1-py2.py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "5e555c3018ee719f93c9c0173314aa3a",
                    "sha256": "11006f58440d3dbaccd65074142a065fe05fa8287544aeba3aa6260fe69d95a4"
                },
                "downloads": -1,
                "filename": "streamsx.eventstreams-1.3.1.tar.gz",
                "has_sig": false,
                "md5_digest": "5e555c3018ee719f93c9c0173314aa3a",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 12089,
                "upload_time": "2019-09-04T12:40:28",
                "url": "https://files.pythonhosted.org/packages/22/0a/7f13bcfaaf2ce6fcfd8dd1ab86cc7658a93346475c89926c4167fd6be7df/streamsx.eventstreams-1.3.1.tar.gz"
            }
        ]
    },
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "md5": "4195358cdca3c959703c44cddbd76e89",
                "sha256": "71868cde01684726755bd931cd8261dd53732ef804a6a4751a8f133a3525dfd6"
            },
            "downloads": -1,
            "filename": "streamsx.eventstreams-1.3.1-py2.py3-none-any.whl",
            "has_sig": false,
            "md5_digest": "4195358cdca3c959703c44cddbd76e89",
            "packagetype": "bdist_wheel",
            "python_version": "3.6",
            "requires_python": null,
            "size": 13937,
            "upload_time": "2019-09-04T12:40:30",
            "url": "https://files.pythonhosted.org/packages/27/a4/bde7dae7d0adba391c8fdedd04a4babcbea2ac8f4e3c2a10532db8d8302f/streamsx.eventstreams-1.3.1-py2.py3-none-any.whl"
        },
        {
            "comment_text": "",
            "digests": {
                "md5": "5e555c3018ee719f93c9c0173314aa3a",
                "sha256": "11006f58440d3dbaccd65074142a065fe05fa8287544aeba3aa6260fe69d95a4"
            },
            "downloads": -1,
            "filename": "streamsx.eventstreams-1.3.1.tar.gz",
            "has_sig": false,
            "md5_digest": "5e555c3018ee719f93c9c0173314aa3a",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": null,
            "size": 12089,
            "upload_time": "2019-09-04T12:40:28",
            "url": "https://files.pythonhosted.org/packages/22/0a/7f13bcfaaf2ce6fcfd8dd1ab86cc7658a93346475c89926c4167fd6be7df/streamsx.eventstreams-1.3.1.tar.gz"
        }
    ]
}