2 个仓库
Capabilities for identifying and listing available data streams from a source for synchronization.
Distinct from Data Stream Integrations: Distinct from general stream integration by focusing specifically on the discovery and listing phase of datasets.
Explore 2 awesome GitHub repositories matching data & databases · Stream Discovery. Refine with filters or upvote what's useful.
Mage AI 是一个基于 Python 的数据流水线编排器和自托管数据集成开发环境。它旨在通过基于块的流水线设计和交互式笔记本界面来构建、调度和监控数据工作流。 该平台通过集成生成式 AI 功能脱颖而出,允许用户通过 API 连接大语言模型提供商,将人工智能纳入自动化数据流中。它还作为一个 Apache Spark 数据处理器,管理高性能分析和大规模数据处理所需的内核和基础设施。 该系统涵盖了广泛的数据工程功能,包括 ETL 工作流自动化、dbt 模型管理和数据流发现。它提供了通过 Git 进行版本控制集成、容器化部署以及基于角色的访问控制的工具,以管理跨开发和生产环境的流水线。监控通过系统性能遥测和流水线执行调试进行处理。
Identifies and lists available data streams from a source to determine datasets ready for synchronization.
dlt 是一个 Python 数据摄取工具和 ETL 流水线框架,旨在从不同来源获取数据并将其持久化到结构化目标中。它作为一个模式推断引擎,可自动检测数据类型并将嵌套的 JSON 结构扁平化为关系表,将数据从源端移动到数据湖、数据仓库或向量数据库。 该项目通过 AI 驱动的流水线生成脱颖而出,利用大语言模型为 REST API 构建提取代码和连接器。它还支持多模态向量存储和向量数据库的专门填充,以支持 AI 和机器学习应用。 该框架涵盖了广泛的功能,包括自动化模式演进、通过状态跟踪进行增量数据加载,以及通过强制执行数据契约进行数据质量验证。它提供了用于关系数据规范化、加载前后转换的工具,以及针对 SQL 数据库和云对象存储的多种目标适配器。 可观测性通过流水线执行仪表板、列血缘跟踪以及使用基于内容的哈希进行模式版本验证来处理。
Identifies and lists available data inputs by name or description to integrate new information streams.