0

Airflow 提供了 REST API 功能来提取 dag/task 状态。

https://airflow.apache.org/docs/apache-airflow/stable/stable-rest-api-ref.html#section/Trying-the-API

但是想知道是否有一种方法可以仅在不为每个 dag id 手动指定的情况下获取所有 dags wrt dag owner 的最新 dag/task 状态。

这将帮助我们为业务用户创建工作流仪表板。

4

1 回答 1

1

您可以使用气流元数据数据库中的dag,dag_run和task_instsnce表。这很简单..

于 2021-08-26T18:23:32.743 回答