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对象的方法.

Answer 1

两者都导入相同的DAG类.只是python导入工作方式的一个属性.

当您执行from airflow.models import DAGpython时,导入模型文件并将变量DAG分配给模型文件中定义的DAG类.

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

最小版本是:

models.py

class DAG():
    pass

init .py

from airflow.models import DAG

的DAG/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失败,我怀疑它与此导入有关