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

html5 • • 问答

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

`from airflow.operators.subdag import SubDagOperator`

但是我不断收到流动错误“Broken DAG：[/usr/local/airflow/dags/POC_Main_DAG.py] No module named '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.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

以上是气流操作员导入似乎不起作用的全部内容。
THE END
分享
二维码
< <上一篇
下一篇>>