faust
Stream processor
A Python stream processing library that enables real-time data pipelines and event-driven systems with scalability and reliability.
Python Stream Processing. A Faust fork
2k stars
32 watching
183 forks
Language: Python
last commit: 2 months ago
Linked from 1 awesome list
asynciodistributed-systemskafkapython-streamingredis
igorbarinov/awesome-data-engineeringRelated projects:
| Repository | Description | Stars |
|---|---|---|
 quixio/quix-streams | A Python framework for real-time data processing on Apache Kafka streams | 1,246 |
 python-streamz/streamz | A library for building and managing real-time stream processing pipelines in Python | 1,247 |
 wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for building stream processing applications | 311 |
 bytewax/bytewax | A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities. | 1,585 |
 madskjeldgaard/faustgen-supercollider | A tool that integrates Faust and SuperCollider for real-time signal processing | 29 |
 beatrichartz/parallel_stream | An Elixir module that parallelizes stream operations while preserving order | 100 |
 wallaroolabs/wally | A distributed stream processing framework for real-time data reactions | 1,477 |
 nerevu/riko | A Python library for analyzing and processing streams of structured data | 1,605 |
 gabriella439/pipes | A lightweight stream processing library that builds and connects reusable streaming components using Haskell | 489 |
 pystorm/streamparse | Enables real-time computation on live streams of data using Python | 1,494 |
 nodefluent/kafka-streams | A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. | 831 |
 mosaicml/streaming | A library for efficient data streaming and training of neural networks on large datasets | 1,171 |
 maki-nage/makinage | Stream Processing Library and Framework | 38 |
 raystack/dagger | A cloud-native framework for stateful processing of real-time streaming data | 268 |
 olacabs/fabric | A real-time stream processing framework designed to handle high-volume event ingestion and complex data processing tasks with guaranteed availability and scalability. | 55 |