问题描述
我正在尝试在 Apache Airflow 中使用 MySQL。
我已经使用PymySQL查询 MySQL 数据库并且没有安装MySQLDb 。
因此我得到了错误：
from airflow.hooks.mysql_hook import MySqlHook
File "/anaconda3/anaconda/lib/python3.6/site-packages/airflow/hooks/mysql_hook.py", line 15, in <module>
import MySQLdb
ModuleNotFoundError: No module named 'MySQLdb'
如果我进入mysql_hook.py类，我已经看到他们正在使用MySQLDB
import MySQLdb
import MySQLdb.cursors
pymysql手动导入pymysql而不是在钩子中，我还有什么选择？
我正在使用 Python 3.6
谢谢
1楼
为了让 MySQL 钩子在 Airflow 中工作，你需要安装 MySQL 额外包。 如果您已经使用 pip 安装了 Airflow，那么以下命令将执行：
pip install apache-airflow[mysql]
这将安装包，这是这里需要的包。