riko
Stream processor
A Python library for analyzing and processing streams of structured data
A Python stream processing engine modeled after Yahoo! Pipes
2k stars
52 watching
76 forks
Language: Python
last commit: about 3 years ago
Linked from 1 awesome list
asynchronousclidataetlfeaturedfunctional-programminglibraryparallelismrssstream-processing
pawl/awesome-etlRelated projects:
| Repository | Description | Stars |
|---|---|---|
 maki-nage/makinage | Stream Processing Library and Framework | 38 |
 bytewax/bytewax | A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities. | 1,585 |
 bkirwi/coast | A streaming data processing framework with strong ordering and exactly-once semantics | 60 |
 wallaroolabs/wally | A distributed stream processing framework for real-time data reactions | 1,477 |
 basho/riak_pipe | Enables parallel processing of data by dividing tasks into independent queues managed by Riak Core's vnode architecture. | 162 |
 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 |
 quixio/quix-streams | A Python framework for real-time data processing on Apache Kafka streams | 1,246 |
 edwardcapriolo/teknek-core | A software platform that enables stream processing and data integration across multiple data sources. | 8 |
 beatrichartz/parallel_stream | An Elixir module that parallelizes stream operations while preserving order | 100 |
 streamio/streamio-ffmpeg | Provides a Ruby interface to FFmpeg for reading movie metadata and transcoding video files. | 1,649 |
 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 |
 wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for building stream processing applications | 311 |
 dm6718/ritsar | A Python-based software toolkit for processing Synthetic Aperture Radar image data | 208 |
 raine/ramda-cli | A tool for composing functions into data-processing pipelines to produce desired output. | 573 |