如何查看气流DAG的完整路径？

Question

在气流网络接口中，我可以查看DAG的列表。如果单击其中一个DAG，我可以看到DAG的不同视图或DAG的代码，在details选项卡中，我可以看到DAGs文件的名称，但看不到路径。

我也尝试过airflow list-dags，但这也不能提供我想要的信息。

我可以在web接口中看到一个DAG，但是我找不到它在文件系统中的位置。

是否有方法从气流网络接口或气流CLI中找到DAG的位置？

Answer 1

在ui中的主DAGs列表中，在DAG暂停切换的左侧有一个按钮。它决定：

https://<airflow.blah.com>/admin/dagmodel/edit/?id=<dag_id>

Fileloc将向您显示气流认为您的DAG文件在哪里。然而..。

• 如果将其他本地文件导入DAG文件，则可能会出错。
• 该文件可能不再存在，此信息存储在db中。

Answer 2

我不这么认为，但是您应该从您的dags_folder中搜索您的airflow.cfg，找出dags是在哪里创建的。

此外，假设您有一些登录，airflow-webserver的日志会准确地告诉您正在导入哪些文件/dags。

Answer 3

特别是当您进行开发和更改DAG / delete DAG文件时，这些条目通常会在后端DB中持久化，并在UI中可见。大多数时候，实际上已经没有任何DAG文件了。

我建议清除数据库中的DAG，使用如下内容：

import sys
from airflow.hooks.postgres_hook import PostgresHook

dag_input = sys.argv[1]
hook=PostgresHook( postgres_conn_id= "airflow_db")

for t in ["xcom", "task_instance", "sla_miss", "log", "job", "dag_run", "dag" ]:
  sql="delete from {} where dag_id='{}'".format(t, dag_input)
  hook.run(sql, True)

(基于Airflow: how to delete a DAG?的回答)