气流操作员导入似乎不起作用答案

【问题标题】：airflow operator import doesn't seem to work气流操作员导入似乎不起作用
【发布时间】：2021-01-05 17:17:31
【问题描述】：

我是气流新手，需要一些指导... 我正在创建我的第一个使用 subdag 并导入 subdag 运算符的 dag

`from airflow.operators.subdag import SubDagOperator`

但是我不断收到流动错误 “损坏的 DAG：[/usr/local/airflow/dags/POC_Main_DAG.py] 没有名为 'airflow.operators.subdag' 的模块”

我也尝试导入虚拟运算符 ang 得到了同样的错误。另一方面，以下运算符似乎按预期导入。

from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_operator import PythonOperator
from airflow.operators.mysql_operator import MySqlOperator

感谢有关解决此问题的帮助提前致谢！

【问题讨论】：

标签： airflow

【解决方案1】：

您使用的是什么版本的 Airflow？

如果您使用的是 Airflow 1.10.x，请使用以下内容：

from airflow.operators.subdag_operator import SubDagOperator

from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_operator import PythonOperator

在 Airflow >=2.0.0 中，使用以下内容：

from airflow.operators.subdag import SubDagOperator

from airflow.operators.bash import BashOperator
from airflow.operators.python import PythonOperator

【讨论】：

【解决方案2】：

我正在使用版本：1.10.4。我按照您建议的方式更改了代码，现在它可以工作了。感谢您的帮助！

【讨论】：