ImportError: 无法导入DAG airflow。

Question

我有一段简单的代码，想要从airflow中导入DAG。

from airflow import DAG
from airflow.operators import BashOperator,S3KeySensor
from datetime import datetime, timedelta
import psycopg2
from datetime import date, timedelta

yesterday = date.today() - timedelta(1)
yesterdayDate = yesterday.strftime('%Y-%m-%d')

但是，我遇到了导入错误。

Traceback (most recent call last):
  File "airflow.py", line 9, in <module>
    from airflow import DAG
  File "/home/ubuntu/airflow/dags/airflow.py", line 9, in <module>
    from airflow import DAG
ImportError: cannot import name DAG

已安装的apache-airflow版本为1.9.0

我不知道哪里出了问题

- Vivek Mehendiratta

Answer 1

这类似于Python 3.5中的包导入失败

当你将Python脚本命名为airflow.py时，语句from airflow import DAG会尝试从脚本本身而不是airflow包中导入DAG。

教训是永远不要将*.py文件与已安装的内置模块或第三方包命名相同。

- Erik Cederstrand