IBM Streams Event Streams integration for IBM Streams topology applications
Project description
Overview
Provides functions to read messages from IBM Event Streams as a stream and publish tuples to Event Streams as messages.
IBM® Event Streams is a fully managed, cloud-based messaging service. Built on Apache Kafka, IBM Event Streams is a high-throughput, fault-tolerant, event management platform that helps you build intelligent, responsive, event-driven applications.
You may also review the streamsx.kafka package. to integrate IBM Event Streams cloud service with your IBM Streams topology applications.
Sample
A simple hello world example of a Streams application publishing to a topic and the same application consuming the same topic:
from streamsx.topology.topology import Topology from streamsx.topology.schema import CommonSchema from streamsx.topology.context import submit, ContextTypes import streamsx.eventstreams as eventstreams import time def delay(v): time.sleep(5.0) return True topology = Topology('EventStreamsHelloWorld') to_evstr = topology.source(['Hello', 'World!']) to_evstr = to_evstr.as_string() # delay tuple by tuple to_evstr = to_evstr.filter(delay) # Publish a stream to Event Streams using HELLO topic eventstreams.publish(to_evstr, topic='HELLO') # Subscribe to same topic as a stream from_evstr = eventstreams.subscribe(topology, schema=CommonSchema.String, topic='HELLO') # You'll find the Hello World! in stdout log file: from_evstr.print() # finally submit the topology to a Streaming Analytics Service instance submit(ContextTypes.STREAMING_ANALYTICS_SERVICE, topology)
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.eventstreams-2.0.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 907e1a5e7bcea7641ab1e8c33b683365cc6fda769f952bae709d5e2e24c52c0f |
|
MD5 | c5127703a7fe739a2af23f9646fd0141 |
|
BLAKE2b-256 | 7349ca87a81d3e8924d04ee4fb3d49b6da592e442eba188ba00b0d6b332ff885 |
Hashes for streamsx.eventstreams-2.0.1-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 327071a7ae62e83695dab18c43aff09a8e4cd1202eee0c043d44ac58918765aa |
|
MD5 | 54e4d875671871b9185323d372ec3b74 |
|
BLAKE2b-256 | 5e4edfe0be422012e94b58adb5db9e2dc6aae7cb8c0c09451b8b3cb12707ebcc |