能否通过编程方式获取Airflow中DAG任务的渲染模板？

数据老陈

2026-6-15

编程获取Airflow Rendered Template信息的方法

完全可以通过编程方式获取Airflow UI中「Rendered Template」页面的内容，以下是三种实用方法：

1. 调用Airflow REST API（推荐）

Airflow v2.x及以上提供了完善的REST API，可直接获取指定任务实例的渲染模板数据：

核心API端点：GET /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/rendered
示例curl命令：

curl -X GET \
  "http://<你的Airflow服务地址>:<端口>/api/v1/dags/<DAG-ID>/dagRuns/<DAG运行ID>/taskInstances/<任务ID>/rendered" \
  -H "Authorization: Bearer <你的API令牌>"

返回的JSON数据会包含该任务所有渲染后的参数，包括KubernetesPodOperator传入的脚本参数、环境变量等关键内容，直接用于对比即可。

2. 查询Airflow元数据库

若有权限访问Airflow的元数据库（如PostgreSQL、MySQL），可直接查询存储渲染数据的表：

Airflow v2.x使用rendered_task_instance_fields表存储渲染字段，配合task_instance和dag_run表关联查询：

SELECT rtif.rendered_fields
FROM rendered_task_instance_fields rtif
JOIN task_instance ti ON rtif.task_instance_id = ti.id
JOIN dag_run dr ON ti.dag_run_id = dr.id
WHERE ti.dag_id = '<你的DAG-ID>'
  AND dr.run_id = '<你的DAG运行ID>'
  AND ti.task_id = '<你的任务ID>';

查询结果中的rendered_fields为JSON格式，解析后即可获取渲染后的任务参数。

3. 使用Airflow Python SDK

在Airflow集群内部执行脚本时，可通过官方Python SDK直接获取：

from airflow.api.client.local_client import Client

# 初始化本地客户端
client = Client(None, None)
# 获取渲染后的任务字段
rendered_content = client.get_rendered_task_fields(
    dag_id="<你的DAG-ID>",
    dag_run_id="<你的DAG运行ID>",
    task_id="<你的任务ID>"
)
# 打印或处理渲染数据
print(rendered_content)