python - 如何向 Airflow 添加新的 DAG？

Question

我在名为 tutorial_2.py 的文件中定义了一个 DAG(实际上是 airflow 教程中提供的 tutorial.py 的副本，除了 dag_id 更改为 tutorial_2)。

当我查看默认的、未修改的 airflow.cfg(位于 ~/airflow)时，我看到 dags_folder 设置为/home/alex/airflow/dags。

我做 cd/home/alex/airflow; mkdir 目录；裁谈会 dags; cp [...]/tutorial_2.py tutorial_2.py。现在我有一个 dags 文件夹匹配 airflow.cfg 中设置的路径，其中包含我之前创建的 tutorial_2.py 文件。

但是，当我运行 airflow list_dags 时，我只获得与默认教程 DAG 对应的名称。

我想让 tutorial_2 出现在我的 DAG 列表中，以便我可以开始与之交互。 python tutorial_2.py 和 airflow resetdb 都没有导致它出现在列表中。

我该如何补救？

Answer 1

我认为这是因为您还没有导出AIRFLOW_HOME。尝试做:AIRFLOW_HOME="/home/alex/airflow/dags" Airflow 列表_dags。如果那不起作用，则执行两个步骤
导出 AIRFLOW_HOME="/home/alex/airflow/dags"
Airflow 列表_dags
我相信这应该有效。试试看？