IBM Streams Event Store integration
Project description
Overview
Provides a function to insert IBM Streams tuple data into a table in IBM Db2 Event Store.
IBM Db2 Event Store is an in-memory database designed to rapidly ingest and analyze streamed data in event-driven applications. It provides the fabric for fast data with its ability to process massive volume of events in real-time, coupled with optimization for streamed data performance for advanced analytics and actionable insights.
This package exposes the com.ibm.streamsx.eventstore toolkit and com.ibm.streamsx.jdbc toolkit as Python methods.
Supported versions:
Db2 Event Store 1.x: streamsx.eventstore version 1.x
Db2 Event Store 2.x: streamsx.eventstore version 2.x
Sample
A simple example of a Streams application inserting rows to a table in a Db2 Event Store database:
from streamsx.topology.topology import Topology from streamsx.topology.schema import CommonSchema, StreamSchema from streamsx.topology.context import submit from streamsx.topology.context import ContextTypes import streamsx.spl.toolkit import streamsx.eventstore as es topo = Topology('EventStoreSample') # provide connection endpoint information es_connection = 'HostIP:Port1;HostIP:Port2' # generate sample tuples with the schema of the target table s = topo.source([1,2,3,4,5,6,7,8,9]) schema=StreamSchema('tuple<int32 id, rstring name>').as_tuple() s = s.map(lambda x : (x,'X'+str(x*2)), schema=schema) # insert tuple data into table as rows res = es.insert(s, connection=es_connection, database='TESTDB', table='SampleTable', primary_key='id', partitioning_key='id') submit (ContextTypes.DISTRIBUTED, topo) # The Streams job is kept running.
Documentation
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for streamsx.eventstore-2.4.2.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | d92890ab310b25c85caa0c6d9e79a861923fce9d377af75a5a396bf2f73a9e75 |
|
MD5 | 6a4ea5a4ae52f783323e5d360d78aba9 |
|
BLAKE2b-256 | d0739e4abf2e8a224f72ded9f05d4e6cb417ffb4ff4d185f3f1e03bb78bf1266 |
Hashes for streamsx.eventstore-2.4.2-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | cce2930d29eaf7173c611a66781debd6150daafbaa4d405bf2e998e9f7199dab |
|
MD5 | 3520a63b285bd9ee26b7e6ec53274375 |
|
BLAKE2b-256 | fc36cfa3b08984cfd2db76efb5cd81a440c1b2d6489ece97c70a31517a7d5ac9 |