Передача параметров в API-интерфейс Airflow Experimental REST при создании трассы запуска - PullRequest
Новая
       5

Передача параметров в API-интерфейс Airflow Experimental REST при создании трассы запуска

0 голосов
/ 01 мая 2018

Похоже, у Airflow есть экспериментальный API REST, который позволяет пользователям создавать прогоны с помощью запроса https POST. Это круто.

Есть ли способ передать параметры через HTTP в прогон создания dag? Судя по официальным документам, найденным здесь , может показаться, что ответ "нет", но я надеюсь, что ошибаюсь.

Ответы [ 2 ]

0 голосов
/ 14 июня 2018

У меня была такая же проблема. значение "conf" должно быть в строке 

curl -X POST \
    http://localhost:8080/api/experimental/dags/<DAG_ID>/dag_runs \
    -H 'Cache-Control: no-cache' \
    -H 'Content-Type: application/json' \
    -d '{"conf":"{\"key\":\"value\"}"}'
0 голосов
/ 01 мая 2018

Судя по исходному коду , может показаться, что параметры могут быть переданы в прогон dag.

Если тело запроса http содержит json, а этот json содержит ключ верхнего уровня conf, то значение ключа conf будет передано в качестве конфигурации trigger_dag. Подробнее о том, как это работает, можно узнать здесь .

...