airflow:how do 我用pymysql和mysql钩子？

svujldwt 于 2021-06-21 发布在 Mysql

关注(0)|答案(1)|浏览(469)

我尝试在apache中使用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` 手动而不是用钩子？
我使用的是python3.6
谢谢

mysql python python-3.x pymysql airflow

来源：https://stackoverflow.com/questions/52336365/airflowhow-do-i-use-pymysql-with-mysql-hook

1条答案

按热度按时间

jgwigjjp1#

为了让mysql钩子在气流中工作，您需要安装mysql额外包。如果已使用pip安装气流，则将执行以下命令：

pip install apache-airflow[mysql]

这将安装mysqlclient包，这里需要这个包。

赞(0）回复(0）举报 2021-06-21

我来回答

airflow:how do 我用pymysql和mysql钩子？

1条答案

相关问题

热门标签

最新问答