如何为气流添加新的DAG？

Question

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

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

我知道。现在我有一个与airflow.cfg中设置的路径匹配的dags文件夹，其中包含我先前创建的tutorial_2.py文件。

但是，当我运行airflow list_dags时，我只得到与默认的tutorial DAGs对应的名称。

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

我该怎么补救？

Answer 1

我认为这是因为您没有导出AIRFLOW_HOME。 试着做： AIRFLOW_HOME="/home/alex/airflow/dags" airflow list_dags。 如果那不起作用，就做两个步骤 export AIRFLOW_HOME="/home/alex/airflow/dags" airflow list_dags 我相信这应该管用。试一试？

Answer 2

问题是目录中可能存在两个airlow配置，因此请检查/root/airlow/dags，如果是，则需要更改airlow.cfg中的dags_文件夹路径

Answer 3

据我所知，AIRFLOW_HOME应该链接到存储airflow.cfg的目录。然后，airflow.cfg可以应用dag目录并将其设置为您在其中输入的值。

重要的一点是：如果没有设置AIRFLOW_HOME，那么airflow.cfg是无用的