{ "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 to store tuple data as JSON documents in Elasticsearch indices.\n\nThis package exposes the `com.ibm.streamsx.elasticsearch `_ 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* `Compose for Elasticsearch `_\n\n\nSample\n======\n\nA simple hello world example of a Streams application writing string messages to\nan index::\n\n from streamsx.topology.topology import *\n from streamsx.topology.schema import CommonSchema\n from streamsx.topology.context import submit\n import streamsx.elasticsearch as es\n\n topo = Topology('ElasticsearchHelloWorld')\n\n s = topo.source(['Hello', 'World!']).as_string()\n es.bulk_insert(s, 'test-index-cloud')\n\n submit('STREAMING_ANALYTICS_SERVICE', topo)\n\n\nA simple example of a Streams application writing JSON messages to an index, with dynamic index name (part of the stream)::\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.elasticsearch as es\n\n schema = StreamSchema('tuple')\n topo = Topology()\n s = topo.source([('idx1','{\"msg\":\"This is message number 1\"}'), ('idx2','{\"msg\":\"This is message number 2\"}')])\n s = s.map(lambda x : x, schema=schema)\n es.bulk_insert_dynamic(s, index_name_attribute='indexName', message_attribute='document')\n\n submit('STREAMING_ANALYTICS_SERVICE', topo)\n\n\nDocumentation\n=============\n\n* `streamsx.elasticsearch 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.elasticsearch", "keywords": "streams", "license": "Apache License - Version 2.0", "maintainer": "", "maintainer_email": "", "name": "streamsx.elasticsearch", "package_url": "https://pypi.org/project/streamsx.elasticsearch/", "platform": "", "project_url": "https://pypi.org/project/streamsx.elasticsearch/", "project_urls": { "Homepage": "https://github.com/IBMStreams/streamsx.elasticsearch" }, "release_url": "https://pypi.org/project/streamsx.elasticsearch/1.2.0/", "requires_dist": null, "requires_python": "", "summary": "IBM Streams Elasticsearch integration", "version": "1.2.0" }, "last_serial": 5774973, "releases": { "0.1.0": [ { "comment_text": "", "digests": { "md5": "6369995d1f5c29d5bd1edaec410ce1e4", "sha256": "eb5d8277194e73e6573a461e80da0e106c49039dbccd5448f5ac2641dda9b98d" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.1.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "6369995d1f5c29d5bd1edaec410ce1e4", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 10115, "upload_time": "2018-11-23T14:04:04", "url": "https://files.pythonhosted.org/packages/33/10/21fc25d15549b9cc3e40336f5413057aebffe8cc59e587bfaa932f795f9d/streamsx.elasticsearch-0.1.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "471b56171c7495f01d143fc211f4d920", "sha256": "9404a8683c98c23d1749df8e1e3e2e7673a3c0eb819101a5cb9567ec82b6c1c3" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.1.0.tar.gz", "has_sig": false, "md5_digest": "471b56171c7495f01d143fc211f4d920", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3583, "upload_time": "2018-11-23T14:04:01", "url": "https://files.pythonhosted.org/packages/a4/30/cd05cc8432bb0c1b15d32f013a5dba4c1d98e95ff9bf7d7e72e39a5ad784/streamsx.elasticsearch-0.1.0.tar.gz" } ], "0.2.0": [ { "comment_text": "", "digests": { "md5": "8388c9ad1aa00e9ec673ad652616613c", "sha256": "943590dec8292c61ae8251bbc0cce5859dc8a0c9c7467e189fd2efedf5835471" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.2.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "8388c9ad1aa00e9ec673ad652616613c", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 10539, "upload_time": "2018-11-26T15:12:04", "url": "https://files.pythonhosted.org/packages/f0/c1/53e2b72666ed2d279508f78dbc6a0e9a42fee7358dcad3b15290d2a93044/streamsx.elasticsearch-0.2.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "69e7a29ea9c867c1864d27092cabe21d", "sha256": "b4730dfb9b67da109742ebea3b09e1d69639a488d184571566ea227f95c51aea" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.2.0.tar.gz", "has_sig": false, "md5_digest": "69e7a29ea9c867c1864d27092cabe21d", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3909, "upload_time": "2018-11-26T15:12:02", "url": "https://files.pythonhosted.org/packages/7f/f4/0e9fdef19687ffeb1ec358ee669d69bef0bd4ce3c0d190ccf54ad92b411b/streamsx.elasticsearch-0.2.0.tar.gz" } ], "0.2.1": [ { "comment_text": "", "digests": { "md5": "a5e595c771b77af7e6a370271ba4baa7", "sha256": "df718d56bd03ae41397fe1b89a215c2d01fae0082ce80b96a202551d28136541" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.2.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "a5e595c771b77af7e6a370271ba4baa7", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 10899, "upload_time": "2018-11-27T09:03:53", "url": "https://files.pythonhosted.org/packages/6f/ae/8c1489c15971a766ddeafc51139846491aecd7ad6ca4ad3e0755479f5c81/streamsx.elasticsearch-0.2.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "2e934a1b8b76dc759d9991d1791076bf", "sha256": "f528af35b70b6082155897317e4f33dcfddbb998035cb09bb0fa5861d82c96a6" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.2.1.tar.gz", "has_sig": false, "md5_digest": "2e934a1b8b76dc759d9991d1791076bf", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3960, "upload_time": "2018-11-27T09:03:50", "url": "https://files.pythonhosted.org/packages/65/be/0196659b8664b821326015979f7ff3ab2e3a5857de696dd2530481fe3bc2/streamsx.elasticsearch-0.2.1.tar.gz" } ], "0.3.0": [ { "comment_text": "", "digests": { "md5": "e11d2d6ddfcc70dbc177357b8ddd81c3", "sha256": "66b9c4138ba67c9dd99cbff62478623b82084e6fe0569cc29cb288d1e8334f22" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.3.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "e11d2d6ddfcc70dbc177357b8ddd81c3", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 10930, "upload_time": "2018-12-13T09:11:04", "url": "https://files.pythonhosted.org/packages/a8/72/410394f54ae7edd8b4036cc5977c9f1934b09e624c6b05d5f7e5388b81ac/streamsx.elasticsearch-0.3.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "4c1b7fac0ebdd7d233fa995f6d11f294", "sha256": "4e8f1f7e545b2e5de2c65c3944c46bdaf0e85460e1990f69e24a2ad9314aa062" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.3.0.tar.gz", "has_sig": false, "md5_digest": "4c1b7fac0ebdd7d233fa995f6d11f294", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3980, "upload_time": "2018-12-13T09:11:01", "url": "https://files.pythonhosted.org/packages/82/c9/18712ab5d1e26055b8013d37a404b33a706e742bb32507406a9b7121035d/streamsx.elasticsearch-0.3.0.tar.gz" } ], "0.4.0": [ { "comment_text": "", "digests": { "md5": "a60f2912f44b221e21567e8334bc8934", "sha256": "fc1a96c4e4fe60f8d4b94f6b133d5694f53aba1fedbd40d357bf104b1cbb8308" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.4.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "a60f2912f44b221e21567e8334bc8934", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 10885, "upload_time": "2018-12-13T12:20:44", "url": "https://files.pythonhosted.org/packages/9c/5b/08dbfadc1bf2c5f3c47f44c4ff91b50b2b24ea6dbad6f5edc880094a3c15/streamsx.elasticsearch-0.4.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "64ff8ff5d0770ede03fdaa4fa12e5221", "sha256": "73b053d6329d6cae567ad98734394ed06d42170b665834a15b44d04ac067807a" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.4.0.tar.gz", "has_sig": false, "md5_digest": "64ff8ff5d0770ede03fdaa4fa12e5221", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3942, "upload_time": "2018-12-13T12:20:42", "url": "https://files.pythonhosted.org/packages/6d/d5/454db0e5d2de64e4beedfac84cad9a2b9e643dabedfd92fa40d81f363251/streamsx.elasticsearch-0.4.0.tar.gz" } ], "0.5.0": [ { "comment_text": "", "digests": { "md5": "85257766593315fad3d2bd49e6630dee", "sha256": "2bff45ae34e896bb429e74fcf8640d4563ef47f56391a090d09df5a87632ea62" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.5.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "85257766593315fad3d2bd49e6630dee", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 10903, "upload_time": "2019-01-15T11:34:20", "url": "https://files.pythonhosted.org/packages/8f/d7/c2efcbca769ef906c3eeb9a723d7dc2d6a307fe1632d0cdabdfd0d8139d8/streamsx.elasticsearch-0.5.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "d69c5d9b18c544c5beefb4dfcb6a9c9b", "sha256": "607291521f2493053fe39a5f1ed10307e3d6db9fb8c8503682a8b2fba0a9b1a7" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.5.0.tar.gz", "has_sig": false, "md5_digest": "d69c5d9b18c544c5beefb4dfcb6a9c9b", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3959, "upload_time": "2019-01-15T11:34:18", "url": "https://files.pythonhosted.org/packages/7d/85/429ba6adbdafb16bf9047cf143f8dd8c8e67dbcdd2b993447a5a6cfd150a/streamsx.elasticsearch-0.5.0.tar.gz" } ], "0.6.0": [ { "comment_text": "", "digests": { "md5": "962e6226537d0798797610cc8ce83767", "sha256": "4b52c34a4b8112099484665321e5037e18b721da6531fd61a63d54ce8251b476" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.6.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "962e6226537d0798797610cc8ce83767", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 11429, "upload_time": "2019-01-31T09:18:21", "url": "https://files.pythonhosted.org/packages/78/b5/899fe3bc3eb3203eb10e4d0d31ac2579bcf970a65f78432a760a07d9e518/streamsx.elasticsearch-0.6.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "27c4890d7d5ec45220a38eefbfeaaf4f", "sha256": "7da7cc80641e2d3d780c80eac02fe864c4b979b75b01d77d3afd36e46e4bf7ce" }, "downloads": -1, "filename": "streamsx.elasticsearch-0.6.0.tar.gz", "has_sig": false, "md5_digest": "27c4890d7d5ec45220a38eefbfeaaf4f", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4495, "upload_time": "2019-01-31T09:18:19", "url": "https://files.pythonhosted.org/packages/da/64/8ccd32af98af0dea03c120ef791e44cfe47dccea40e0f76dcaa7aebf2dc0/streamsx.elasticsearch-0.6.0.tar.gz" } ], "1.0.0": [ { "comment_text": "", "digests": { "md5": "3e356713ab3f95151750311a54ab057e", "sha256": "8e8bfef92f50cc664bc26eb0c2d73cb194af82a25df449eb2cced338c315e110" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.0.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "3e356713ab3f95151750311a54ab057e", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 11427, "upload_time": "2019-02-05T09:33:00", "url": "https://files.pythonhosted.org/packages/71/57/59551f1bcab90133d79463dbe8b05f472cf79c670d835421a9c809b1328d/streamsx.elasticsearch-1.0.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "37aed44cbe0c0a9946c5d15195dba632", "sha256": "2ecb673154bd88095b29680e66289fc4d7d401d91924d2586ae9592752e55e6a" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.0.0.tar.gz", "has_sig": false, "md5_digest": "37aed44cbe0c0a9946c5d15195dba632", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4497, "upload_time": "2019-02-05T09:32:58", "url": "https://files.pythonhosted.org/packages/bc/bf/360116fe78cb56cf7f41ff78d158eaed4e53d01de3c7718978a4cc30eea4/streamsx.elasticsearch-1.0.0.tar.gz" } ], "1.1.0": [ { "comment_text": "", "digests": { "md5": "c825a4d5f967356aee9a9d8c5b5f9c5c", "sha256": "ccac1b1213eb1f811ba2ae6e8a7baee14d3d0d5c7f1dce591e74b787702e4365" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.1.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "c825a4d5f967356aee9a9d8c5b5f9c5c", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 11594, "upload_time": "2019-02-19T12:18:12", "url": "https://files.pythonhosted.org/packages/b7/80/f9a3174b6eb4d0d96643778bd9dd867ebf15e4e3b3bb7100f8705899a6d9/streamsx.elasticsearch-1.1.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "b63555eb6643fcee5ac9f704e9c89960", "sha256": "53e6eaf16e070c8bb646c1dbd2d455ba558c0ea12a376333790cdcd07d4bc191" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.1.0.tar.gz", "has_sig": false, "md5_digest": "b63555eb6643fcee5ac9f704e9c89960", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4637, "upload_time": "2019-02-19T12:18:10", "url": "https://files.pythonhosted.org/packages/27/47/72f8ddf97546cd8e2ffe5375ffac71581ce7766d5656c04fdd7a7d969b67/streamsx.elasticsearch-1.1.0.tar.gz" } ], "1.1.1": [ { "comment_text": "", "digests": { "md5": "72d899950d5552785ab0a6bfaf2e9778", "sha256": "eca02ac169ac0951e43a4ce56199c32e8b80780c92b60e1beff48491a94127a4" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.1.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "72d899950d5552785ab0a6bfaf2e9778", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 11914, "upload_time": "2019-03-01T13:15:52", "url": "https://files.pythonhosted.org/packages/fb/a4/c8beaf0ce23032baa0bb829895ff7d13e4cfc68f961c687fde02d68c6664/streamsx.elasticsearch-1.1.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "14f7b16f2ed4b348d34886af730be5ae", "sha256": "d48a1d78ac98649437eabff2aa17e6c3b5c40a0ed50fd916ed3a40f0ab40a8e4" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.1.1.tar.gz", "has_sig": false, "md5_digest": "14f7b16f2ed4b348d34886af730be5ae", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4719, "upload_time": "2019-03-01T13:15:50", "url": "https://files.pythonhosted.org/packages/57/2d/59d0db92cdc6f2f2cf36e6030346e9a7c23050d9fb366514e599cf33e2ab/streamsx.elasticsearch-1.1.1.tar.gz" } ], "1.1.2": [ { "comment_text": "", "digests": { "md5": "eec958de4117d061d20df20625000da8", "sha256": "66889afc951771aa43f9cb78bfe2424d6f18382efe33b3818db98560443ff06b" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.1.2-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "eec958de4117d061d20df20625000da8", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 11911, "upload_time": "2019-06-11T11:29:43", "url": "https://files.pythonhosted.org/packages/35/2f/0f84b05a30ea987b824fd705dc61a03acf56112861007187b70bc276eb9c/streamsx.elasticsearch-1.1.2-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "8e4b71f3e53816731f581797b6a0a632", "sha256": "b50f321ec7058c100579ff94a8c7839da0725f3290c6f871437517b8f4c7bc35" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.1.2.tar.gz", "has_sig": false, "md5_digest": "8e4b71f3e53816731f581797b6a0a632", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4679, "upload_time": "2019-06-11T11:29:41", "url": "https://files.pythonhosted.org/packages/5f/f0/546271642a44ca90f56675c3a0862f88f258b96e449273a0e52334544544/streamsx.elasticsearch-1.1.2.tar.gz" } ], "1.2.0": [ { "comment_text": "", "digests": { "md5": "7cb33fdf228ec78eebcfa942d9272c88", "sha256": "38a0f96a5cb40cdd067d912cbea1469d972fea6fb270926d78e6d677126889b2" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.2.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "7cb33fdf228ec78eebcfa942d9272c88", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 12544, "upload_time": "2019-09-03T09:48:38", "url": "https://files.pythonhosted.org/packages/09/90/ee28aaff18ed6424f8807cd36f383f150b3eb500b0f211d0f746befec876/streamsx.elasticsearch-1.2.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "6828fc3c134b9cac9da09bf98e23096c", "sha256": "ebd1cc56988e70735b9709365fd5f5580cc3ecb489a5ff69d3540d53070b5ba5" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.2.0.tar.gz", "has_sig": false, "md5_digest": "6828fc3c134b9cac9da09bf98e23096c", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5245, "upload_time": "2019-09-03T09:48:36", "url": "https://files.pythonhosted.org/packages/26/e0/d6bf037f40aafcf944756ea0791cbff31bd9cf1e17aab4d7b9aa956e7bfc/streamsx.elasticsearch-1.2.0.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "7cb33fdf228ec78eebcfa942d9272c88", "sha256": "38a0f96a5cb40cdd067d912cbea1469d972fea6fb270926d78e6d677126889b2" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.2.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "7cb33fdf228ec78eebcfa942d9272c88", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 12544, "upload_time": "2019-09-03T09:48:38", "url": "https://files.pythonhosted.org/packages/09/90/ee28aaff18ed6424f8807cd36f383f150b3eb500b0f211d0f746befec876/streamsx.elasticsearch-1.2.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "6828fc3c134b9cac9da09bf98e23096c", "sha256": "ebd1cc56988e70735b9709365fd5f5580cc3ecb489a5ff69d3540d53070b5ba5" }, "downloads": -1, "filename": "streamsx.elasticsearch-1.2.0.tar.gz", "has_sig": false, "md5_digest": "6828fc3c134b9cac9da09bf98e23096c", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5245, "upload_time": "2019-09-03T09:48:36", "url": "https://files.pythonhosted.org/packages/26/e0/d6bf037f40aafcf944756ea0791cbff31bd9cf1e17aab4d7b9aa956e7bfc/streamsx.elasticsearch-1.2.0.tar.gz" } ] }