Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
- airflow
- apache
- apache-airflow
- python
47,133 repositories indexed
1–23 of 23 · Most stars
Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
Ray is an AI compute engine. Ray consists of a core distributed runtime and a set of AI Libraries for accelerating ML workloads.
Open-source data movement for ELT pipelines and AI agents — from APIs, databases & files to warehouses, lakes, and AI applications. Both self-hosted and Cloud.
GUI for ChatGPT API and many LLMs. Supports agents, file-based QA, GPT finetuning and query with web search. All with a neat UI.
🐚 Python-powered shell. Full-featured, cross-platform and AI-friendly.
The Open Source Feature Store for AI/ML
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.
Meltano: the declarative code-first data integration engine that powers your wildest data and ML-powered product ideas. Say goodbye to writing, maintaining, and scaling your own API integrations.
A lightweight opinionated ETL framework, halfway between plain scripts and Apache Airflow
Elyra extends JupyterLab with an AI centric approach.
A library for event sourcing in Python.
asyncio client for kafka
Python3 client for NATS
OntiCards 是面向企业的 AI 数据中枢(AI Data Hub),围绕业务数据库提供一站式能力:数据源连接、元数据理解、自然语言查询、跨源融合、数据质检、查询审计与数据资产管理等
Karapace - Your Apache Kafka® essentials in one tool
The idiomatic asyncio MQTT client
Engine for AI/ML/Data tracking, visualization, explainability, drift detection, and dashboards for Polyaxon.
No description provided by the repository host.
Async MQTT client for CPython and MicroPython with asyncio support.
Declarative data quality engine. Define checks in YAML, run anywhere.
ETL scripts for EOS.
Open, audit-grade agentic data quality framework with portable industry packs
Pipeline de ingestão e busca semântica de documentos para RAG — com rate limiting, circuit breaker e fila resiliente.