Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
- batch-processing
- kafka
- pathway
- python
47,133 repositories indexed
1–12 of 12 · Most stars
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Cross-platform, customizable ML solutions for live and streaming media.
Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.
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.
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
Kubernetes-native platform to run massively parallel data/streaming jobs
High-performance time-series aggregation for PostgreSQL
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
The fastest unified streaming SQL Engine in a single C++ binary. ⚡ Millisecond latency. 100+ GB/s throughput. Continuously compute stateful context from streams, logs, metrics, events, and CDC.
A lightweight stream processing library for Go
Python Streaming DataFrames for Kafka
Distributed Stream Processing