获取python中所有dags的列表

Question

我有一个托管在 Airflow 上的 dags 列表。我想在 AWS lambda 函数中获取 dag 的名称，以便我可以使用这些名称并使用实验性 API 触发 dag。我一直在寻找达格的名字。任何帮助，将不胜感激

Answer 1

from airflow.models import DagBag
dag_ids = DagBag(include_examples=False).dag_ids
for id in dag_ids:
   print(id)

Answer 2

从 Airflow 2.0 开始，airflow list_dags命令现在是：

\n

airflow dags list [-h] [-o table, json, yaml, plain] [-S SUBDIR] [-v]\n

\n

具有以下命名参数：

\n

-o,--output

\n

\n
• 可能的选择：table、json、yaml、plain
\n
• 输出格式。允许的值：json、yaml、plain、table（默认值：\ntable）
\n
• 默认值：\xe2\x80\x9ctable\xe2\x80\x9d
\n

\n

-S,--subdir

\n

\n
• 从中查找 dag 的文件位置或目录。默认为 \xe2\x80\x98[AIRFLOW_HOME]/dags\xe2\x80\x99，其中 [AIRFLOW_HOME] 是您在 \xe2\x80\ 中设置的 \xe2\x80\x98AIRFLOW_HOME\xe2\x80\x99 配置的值x98airflow.cfg\xe2\x80\x99
\n
• 默认值：\xe2\x80\x9c[AIRFLOW_HOME]/dags\xe2\x80\x9d
\n

\n

-v,--verbose

\n

\n
• 使日志输出更详细
\n
• 默认值：假
\n

\n

看：

\n

\n
• Airflow CLI 2.0 中的变化
\n
• 命令行界面和环境变量参考
\n

\n