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
33 watching
183 forks
Language: Python
last commit: 9 days 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,190 |
 python-streamz/streamz | A library for building and managing real-time stream processing pipelines in Python | 1,244 |
 wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for stream processing applications | 313 |
 bytewax/bytewax | A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities. | 1,558 |
 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,480 |
 nerevu/riko | A Python library for analyzing and processing streams of structured data | 1,604 |
 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,495 |
 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,141 |
 maki-nage/makinage | Stream Processing Library and Framework | 39 |
 raystack/dagger | A cloud-native framework for stateful processing of real-time streaming data | 267 |
 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 |