bytewax

Stream processor

A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities.

Python Stream Processing

GitHub

2k stars
19 watching
64 forks
Language: Python
last commit: over 1 year ago
Linked from 2 awesome lists

data-engineeringdata-processingdata-sciencedataflowmachine-learningpythonruststream-processingstreaming-data

Backlinks from these awesome lists:

Related projects:

Repository Description Stars
wallaroolabs/wally A distributed stream processing framework for real-time data reactions 1,477
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
knowledgeonwebscale/streamingmassif A Java-based platform for efficient processing of data streams by performing cascading reasoning and complex event processing. 10
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
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
pystorm/streamparse Enables real-time computation on live streams of data using Python 1,494
jpcik/morph-streams A tool for processing and analyzing continuous data streams using query languages 16
wintoncode/winton-kafka-streams A Python implementation of Apache Kafka's Streams API for building stream processing applications 311
substantic/rain A framework for processing large-scale task-based pipelines in a distributed manner 749
scramjetorg/framework-python Reactive stream processing framework for Python 35
weblyzard/streaming-sparql Provides a robust, incremental processing of streaming results from SPARQL servers. 6
yahoo/streaming-benchmarks A comprehensive benchmarking platform for evaluating low-latency stream processing solutions 635