气流：如何将 PyMySQL 与 MySQL Hook 一起使用？_python

我正在尝试在 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

谢谢

为了让 MySQL 钩子在 Airflow 中工作，你需要安装 MySQL 额外包。 如果您已经使用 pip 安装了 Airflow，那么以下命令将执行：

pip install apache-airflow[mysql]

这将安装包，这是这里需要的包。

气流：如何将 PyMySQL 与 MySQL Hook 一起使用？

问题描述

1楼