气流：怎么做我用PyMySQL和MySQL钩子？

Question

我正在尝试在apacheflow中使用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

^{pr2}$

除了手动导入pymysql而不是在钩子中导入之外，我还有什么选择？在

我使用的是python3.6

谢谢

Answer 1

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

pip install apache-airflow[mysql]

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