streamz
Stream processor
A library for building and managing real-time stream processing pipelines in Python
Real-time stream processing for python
1k stars
35 watching
148 forks
Language: Python
last commit: 11 months ago
Linked from 1 awesome list
asyncpythonreal-timestreaming-data
manuzhang/awesome-streamingRelated projects:
| Repository | Description | Stars |
|---|---|---|
 bytewax/bytewax | A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities. | 1,585 |
 pystorm/streamparse | Enables real-time computation on live streams of data using Python | 1,494 |
 wallaroolabs/wally | A distributed stream processing framework for real-time data reactions | 1,477 |
 quora/asynq | A Python library that simplifies asynchronous programming by allowing batching of requests to external services. | 688 |
 nerevu/riko | A Python library for analyzing and processing streams of structured data | 1,605 |
 beatrichartz/parallel_stream | An Elixir module that parallelizes stream operations while preserving order | 100 |
 scramjetorg/framework-python | Reactive stream processing framework for Python | 35 |
 faust-streaming/faust | A Python stream processing library that enables real-time data pipelines and event-driven systems with scalability and reliability. | 1,675 |
 wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for building stream processing applications | 311 |
 maki-nage/makinage | Stream Processing Library and Framework | 38 |
 quixio/quix-streams | A Python framework for real-time data processing on Apache Kafka streams | 1,246 |
 saghul/pythonz | Automates building and installation of multiple Python versions on a user's system | 750 |
 mosaicml/streaming | A library for efficient data streaming and training of neural networks on large datasets | 1,171 |
 jpcik/morph-streams | A tool for processing and analyzing continuous data streams using query languages | 16 |
 pytoolz/cytoolz | A high-performance functional data analysis library for Python | 1,010 |