Stream Processing
Streaming Database for IoT
★ 3.6
Scalable Stream Processing
★ 4.6
pip install hstreamdbpip install pysparkpip install hstreamdbpip install pysparkPython data engineers use the `hstreamdb` Python client to produce and consume events from HStreamDB streams in IoT and real-time analytics pipelines. SQL subscriptions let Python consumers receive only the records matching a filter condition, reducing the amount of data the Python processor needs to handle and filter client-side.
Python data engineers use Spark Structured Streaming via PySpark to process high-volume Kafka streams at scale. A streaming job reads a Kafka topic as a DataFrame, applies transformations (filtering, aggregations, joins with static data), and writes results continuously to Delta Lake or a database — using the same PySpark syntax as batch jobs.
Individual Tool Pages