Сбой воздушного потока при MySQL - PullRequest
Новая
       26

Сбой воздушного потока при MySQL

0 голосов
/ 27 февраля 2020

В настоящее время я использую воздушный поток 1,10 с Python2 .7 и MySQL 8 (локальный исполнитель). После initdb воздушного потока и запуска веб-сервера, я могу получить доступ к домашней странице. Но всякий раз, когда я переключаю свою группу обеспечения доступности баз данных или нажимаю на группу обеспечения доступности баз данных в пользовательском интерфейсе, веб-сервер завершается с ошибкой ниже. Настройка работала нормально с Sequential Executor и SQLite по умолчанию.

ProgrammingError: (py mysql .err.ProgrammingError) (1064, u "У вас ошибка в синтаксисе SQL; проверьте руководство, соответствующее вашей версии сервера MySQL для правильного синтаксиса, который будет использоваться рядом с '[(\' is_paused \ ', u \' false \ '), (\' dag_id \ ', u \' airflow_rest_producer \ ')] '') 'в строке 1 ")
[SQL: INSERT INTO log (dttm, dag_id, task_id, событие, execute_date, владелец, дополнительно) VALUES (% (dttm) s,% (dag_id) s,% (task_id) s,% (событие) s,% (execute_date) s,% (владелец) s,% (extra) s)]
[параметры: {'task_id': нет, 'extra': "[( 'is_paused', u'false '), (' dag_id ', u'airflow_rest_producer')] ", 'execute_date': нет, 'event': 'paused', 'owner': 'anonymous', 'dttm': datetime .datetime (2020, 2, 27, 5, 29, 56, 376969, tzinfo =), 'dag_id': u'airflow_rest_producer '}]
(фон этой ошибки: http://sqlalche.me/e/f405 )

Я использую библиотеку Py MySQL в качестве клиента.

Любая помощь будет признательна ованные. Спасибо!

1 Ответ

0 голосов
/ 28 февраля 2020

После изоляции всех факторов реальная проблема заключалась в параметре sql_alchemy_conn в airflow.cfg. Я использовал MySql8 и py Mysql -0.9.3 в качестве python клиента.

sql_alchemy_conn: mysql+pymsql://[username]:[password]@localhost:3306/airflow

Правильный параметр, который работал для меня: 

mysql+mysqlconnector://[username]:[password]@localhost:3306/airflow

Надеюсь, это кому-нибудь поможет.

...