Airflow
Для запуска проектов через Airflow сначала необходимо создать подключение к API.
Создание подключения к DVT Gateway
В веб-интерфейсе Airflow перейдите в Admin → Connections.
Нажмите + Add a new record и заполните поля:
Connection Id —
dvt_api(если в конфигурации DAG не используется другое значение)Host — полный адрес DVT Gateway, например
http://host:portExtra — укажите ваш API-ключ в формате JSON:
{ "api_key": "АПИ_КЛЮЧ" }
Мануальный запуск проекта
Перейдите на вкладку DAGs.
В списке найдите run_project_by_api_key.
Нажмите ▶ Trigger DAG.
В открывшемся окне введите
project_idи подтвердите запуск.
Автоматический запуск по расписанию (Cron)
Чтобы проекты запускались по расписанию:
В интерфейсе Airflow откройте Admin → Variables.
Добавьте новую переменную:
Key —
PROJECTS_CONFIGValue — список проектов с расписаниями в формате JSON:
[ {"project_id": "PROJECT_1_ID", "project_name": "My project name", "schedule": "0 8 * * *"}, {"project_id": "PROJECT_2_ID", "project_name": "My other project name", "schedule": "0 16 * * *"} ]
После сохранения для каждого проекта из списка автоматически создастся свой DAG
с именем run_project_{PROJECT_ID}, который будет выполняться по заданному расписанию.
Если DAG’и не появились сразу, откройте вкладку DAGs и нажмите кнопку Refresh (обновить список).