Параметры соединения MySQL с воздушным потоком с URI

Я пытаюсь использовать документацию по методу MySqlHook.bulk_load() в моей задаче Airflow, и, если мое понимание правильное, я должен включить "local_infile" и "oose-local-infile", когда создаю соединение с моей базой данных MySQL. для того, чтобы это сработало.

В противном случае это приводит к следующей ошибке: "Используемая команда не разрешена в этой версии MySQL".

Если я создаю свое соединение со страницы "Соединения" в пользовательском интерфейсе веб-сервера и передаю следующие параметры как "дополнительные", метод будет успешным, и группа обеспечения доступности баз данных будет работать, как предполагалось: {"local_infile":"1","oose-local-infile" ":"1"} изображение настроек соединения в интерфейсе веб-сервера Airflow

Тем не менее, я пытаюсь создать соединение с базой данных, передавая его как переменную среды. Для этого требуется, чтобы я передал настройки подключения как URI. см. "Соединения" в документации

то есть: scheme://[user[:[password]]@]target[:port][/schema][?attribute1=value1&attribute2=value2... документы

Я пробовал следующие форматы, но ни один из них не работал успешно для меня:

mysql://user:password@hostname:port/schema?local_infile=1&loose-local-infile=1mysql://user:password@hostname:port/schema?local_infile=1;loose-local-infile=1

Я также пробовал процентное кодирование моих значений следующим образом: mysql://user:password@hostname:port/schema?local_infile%3D1%26loose-local-infile%3D1

Буду признателен за любую помощь, спасибо!

0 ответов

Другие вопросы по тегам