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