python - 导入错误 : cannot import 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

我不知道我哪里错了

Answer 1

这类似于 Package import failure in Python 3.5

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

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