mcpField
T
tracing-downstream-lineage

tracing-downstream-lineage

github.com/necatiarslan数据与数据库4446 次安装21 周前更新
代码仓库

关于 tracing-downstream-lineage

用于分析表或 DAG 变更下游影响的数据血缘技能。它追踪消费方、划分重要性，并整理包含责任人和缓解措施的影响报告。

主要功能

  1. 01查找表和 DAG 的直接消费方
  2. 02追踪下游依赖关系
  3. 03按重要性划分资产
  4. 04评估架构与时间变更风险
  5. 05汇总影响、负责人和缓解措施

适用场景

  1. 01评估表变更前的影响
  2. 02查找消费某 DAG 输出的其他 DAG
  3. 03编写下游变更风险报告

安装

复制下面的命令，在终端中运行。

$npx skills add https://github.com/necatiarslan/airflow-vscode-extension --skill tracing-downstream-lineage

安装后在 Claude Code 中输入/tracing-downstream-lineage确认已加载。

详细介绍

下游血缘：影响

回答以下问题：“如果我更改此项，会有什么影响？”

影响分析

步骤 1：确定直接使用方

对于表：

  1. 使用 list_active_dags 和 list_paused_dags 列出 DAG
  2. 使用 get_dag_source_code 搜索 DAG 源代码，查找表引用

对于 DAG：

  1. 根据 DAG 源代码确定输出
  2. 追踪读取这些输出的下游 DAG
步骤 2：构建依赖树

示例：

SOURCE: fct.orders
    |
    +-- TABLE: agg.daily_sales -> Dashboard: Executive KPIs
    +-- TABLE: ml.order_features -> Model: Forecasting
步骤 3：按关键程度分类
  • 严重：生产仪表板、面向客户的应用
  • 高：内部运维仪表板、下游 ETL
  • 中：临时分析
  • 低：已弃用或测试数据
步骤 4：评估变更风险

请考虑：

  • 架构变更
  • 数据时序变更
  • 删除或弃用
步骤 5：查找相关方
  • DAG 定义中的 DAG 所有者
  • BI 工具中的仪表板所有者

输出：影响报告

包括：

  • 下游资产摘要
  • 影响示意图
  • 详细影响及所有者
  • 风险评估和缓解措施

相关技能

  • tracing-upstream-lineage
  • checking-freshness
  • debugging-dags
  • annotating-task-lineage
  • creating-openlineage-extractors

评论

支持 Markdown