如何解决气流操作员导入似乎不起作用
我是气流的新手，需要一些指导... 我正在创建我的第一个使用 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？
如果您使用的是 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
我使用的是版本：1.10.4。我按照您建议的方式更改了代码，现在可以使用了。 感谢帮助！
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。