Agent Skills
返回列表
📊

Meltano 声明式 ELT 数据集成引擎

数据分析 更新于 2026.08.29

将以下提示词粘贴到你的 AI 对话框中:

请根据 https://skillhub.cn/install/skillhub.md,安装 @user_3c6cb52e/meltano-declarative-elt-data-integration-engine。

技能介绍

要解决什么问题

数据工程师常面对这类场景:CRM、广告平台、业务数据库和一堆 CSV 文件,要统一灌进 Snowflake 或 Databricks。每个源的 schema、认证方式、增量逻辑都不一样,于是团队里复制了十几份差不多的胶水脚本,字段映射散落在各处,出了线上问题只能翻提交记录。

技能如何工作

Meltano 的思路是把「从哪抽、往哪灌」拆成两个标准件:Singer taps 负责按规范从源端抽取(含 schema 发现与增量游标),Singer targets 负责把标准化后的记录写入目标端。所谓 600+ 连接器,本质就是这些 taps / targets 的注册表。

关键步骤:

  • 声明式配置:在 meltano.yml 里描述 pipeline,而不是手写 Python
  • 代码优先:配置可入 Git、可 review、可版本化
  • 覆盖 API、数据库、文件三类来源,目标端对接数仓与湖仓

适用边界与注意点

上游仓库未提供可直接执行的安装与调用说明,意味着你需要先到 Meltano 上游项目核对版本兼容性与安全实践,再决定是否接入生产流程。涉及生产数据时,建议先做 dry-run 和最小权限验证。

使用场景

  • 要把 Salesforce、广告平台和 Postgres 业务库按统一 schema 同步进 Snowflake 做月度分析
  • 多份 CSV 报表和 API 日志需要增量写入数据湖,要求保留游标、可断点续传
  • 想用 Git 管理数据管道配置,替代散落各处的一次性 Python 同步脚本
  • 需要按 Singer 规范封装内部自研数据源,交给下游目标端统一消费

适合人员

  • 数据工程师:要把多个 API 与数据库源同步进数仓,且管道配置可 review、可回滚
  • 分析工程师:习惯用 Git 管理管道定义,想用声明式配置替代手写同步脚本
  • 数据平台负责人:想基于 Singer 规范统一对接内部自研源与目标端的写入标准