pathwaycom / pathway

Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.

online-ml / river

🌊 Online machine learning in Python

ag2ai / faststream

Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.

bytewax / bytewax

Python Stream Processing

quixio / quix-streams

Python Streaming DataFrames for Kafka

dpnkrpl / radio-active

Play any radios around the globe right from the terminal :zap:

nerevu / riko

A Python stream processing engine modeled after Yahoo! Pipes