【发布时间】:2021-06-19 17:39:22
【问题描述】:
我正在使用Apache Airflow REST API。
支持许多基本命令。例如,我可以通过运行返回特定 DAG 的信息:
https://8080/my_url/api/experimental/dags/example_pig_operator/dag_runs
...返回:
[{
"dag_id": "example_pig_operator",
"dag_run_url": "/admin/airflow/graph?dag_id=example_pig_operator&execution_date=2021-06-18 19:57:31+00:00",
"execution_date": "2021-06-18T19:57:31 00:00",
"id": 4,
"run_id": "manual__2021-06-18T19:57:31 00:00",
"start_date": "2021-06-18T19:57:31.474920 00:00",
"state": "running"
}]
但这并不能告诉你什么与什么有关。我看不到如何检索用于构建树的实际 DAG 数据。
有没有办法返回实际连接的 DAG 数据,以便人们可以构建自己的 UI 来可视化 DAG?
看来我们应该可以使用TaskInstance endpoint,但我看不到如何获得dag_run_id
【问题讨论】:
标签: api rest airflow directed-acyclic-graphs