streamsx.elasticsearch 0.1.0

IBM Streams Elasticsearch integration

Overview

Provides functions to store tuple data as JSON documents in Elasticsearch indices. This package exposes the com.ibm.streamsx.elasticsearch toolkit as Python methods for services on IBM Cloud.

Streaming Analytics Compose for Elasticsearch

Sample

A simple hello world example of a Streams application writing string messages to an index.:

from streamsx.topology.topology import *
from streamsx.topology.schema import CommonSchema
from streamsx.topology.context import submit
import streamsx.elasticsearch as es

topo = Topology('ElasticsearchHelloWorld')

s = topo.source(['Hello', 'World!']).as_string()
es.bulk_insert(s, 'test-index-cloud')

submit('STREAMING_ANALYTICS_SERVICE', topo)

Documentation

• streamsx.elasticsearch package documentation