如何解决无法在 Apache 气流中使用导入和使用 MySqlOperator
我好像不能导入MysqL。
就像尝试使用这个导入
def test_function(x,y,diagnostic:bool=False):
w = x*y
z = []
if diagnostic:
z = [w,w*2]
return (z,w) if diagnostic else w
print(test_function(3,4)) # returns 12
print(test_function(3,4,diagnostic=False)) # returns (12,[12,24])
w,z = test_function(3,diagnostic=True)
print(w) # returns 12
print(z) # returns [12,24]
我收到这个错误
“在‘MysqL_operator.py’中找不到引用‘MysqLOperator’”
解决方法
假设您使用的是 2.0.0 或更高版本，导入将是：
from airflow.providers.mysql.operators.mysql import MySqlOperator
记得先安装MySQL providers package：
pip install 'apache-airflow-providers-mysql'
这是文档中的 example。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
