semvec/pypi-packages huggingface dataset:
streamsx.eventstore 2.8.5
Event Store integration for IBM Streams
License: Apache License - Version 2.0
Keywords: streams

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.

Supported versions:

* Db2 Event Store 1.x: streamsx.eventstore version 1.x
* Db2 Event Store 2.x: streamsx.eventstore version 2.x


Documentation
=============

* `streamsx.eventstore package documentation <http://streamsxeventstore.readthedocs.io>`_
streamsx.sttgateway 1.0.1
Speech To Text gateway integration for IBM Streams
License: Apache License - Version 2.0
Keywords: streams

Overview
========

Provides functions and classes for use with Streaming Analytics service on
IBM Cloud and IBM Streams including IBM Cloud Pak for Data.

Transcribes audio into text via the IBM Watson STT (Speech To Text) service running on the IBM Cloud or on the IBM Cloud Pak for Data.

* `IBM Streams <https://ibmstreams.github.io/>`_
* `Watson Speech to Text <https://www.ibm.com/cloud/watson-speech-to-text>`_

Documentation
=============

* `streamsx.sttgateway package documentation <http://streamsxsttgateway.readthedocs.io>`_
streamsx.pmml 1.0.7
PMML integration for IBM Streams
License: Apache License - Version 2.0
Keywords: streams

Overview
========

Provides functions to score input records using PMML models and to interact with the Watson Machine Learning (WML) repository.


This package exposes the `com.ibm.streams.pmml` toolkit as Python methods for use with Streaming Analytics service on
IBM Cloud and IBM Streams including IBM Cloud Pak for Data.

* `IBM Streams <https://ibmstreams.github.io/>`_
* `IBM Cloud Machine-Learning-Service <https://console.bluemix.net/catalog/services/machine-learning>`_


For details on PMML see `Predictive Model Markup Language <https://en.wikipedia.org/wiki/Predictive_Model_Markup_Language>`_.

For details on WML see `Watson Machine Learning Service <https://dataplatform.cloud.ibm.com/docs/content/analyze-data/ml-overview.html?context=analytics>`_.


Documentation
=============

* `streamsx.pmml package documentation <http://streamsxpmml.readthedocs.io>`_
streamsx.objectstorage 1.5.6
Object Storage integration for IBM Streams
License: Apache License - Version 2.0
Keywords: streams

Overview
========

Provides functions to read objects from Object Storage as a stream
and submit tuples to create objects in Object Storage.

Cloud Object Storage (COS) or any other S3 compatible object storage can be used.

* `IBM Streams <https://ibmstreams.github.io/>`_
* `IBM Cloud Object Storage <https://www.ibm.com/cloud/object-storage>`_

Documentation
=============

* `streamsx.objectstorage package documentation <http://streamsxobjectstorage.readthedocs.io/>`_
streamsx.mqtt 1.0.3
MQTT integration for IBM Streams topology applications
License: Apache License - Version 2.0
Keywords: streams

Overview
========

Provides function:

* to connect to an MQTT server
* to subscribe to topics and receive events
* to send events

This package wraps the `com.ibm.streamsx.mqtt` toolkit for use with Python. It can be used with Streaming Analytics service on
IBM Cloud and IBM Streams including IBM Cloud Pak for Data.

* `IBM Streams <https://ibmstreams.github.io/>`_


Documentation
=============

* `streamsx.mqtt package documentation <http://streamsxmqtt.readthedocs.io>`_
streamsx.kafka 1.10.2
Kafka integration for IBM Streams topology applications
License: Apache License - Version 2.0
Keywords: streams

Overview
========

Provides functions to read messages from Kafka brokers including the IBM Event Streams cloud service as a stream
and submit tuples to Kafka brokers as messages.

The broker configuration must be done with properties in an application configuration or by
using a dictionary variable.
The minimum set of properties must contain the `bootstrap.servers` configuration, which is valid
for both consumers and producers, i.e. for the `KafkaConsumer` and `KafkaProducer` classes.

It is also possible to use different application configurations for consumer and producer
when special consumer or producer configs must be used.

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
    from streamsx.kafka import KafkaConsumer, KafkaProducer
    import time
    
    def delay(v):
        time.sleep(5.0)
        return True
    
    topology = Topology('KafkaHelloWorld')
    
    to_kafka = topology.source(['Hello', 'World!'])
    to_kafka = to_kafka.as_string()
    # delay tuple by tuple
    to_kafka = to_kafka.filter(delay)
    
    # Publish a stream to Kafka using TEST topic, the Kafka server is at localhost
    producer = KafkaProducer(config={'bootstrap.servers': 'localhost:9092'},
                             topic='TEST')
    to_kafka.for_each(producer)
    
    # Subscribe to same topic as a stream
    consumer = KafkaConsumer(config={'bootstrap.servers': 'localhost:9092'},
                             schema=CommonSchema.String,
                             topic='TEST')
    from_kafka = topology.source(consumer)
    
    # You'll find the Hello World! in stdout log file:
    from_kafka.print()
    
    submit(ContextTypes.DISTRIBUTED, topology)
    # The Streams job is kept running.

Documentation
=============

* `streamsx.kafka package documentation <http://streamsxkafka.readthedocs.io/>`_
streamsx.geospatial 1.1.4
Geospatial integration for IBM Streams
License: Apache License - Version 2.0
Keywords: streams

Overview
========

Provides geospatial functions and classes for use with Streaming Analytics service on
IBM Cloud and IBM Streams including IBM Cloud Pak for Data.

* `IBM Streams <https://ibmstreams.github.io/>`_


Documentation
=============

* `streamsx.geospatial package documentation <http://streamsxgeospatial.readthedocs.io>`_
streamsx.elasticsearch 1.3.4
Elasticsearch integration for IBM Streams
License: Apache License - Version 2.0
Keywords: streams

Overview
========

Provides functions to store tuple data as JSON documents in Elasticsearch indices.

* `IBM Streams <https://ibmstreams.github.io/>`_
* `Compose for Elasticsearch <https://www.ibm.com/cloud/compose/elasticsearch>`_

Documentation
=============

* `streamsx.elasticsearch package documentation <http://streamsxelasticsearch.readthedocs.io/>`_
streamsx.avro 1.2.4
Avro integration for IBM Streams
License: Apache License - Version 2.0
Keywords: streams

Overview
========

Provides functions for serialization and deserialization of messages in an Apache Avro format.

* `IBM Streams <https://ibmstreams.github.io/>`_

Documentation
=============

* `streamsx.avro package documentation <http://streamsxavro.readthedocs.io>`_