FTP-соединение с Airflow: укажите каталог по умолчанию - PullRequest
1 голос
/ 05 марта 2019

Как указать каталог по умолчанию в FTP-соединении в Airflow?

Следующие поля доступны для Тип соединения = FTP

Схема
Порт
Дополнительно

Схема не будет работать, если там указано имя каталога.

Я ищу, какая пара ключ / значение требуется в поле Extra, что-то вроде этого (как указано в этом сообщении)

{"путь":" / my / path "}

Я пробовал" path "," directory "и" cwd "

Что работает?

1 Ответ

1 голос
/ 05 марта 2019

Вы можете ввести дополнительную информацию, такую ​​как путь в дополнительное поле.Однако, используя данные или получая к ним доступ, например, FTPSensor требует от вас настройки (т. Е. Подкласса) либо FTPSensor, и / или FTPHook в соответствии с вашими потребностями.

Существует пример использованиядополнительные данные в Hook здесь , довольно просто создать собственный FTPHook / FTPSensor, который распознает ваши дополнительные данные.Например, существующий FTPHook уже использует некоторые из дополнительных данных (установка пассивного режима) - просто расширьте или измените, создав подкласс существующего FTPHook.

Было бы полезно увидеть, каквы используете FTP-соединение внутри DAG.

...