Передайте пользовательский `endpoint_url` в поток S3TaskHandler - PullRequest
0 голосов
/ 08 апреля 2019

Я устанавливаю журналы воздушного потока для загрузки в корзину S3. Этот вопрос - моя установка.

Хранилище объектов, которое я использую, является сторонним хранилищем объектов, построенным поверх S3, поэтому оно имеет собственный URL-адрес конечной точки для подключения. Нет переменной окружения, которую я могу установить для endpoint_url. Я попытался установить параметр конфигурации endpoint_url в airflow.cfg, но это не удалось.

Я попытался жестко закодировать endpoint_url в файле aws_hook.py, и соединение установилось успешно с записью журналов в корзину s3.

Как я могу передать endpoint_url в качестве аргумента для потока S3TaskHandler

...