Как воздушный поток может получить конфигурацию JSON из локального каталога? - PullRequest
Новая
       8

Как воздушный поток может получить конфигурацию JSON из локального каталога?

0 голосов
/ 07 ноября 2019

Я запускаю свои пакеты воздушных потоков с помощью конфигурации jsons, представленной в разделе Admin-> Variables, и использую строку dag_config = Variable.get ("conig_version_1", deserialize_json = True). Тот же самый json находится в каталоге / airflow / configs /. Что нужно изменить в dag_file.py, чтобы он выбирал файл из локального каталога?

1 Ответ

0 голосов
/ 11 ноября 2019

Переменные воздушного потока хранятся в базе данных. Если у вас есть файл JSON, который вы хотите импортировать, перейдите к Воздушный поток -> Переменные . Нажмите Выберите Файл и нажмите Импорт.

Вы также можете использовать команду cli: 

airflow variables -i /path/to/var.json
...