wally
Stream processor
A distributed stream processing framework for real-time data reactions
Distributed Stream Processing
1k stars
70 watching
68 forks
Language: Pony
last commit: over 5 years agoLinked from 2 awesome lists
apiframeworkgogolanglinuxpony-languagepythonstream-processingstream-processing-enginestream-processor
manuzhang/awesome-streaming
rootsongjc/awesome-cloud-nativeRelated 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 |
 reugn/go-streams | Provides a lightweight and flexible way to process data streams in Go | 1,935 |
 python-streamz/streamz | A library for building and managing real-time stream processing pipelines in Python | 1,247 |
 maki-nage/makinage | Stream Processing Library and Framework | 38 |
 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 |
 nerevu/riko | A Python library for analyzing and processing streams of structured data | 1,605 |
 bkirwi/coast | A streaming data processing framework with strong ordering and exactly-once semantics | 60 |
 picanumber/yapp | Parallel pipeline library for stream processing | 62 |
 substantic/rain | A framework for processing large-scale task-based pipelines in a distributed manner | 749 |
 quixio/quix-streams | A Python framework for real-time data processing on Apache Kafka streams | 1,246 |
 go-playground/webhooks | A library that enables easy processing of GitHub, Bitbucket, GitLab, and other web service notifications. | 963 |
 scramjetorg/framework-cpp | A C++ framework for reactive stream programming with concurrent asynchronous operations | 3 |
 keilerkonzept/topk | An implementation of probabilistic data structures for approximate data stream processing | 4 |
| scramjetorg/framework-python | Reactive stream processing framework for Python | 35 |
 gazette/core | Enables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms | 723 |