{
"info": {
"author": "IBM Streams @ github.com",
"author_email": "debrunne@us.ibm.com",
"bugtrack_url": null,
"classifiers": [
"Development Status :: 7 - Inactive",
"License :: OSI Approved :: Apache Software License",
"Programming Language :: Python :: 3",
"Programming Language :: Python :: 3.5",
"Programming Language :: Python :: 3.6"
],
"description": "Overview\n========\n\nThis package is in status '7 - Inactive'. Please use `streamsx.eventstreams `_ instead.\n\nProvides functions to read messages from Event Streams as a stream\nand submit tuples to Event Streams as messages.\n\n`IBM\u00ae 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\n import streamsx.messagehub as messagehub\n import time\n\n def delay (v):\n time.sleep (5.0)\n return True\n\n topo = Topology ('MessageHubHelloWorld')\n\n to_mh = topo.source (['Hello', 'World!'])\n to_mh = to_mh.as_string()\n # delay tuple by tuple\n to_mh = to_mh.filter (delay)\n\n # Publish a stream to Event Streams using MH_HW topic\n messagehub.publish (to_mh, topic='MH_HW')\n\n # Subscribe to same topic as a stream\n from_mh = messagehub.subscribe (topo, schema=CommonSchema.String, topic='MH_HW')\n\n # You'll find the Hello World! in stdout log file:\n from_mh.print()\n\n submit ('STREAMING_ANALYTICS_SERVICE', topo)\n\nDocumentation\n=============\n\n* `streamsx.messagehub package documentation `_\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/streamsx.messagehub",
"keywords": "streams",
"license": "Apache License - Version 2.0",
"maintainer": "",
"maintainer_email": "",
"name": "streamsx.messagehub",
"package_url": "https://pypi.org/project/streamsx.messagehub/",
"platform": "",
"project_url": "https://pypi.org/project/streamsx.messagehub/",
"project_urls": {
"Homepage": "https://github.com/IBMStreams/streamsx.messagehub"
},
"release_url": "https://pypi.org/project/streamsx.messagehub/0.6.1/",
"requires_dist": null,
"requires_python": "",
"summary": "IBM Streams Event Streams integration",
"version": "0.6.1"
},
"last_serial": 5776445,
"releases": {
"0.2.4": [
{
"comment_text": "",
"digests": {
"md5": "f98e93414df46d3c858bf16125c9fb6e",
"sha256": "9a2ec8250c27febef0cafffe781ad19d94f5d8dddc4990ea7a7d9210b6349b68"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.2.4-py2.py3-none-any.whl",
"has_sig": false,
"md5_digest": "f98e93414df46d3c858bf16125c9fb6e",
"packagetype": "bdist_wheel",
"python_version": "3.5",
"requires_python": null,
"size": 10327,
"upload_time": "2017-12-13T23:10:46",
"url": "https://files.pythonhosted.org/packages/ae/fa/43fd62e73c7cddc3e763ad0ab453183638f6bdced7013a639a69d773a36e/streamsx.messagehub-0.2.4-py2.py3-none-any.whl"
},
{
"comment_text": "",
"digests": {
"md5": "8d642fdf6c4d5d0224324ec53b977bd4",
"sha256": "84d20ee7ba659b36acea379ec569a74c2539e5fbea9b27aea52d489ed170931c"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.2.4.tar.gz",
"has_sig": false,
"md5_digest": "8d642fdf6c4d5d0224324ec53b977bd4",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 3540,
"upload_time": "2017-12-13T23:10:43",
"url": "https://files.pythonhosted.org/packages/7d/f1/5f32bce8659f62a99d581e28e2505cbb10443ac43eba3c55b0022bd141f8/streamsx.messagehub-0.2.4.tar.gz"
}
],
"0.3.1": [
{
"comment_text": "",
"digests": {
"md5": "4679c4c9dbef3645a62134679bb2f180",
"sha256": "65e1f5a1657de7cb50bca668c53c3915ea13ad8272569bf157f3d23a6d0100b6"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.3.1-py2.py3-none-any.whl",
"has_sig": false,
"md5_digest": "4679c4c9dbef3645a62134679bb2f180",
"packagetype": "bdist_wheel",
"python_version": "3.5",
"requires_python": null,
"size": 10576,
"upload_time": "2018-11-30T13:20:11",
"url": "https://files.pythonhosted.org/packages/4c/f1/820119a3570fe6848b3774b2810e8a30f10e21ba405e4fdf827790706a43/streamsx.messagehub-0.3.1-py2.py3-none-any.whl"
},
{
"comment_text": "",
"digests": {
"md5": "f4f7d3eba347e5fe73d363d8b6f67ca6",
"sha256": "cbddcb9acfa96a1e9dc4d4a61814ed95bc76e283c43068a7bcfa4e428b112a4d"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.3.1.tar.gz",
"has_sig": false,
"md5_digest": "f4f7d3eba347e5fe73d363d8b6f67ca6",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 3805,
"upload_time": "2018-11-30T13:20:09",
"url": "https://files.pythonhosted.org/packages/d2/46/ac8b3d6b516bdb44b60c114057bfaf335367a9bb5a1592d46771f1ccb607/streamsx.messagehub-0.3.1.tar.gz"
}
],
"0.4.0": [
{
"comment_text": "",
"digests": {
"md5": "cf845aeac2fe2d1939da734eeed3b9ed",
"sha256": "b34f36bda40b17d24510532906742fd8e78bd301e46cb2ae3912e3f821d982d5"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.4.0-py2.py3-none-any.whl",
"has_sig": false,
"md5_digest": "cf845aeac2fe2d1939da734eeed3b9ed",
"packagetype": "bdist_wheel",
"python_version": "3.5",
"requires_python": null,
"size": 10795,
"upload_time": "2018-11-30T14:57:01",
"url": "https://files.pythonhosted.org/packages/17/32/460f63ac5ff28a0a160486fd46aa6387d2b6ea07e083e72c1925d8910e03/streamsx.messagehub-0.4.0-py2.py3-none-any.whl"
},
{
"comment_text": "",
"digests": {
"md5": "07f13d32e46c015cf0b8456df14907aa",
"sha256": "8fc6a71776a6a38ff2c67ea111671758fb3566c8611ba27dc3c73d2cd012d67c"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.4.0.tar.gz",
"has_sig": false,
"md5_digest": "07f13d32e46c015cf0b8456df14907aa",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 4097,
"upload_time": "2018-11-30T14:56:59",
"url": "https://files.pythonhosted.org/packages/39/4a/bd9aa7ea5a813aac157a9786ea4c76eea034266461cd21678e3d2bce7a32/streamsx.messagehub-0.4.0.tar.gz"
}
],
"0.5.0": [
{
"comment_text": "",
"digests": {
"md5": "eba31f8d51e739662ac3e461b0931b5a",
"sha256": "f195157b48040c788ad0f9fac27cc65a665e33f517787d5be0b231a16735f681"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.5.0-py2.py3-none-any.whl",
"has_sig": false,
"md5_digest": "eba31f8d51e739662ac3e461b0931b5a",
"packagetype": "bdist_wheel",
"python_version": "3.5",
"requires_python": null,
"size": 10801,
"upload_time": "2018-12-13T13:05:49",
"url": "https://files.pythonhosted.org/packages/89/7e/536b5bfcb34f8356e52d31aaf71dfe0d89331abe597b2dfa66fe40134669/streamsx.messagehub-0.5.0-py2.py3-none-any.whl"
},
{
"comment_text": "",
"digests": {
"md5": "1ff9225e5971dd4abfed866a7d0fd118",
"sha256": "66ad74ab0e91c217da64941a5ef38c5a6572f124bd1b8b92b4286d7a64f63d0e"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.5.0.tar.gz",
"has_sig": false,
"md5_digest": "1ff9225e5971dd4abfed866a7d0fd118",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 4114,
"upload_time": "2018-12-13T13:05:47",
"url": "https://files.pythonhosted.org/packages/98/ee/c311b2608a87faa66c229cfe0c9f17197c5e5aae0e4d0002fc9232e31f61/streamsx.messagehub-0.5.0.tar.gz"
}
],
"0.6.0": [
{
"comment_text": "",
"digests": {
"md5": "62b288eac78fcfe15ea5e723a7fadb5d",
"sha256": "409ed7fe326b26580a35400dd5df123a49d5f8427a6528ad5bd089aed38322d8"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.6.0-py2.py3-none-any.whl",
"has_sig": false,
"md5_digest": "62b288eac78fcfe15ea5e723a7fadb5d",
"packagetype": "bdist_wheel",
"python_version": "3.5",
"requires_python": null,
"size": 9396,
"upload_time": "2019-01-15T10:29:42",
"url": "https://files.pythonhosted.org/packages/4d/bd/3e9ac8eb3f31b09b6fb62d8646cce4b3d64861391886dc76ff6d1e5717cd/streamsx.messagehub-0.6.0-py2.py3-none-any.whl"
},
{
"comment_text": "",
"digests": {
"md5": "82ccc555e88147a657927d01d7367a5d",
"sha256": "e244e8501f385917fe110f14fe6cab085aa16804fd7ffa2175a6a89b3dfb3660"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.6.0.tar.gz",
"has_sig": false,
"md5_digest": "82ccc555e88147a657927d01d7367a5d",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 4218,
"upload_time": "2019-01-15T10:29:40",
"url": "https://files.pythonhosted.org/packages/06/7c/af865c01a7ab2a9f29b0399bed0571fd5e98b0f5a46f10a03b3578227838/streamsx.messagehub-0.6.0.tar.gz"
}
],
"0.6.1": [
{
"comment_text": "",
"digests": {
"md5": "3b426f1538f06401dc3ae371b2b367bd",
"sha256": "f42f37064aeff647f255192e9caa579ce7e6e9fd8a76abe0fb512642d07173d9"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.6.1-py2.py3-none-any.whl",
"has_sig": false,
"md5_digest": "3b426f1538f06401dc3ae371b2b367bd",
"packagetype": "bdist_wheel",
"python_version": "3.6",
"requires_python": null,
"size": 9451,
"upload_time": "2019-09-03T14:53:56",
"url": "https://files.pythonhosted.org/packages/1a/e6/652e0c8e8d1b3ec165fc4e1507241f5e74b4c67989738214896a244c6e72/streamsx.messagehub-0.6.1-py2.py3-none-any.whl"
},
{
"comment_text": "",
"digests": {
"md5": "c06c2b83b3af850fe206712e6925e267",
"sha256": "d9949ad4382472381cd2b97530c5e9d78c264cc82143215a710946b1dce275d5"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.6.1.tar.gz",
"has_sig": false,
"md5_digest": "c06c2b83b3af850fe206712e6925e267",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 8233,
"upload_time": "2019-09-03T14:53:53",
"url": "https://files.pythonhosted.org/packages/5d/3f/c89550c2c662d52dee18d5fa34c7b83558e6894a8f380c97abbaccdbf7c5/streamsx.messagehub-0.6.1.tar.gz"
}
]
},
"urls": [
{
"comment_text": "",
"digests": {
"md5": "3b426f1538f06401dc3ae371b2b367bd",
"sha256": "f42f37064aeff647f255192e9caa579ce7e6e9fd8a76abe0fb512642d07173d9"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.6.1-py2.py3-none-any.whl",
"has_sig": false,
"md5_digest": "3b426f1538f06401dc3ae371b2b367bd",
"packagetype": "bdist_wheel",
"python_version": "3.6",
"requires_python": null,
"size": 9451,
"upload_time": "2019-09-03T14:53:56",
"url": "https://files.pythonhosted.org/packages/1a/e6/652e0c8e8d1b3ec165fc4e1507241f5e74b4c67989738214896a244c6e72/streamsx.messagehub-0.6.1-py2.py3-none-any.whl"
},
{
"comment_text": "",
"digests": {
"md5": "c06c2b83b3af850fe206712e6925e267",
"sha256": "d9949ad4382472381cd2b97530c5e9d78c264cc82143215a710946b1dce275d5"
},
"downloads": -1,
"filename": "streamsx.messagehub-0.6.1.tar.gz",
"has_sig": false,
"md5_digest": "c06c2b83b3af850fe206712e6925e267",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 8233,
"upload_time": "2019-09-03T14:53:53",
"url": "https://files.pythonhosted.org/packages/5d/3f/c89550c2c662d52dee18d5fa34c7b83558e6894a8f380c97abbaccdbf7c5/streamsx.messagehub-0.6.1.tar.gz"
}
]
}