ImportError: невозможно импортировать поток данных DAG - PullRequest
Новая
       29

ImportError: невозможно импортировать поток данных DAG

0 голосов
/ 02 мая 2018

У меня есть простой код, я пытаюсь импортировать 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

Я не знаю, где я иду не так

1 Ответ

0 голосов
/ 02 мая 2018

Это похоже на Ошибка импорта пакета в Python 3.5

Когда вы называете свой скрипт Python airflow.py, оператор from airflow import DAG в итоге пытается импортировать DAG из самого скрипта, а не из пакета airflow.

Урок заключается в том, чтобы никогда не называть ваши скрипты Python такими же, как встроенные модули или сторонние пакеты, которые вы установили.

...