{ "info": { "author": "IBM Streams @ github.com", "author_email": "hegermar@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 for serialization and deserialization of messages in an Apache Avro format.\n\nThis package exposes the `com.ibm.streamsx.avro `_ toolkit as Python methods for use with Streaming Analytics service on\nIBM Cloud and IBM Streams including IBM Cloud Pak for Data.\n\n* `Streaming Analytics service `_\n* `IBM Streams developer community `_\n\n\nSample\n======\n\nA simple example of a Streams application that serializes and deserializes messages::\n\n from streamsx.topology.topology import *\n from streamsx.topology.schema import CommonSchema, StreamSchema\n from streamsx.topology.context import submit\n import streamsx.avro as avro\n\n topo = Topology()\n\n avro_schema = '{\"type\" : \"record\", \"name\" : \"hw_schema\", \"fields\" : [{\"name\" : \"a\", \"type\" : \"string\"}]}'\n s = topo.source([{'a': 'Hello'}, {'a': 'World'}, {'a': '!'}]).as_json()\n \n # convert json to avro blob\n o = avro.json_to_avro(s, avro_schema)\n # convert avro blob to json\n res = avro.avro_to_json(o, avro_schema)\n res.print()\n\n submit('STREAMING_ANALYTICS_SERVICE', topo)\n # Use for IBM Streams including IBM Cloud Pak for Data\n # submit ('DISTRIBUTED', topo, cfg)\n\nDocumentation\n=============\n\n* `streamsx.avro 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.avro", "keywords": "streams", "license": "Apache License - Version 2.0", "maintainer": "", "maintainer_email": "", "name": "streamsx.avro", "package_url": "https://pypi.org/project/streamsx.avro/", "platform": "", "project_url": "https://pypi.org/project/streamsx.avro/", "project_urls": { "Homepage": "https://github.com/IBMStreams/streamsx.avro" }, "release_url": "https://pypi.org/project/streamsx.avro/1.1.0/", "requires_dist": null, "requires_python": "", "summary": "IBM Streams Avro integration", "version": "1.1.0" }, "last_serial": 5774432, "releases": { "0.1.0": [ { "comment_text": "", "digests": { "md5": "b6dbac9cb2ab85260c38e830104b95d9", "sha256": "b819e38678fc6af2e8c5df066dfbe075a96b1a027a1f975a8d04b55f83053927" }, "downloads": -1, "filename": "streamsx.avro-0.1.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "b6dbac9cb2ab85260c38e830104b95d9", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 8979, "upload_time": "2019-01-31T16:08:51", "url": "https://files.pythonhosted.org/packages/21/2c/958fda363d579c1943b6619e89e0c0d640f9704b8cdd2f36bad852a0b80a/streamsx.avro-0.1.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "1ae538892dbbbef0dd935d5d93dab230", "sha256": "20390c231e4fba7309a6e2dfd2a0ed6abc9419301e5b88b7821e8ad67b236bd5" }, "downloads": -1, "filename": "streamsx.avro-0.1.0.tar.gz", "has_sig": false, "md5_digest": "1ae538892dbbbef0dd935d5d93dab230", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3060, "upload_time": "2019-01-31T16:08:48", "url": "https://files.pythonhosted.org/packages/cc/3a/6fb9825ac57f79ef65422541d1a84790f32c78d6cfc44814e97ce3f24813/streamsx.avro-0.1.0.tar.gz" } ], "0.2.0": [ { "comment_text": "", "digests": { "md5": "7d21a7f7184628a80e6d08a0d21bedd6", "sha256": "b7b71582aeabab3fd93af98ba45e7c354b4b48515a2a5246014ab8ff2d791d77" }, "downloads": -1, "filename": "streamsx.avro-0.2.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "7d21a7f7184628a80e6d08a0d21bedd6", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 10568, "upload_time": "2019-02-01T12:38:54", "url": "https://files.pythonhosted.org/packages/2a/be/4aaa60414335fef2a17244c02be691bf0f5d373685af54db4d321c259d8e/streamsx.avro-0.2.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "6275342608e10b0607b6d1233ef8edb4", "sha256": "8a3eab2e5494c2246dff840b01f8cbc1fd54d9454fc64b062580d24e8bc0b020" }, "downloads": -1, "filename": "streamsx.avro-0.2.0.tar.gz", "has_sig": false, "md5_digest": "6275342608e10b0607b6d1233ef8edb4", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4061, "upload_time": "2019-02-01T12:38:52", "url": "https://files.pythonhosted.org/packages/cd/b4/2efb804d8ed0c3871155f8c95f124cda4fa3d02b13418d3bc434e7f91a2b/streamsx.avro-0.2.0.tar.gz" } ], "1.0.0": [ { "comment_text": "", "digests": { "md5": "48f88c628becc41730927a8673dfb48e", "sha256": "7bd579b24f1fbbe052d0420700e3e64e0377b89186739d6eab5d5f053e44152a" }, "downloads": -1, "filename": "streamsx.avro-1.0.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "48f88c628becc41730927a8673dfb48e", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 10564, "upload_time": "2019-02-05T14:40:21", "url": "https://files.pythonhosted.org/packages/47/60/36f94e7ffe0037563cfcbc7af5ce46245c95a9b885522ffdd4375beee02f/streamsx.avro-1.0.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "a1953f5aefd6c336927c4b316376294a", "sha256": "fbc64df06f0ac543cb7c24f4bd00fdfea1dc5989e74cd4409e4d4bcb53c24d95" }, "downloads": -1, "filename": "streamsx.avro-1.0.0.tar.gz", "has_sig": false, "md5_digest": "a1953f5aefd6c336927c4b316376294a", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4028, "upload_time": "2019-02-05T14:40:19", "url": "https://files.pythonhosted.org/packages/62/66/9786da56323fdcff9a1c759824044a4c3bdfdaa9ace7d813b0f6dcabcc67/streamsx.avro-1.0.0.tar.gz" } ], "1.0.1": [ { "comment_text": "", "digests": { "md5": "21918e4475ce514bbbe5c8accdebd612", "sha256": "8ad69423c206774e69f49659fe458a3374f2561a0762c23ae01bdc2915f4d6b9" }, "downloads": -1, "filename": "streamsx.avro-1.0.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "21918e4475ce514bbbe5c8accdebd612", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 10921, "upload_time": "2019-03-04T08:41:34", "url": "https://files.pythonhosted.org/packages/5e/36/7625c85aac26177fbae948e26751431f7b76b0efe51d045921ba467f75af/streamsx.avro-1.0.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "e1edce7023933e9e22119aaf3548b6f0", "sha256": "3b7ec1487d2a7004847e523d1f02c656ae44aed3889a6da2331d994c2b9ee813" }, "downloads": -1, "filename": "streamsx.avro-1.0.1.tar.gz", "has_sig": false, "md5_digest": "e1edce7023933e9e22119aaf3548b6f0", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4155, "upload_time": "2019-03-04T08:41:32", "url": "https://files.pythonhosted.org/packages/f4/9d/f862d38357be22bf6cc63bf239fabd80649de7f887c5469db47bf5f47b91/streamsx.avro-1.0.1.tar.gz" } ], "1.0.2": [ { "comment_text": "", "digests": { "md5": "4642f55850a0d575fd7b2c21881a7fd0", "sha256": "c20d833d61fd37320fc218070dbd11caccb3131f97096c7ab8d01a78221bdcc6" }, "downloads": -1, "filename": "streamsx.avro-1.0.2-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "4642f55850a0d575fd7b2c21881a7fd0", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 10920, "upload_time": "2019-06-11T10:54:36", "url": "https://files.pythonhosted.org/packages/2e/69/72f9a94dbe10f64a5293c5b9fcdaa099285ab3d0e53afee08c117ea470c2/streamsx.avro-1.0.2-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "3259feb9a9536634ae4d801b691c20ff", "sha256": "48fd15e9769206ac3041c08fa9486b8b684fb798e46194a333a49e58fee81026" }, "downloads": -1, "filename": "streamsx.avro-1.0.2.tar.gz", "has_sig": false, "md5_digest": "3259feb9a9536634ae4d801b691c20ff", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4135, "upload_time": "2019-06-11T10:54:34", "url": "https://files.pythonhosted.org/packages/a2/df/faebd41722f1c9f4d59c005600326fad4f3804f1751b4df64e0a943ec9ea/streamsx.avro-1.0.2.tar.gz" } ], "1.1.0": [ { "comment_text": "", "digests": { "md5": "cb2743fa9568f087b60aa2c04ef4e03f", "sha256": "b3ee208763cfcaf373dfec769be76ccbed95051ff33abe0116de8910955da45a" }, "downloads": -1, "filename": "streamsx.avro-1.1.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "cb2743fa9568f087b60aa2c04ef4e03f", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 11566, "upload_time": "2019-09-03T07:45:38", "url": "https://files.pythonhosted.org/packages/54/e7/4a48374c20839e5d114966beb885325362fdfb2c44c4415e0c30419e27ef/streamsx.avro-1.1.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "13671ef0a1f03077b7005b42b37c76df", "sha256": "647cbbb05adaa60d23df155a2f48069b0df7e5599411662f6c8c519524e7e38c" }, "downloads": -1, "filename": "streamsx.avro-1.1.0.tar.gz", "has_sig": false, "md5_digest": "13671ef0a1f03077b7005b42b37c76df", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4703, "upload_time": "2019-09-03T07:45:36", "url": "https://files.pythonhosted.org/packages/19/23/4edfa76e8f59ac5f4f697fe034eb5add1a35396e192ead0d6060417abdec/streamsx.avro-1.1.0.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "cb2743fa9568f087b60aa2c04ef4e03f", "sha256": "b3ee208763cfcaf373dfec769be76ccbed95051ff33abe0116de8910955da45a" }, "downloads": -1, "filename": "streamsx.avro-1.1.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "cb2743fa9568f087b60aa2c04ef4e03f", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 11566, "upload_time": "2019-09-03T07:45:38", "url": "https://files.pythonhosted.org/packages/54/e7/4a48374c20839e5d114966beb885325362fdfb2c44c4415e0c30419e27ef/streamsx.avro-1.1.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "13671ef0a1f03077b7005b42b37c76df", "sha256": "647cbbb05adaa60d23df155a2f48069b0df7e5599411662f6c8c519524e7e38c" }, "downloads": -1, "filename": "streamsx.avro-1.1.0.tar.gz", "has_sig": false, "md5_digest": "13671ef0a1f03077b7005b42b37c76df", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4703, "upload_time": "2019-09-03T07:45:36", "url": "https://files.pythonhosted.org/packages/19/23/4edfa76e8f59ac5f4f697fe034eb5add1a35396e192ead0d6060417abdec/streamsx.avro-1.1.0.tar.gz" } ] }