Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
- batch-processing
- kafka
- pathway
- python
47,133 repositories indexed
1–10 of 10 · Most stars
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Logstash - transport and process your logs, events, or other data
Incremental engine for long horizon agents 🌟 Star if you like it!
SeaTunnel is a multimodal, high-performance, distributed, massive data integration tool.
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.
:elephant: Elasticsearch real-time search and analytics natively integrated with Hadoop
Python Streaming DataFrames for Kafka
High performance Rust stream processing engine seamlessly integrates AI capabilities, providing powerful real-time data processing and intelligent analysis.
Data logistics system enabling real-time pathogen surveillance. Built for the Seattle Flu Study.
Real-time GTFS database loader and ORM library.