ImportError:无法导入DAG气流

Question

我有简单的代码,我试图从气流导入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

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

当您命名Python脚本时airflow.py,该语句from airflow import DAG最终会尝试DAG从脚本本身导入,而不是从airflow包中导入.

本课程绝不会将您的Python脚本称为与已安装的内置模块或第三方pacakges相同.