无法在 Apache 气流中使用导入和使用 MySqlOperator

Question

我似乎无法导入 Mysql。 就像尝试使用这个导入 from airflow.operators.mysql_operator import MySqlOperator 我收到这个错误 “在 'mysql_operator.py' 中找不到引用 'MySqlOperator' “

Answer 1

假设您使用的是 2.0.0 或更高版本，导入将是：

from airflow.providers.mysql.operators.mysql import MySqlOperator

记得先安装MySQL providers package：

pip install 'apache-airflow-providers-mysql'

这是来自文档的 example。