导入airflow.DAG和airflow.models.DAG的区别

Question

from airflow import DAG（在文档中的教程中使用）和from airflow.models import DAG（在示例 DAG 中使用）之间有什么区别吗？

我是 Airflow 的新手，不确定它们是否应该以不同的方式使用。

Answer 1

有什么区别吗？

不

查看源代码，以下行为应该相同

• from airflow.models.dag import DAG：这是模块的完全限定导入dag.py

• from airflow.models import DAGDAG：这与已导入包中的效果相同__init__.pymodels

• from airflow import DAG：这也有效，因为DAG可以在__init__.pyairflow