airflow - DAG导入两种方式的区别？

Question

我正在尝试创建动态 dag，但目前似乎失败了。我遇到了以两种不同的方式创建 DAG 对象：

• from airflow.models import DAG https://airflow.apache.org/concepts.html#latest-run-only
• from airflow import DAG https://airflow.apache.org/tutorial.html 这真的让我很困惑，因为在同一个文档中有两种实例化 DAG 对象的方法。

标签： airflow

Answer 1

两者都在导入相同的 DAG 类。只是 python 导入如何工作的一个属性。

当您这样做时，from airflow.models import DAGpython 正在导入模型文件并将变量 DAG 分配给模型文件中定义的 DAG 类。

当您这样做时，from airflow import DAGpython 正在导入在init .py中定义的变量 DAG，实际上就是from airflow.models import DAG.

最小版本是：

模型.py

class DAG():
    pass

初始化.py

from airflow.models import DAG

dags/dag_file.py

# import __init__.py which imports models.py which contains DAG
from airflow import DAG

# or this which just imports models.py which contains DAG
from airflow.models import DAG

话虽如此，如果您的动态 DAG 失败，我怀疑它与此导入有关