streamsx.database 0.1.1

IBM Streams Database integration

Overview

Provides functions to run SQL statements to a IBM Db2 Warehouse on Cloud. This package exposes the com.ibm.streamsx.jdbc toolkit as Python methods for services on IBM Cloud.

• IBM Streaming Analytics

• IBM Db2 Warehouse

Sample

A simple hello world example of a Streams application that creates a table, inserts a row and deletes the table:

from streamsx.topology.topology import *
from streamsx.topology.schema import CommonSchema, StreamSchema
from streamsx.topology.context import submit
import streamsx.database as db

topo = Topology()
sql_create = 'CREATE TABLE RUN_SAMPLE (A CHAR(10), B CHAR(10))'
sql_insert = 'INSERT INTO RUN_SAMPLE (A, B) VALUES (\'hello\', \'world\')'
sql_drop = 'DROP TABLE RUN_SAMPLE'
s = topo.source([sql_create, sql_insert, sql_drop]).as_string()
res_sql = db.run_statement(s, credentials)
res_sql.print()
submit('STREAMING_ANALYTICS_SERVICE', topo)

Documentation

• streamsx.database package documentation