Stream Processing
Python Stream Processing
★ 4.5
Streaming Database for IoT
★ 3.6
pip install faust-streamingpip install hstreamdbpip install faust-streamingpip install hstreamdbFaust lets Python data engineers write Kafka stream processors entirely in async Python — defining an agent as a coroutine that processes messages from a topic and produces results to another. Engineers use Faust tables for stateful aggregations (e.g., running counts or session windows) that persist across restarts via RocksDB.
Python 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.
Individual Tool Pages