无法为气流本地控制器设置 MySQL 后端

Question

我需要并行运行 dags，但不需要显著的缩放，因此 LocalExecutor 可以很好地完成这项工作。我浏览了气流文档，并首先创建了一个MySQL数据库：

CREATE DATABASE airflow_db CHARACTER SET utf8;
CREATE USER <user> IDENTIFIED BY <pass>;
GRANT ALL PRIVILEGES ON airflow_db.* TO <user>;

然后，我在气流.cfg文件中修改以下参数：

executor = LocalExecutor
sql_alchemy_conn = mysql+mysqlconnector://<user>:<pass>@localhost:3306/airflow_db

当我运行airflow db init时，我遇到以下错误消息：

AttributeError:“MySQLConverter”对象没有属性“_dagruntype_to_mysql”

在处理上述异常的过程中，出现了另一个异常:类型错误:Python“dagruntype”无法转换为MySQL类型

请注意，气流中没有其他东西。cfg文件已经更改，使用默认的SequentialExecutor和sqlite可以让一切正常运行。还要注意，我使用的是Airflow 2.2.0版

Answer 1

我找到了自己问题的解决方案。我没有使用mysql连接器，而是使用了pymysql驱动程序：

pip install PyMySQL

气流。cfg参数可以调整如下：

sql_alchemy_conn = mysql+pymysql://<user>:<pass>@localhost:3306/airflow_db

其他一切都可以保持不变。