Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
- batch-processing
- kafka
- pathway
- python
47,133 repositories indexed
1–19 of 19 · Most stars
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Convert documents to structured data effortlessly. Unstructured is open-source ETL solution for transforming complex documents into clean, structured formats for language models. Visit our website to learn more about our enterprise grade Platform product for production grade workflows, partitioning, enrichments, chunking and embedding.
Logstash - transport and process your logs, events, or other data
SeaTunnel is a multimodal, high-performance, distributed, massive data integration tool.
Fancy stream processing made operationally mundane
Privacy and Security focused Segment-alternative, in Golang and React
Self-hosted platform to unify wearable health data through one AI-ready API.
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 distributed data integration framework that simplifies common aspects of big data integration such as data ingestion, replication, organization and lifecycle management for both streaming and batch data ecosystems.
Python Streaming DataFrames for Kafka
Apache InLong - a one-stop, full-scenario integration framework for massive data
Dex : The Data Explorer -- A data visualization tool written in Java/Groovy/JavaFX capable of powerful ETL and publishing web visualizations.
omniparser: a native Golang ETL streaming parser and transform library for CSV, JSON, XML, EDI, text, etc.
:lipstick: Durable and asynchronous data imports for consuming data at scale and publishing testable SDKs.
Download, unpack from a ZIP/TAR/GZ/BZ2 archive, parse, correct, convert units and import Google Spreadsheets, XLS, ODS, XML, CSV, HTML, etc. into your ActiveRecord models. Uses RemoteTable gem internally.
Universal BLE Smart Scale bridge. Captures body composition from Renpho, Xiaomi & 20+ others, syncs to Garmin Connect, Strava, MQTT (Home Assistant), InfluxDB, Webhooks, Ntfy & local files (CSV/JSONL). Headless CLI for Raspberry Pi, Linux, macOS & Windows.
Insert incoming MQTT values into InfluxDB. Follows mqtt-smarthome architecture.
High performant ETL engine written in TypeScript
R COBOL DI (Data Integration) Package : Import COBOL CopyBook data files directly into R as properly structured data frames.