streamsx.endpoint 0.1.0

IBM Streams endpoint integration

Overview

Provides functions to add Streams operators acting as communication endpoints for your Streams application.

This package exposes the com.ibm.streamsx.inetserver toolkit as Python methods for use with IBM Streams including IBM Cloud Pak for Data.

• IBM Streams developer community

Sample

A simple example of a Streams application that provides an endpoint for json injection:

from streamsx.topology.topology import *
from streamsx.topology.context import submit
import streamsx.endpoint as endpoint

topo = Topology()

s1 = endpoint.json_injection(topo)
s1.print()

submit ('DISTRIBUTED', topo)

Documentation

• streamsx.endpoint package documentation