Airflow

Для запуска проектов через Airflow сначала необходимо создать подключение к API.

Создание подключения к DVT Gateway

  1. В веб-интерфейсе Airflow перейдите в Admin → Connections.

  2. Нажмите + Add a new record и заполните поля:

  • Connection Iddvt_api (если в конфигурации DAG не используется другое значение)

  • Host — полный адрес DVT Gateway, например http://host:port

  • Extra — укажите ваш API-ключ в формате JSON:

{ "api_key": "АПИ_КЛЮЧ" }

Мануальный запуск проекта

  1. Перейдите на вкладку DAGs.

  2. В списке найдите run_project_by_api_key.

  3. Нажмите ▶ Trigger DAG.

  4. В открывшемся окне введите project_id и подтвердите запуск.

Автоматический запуск по расписанию (Cron)

Чтобы проекты запускались по расписанию:

  1. В интерфейсе Airflow откройте Admin → Variables.

  2. Добавьте новую переменную:

  • KeyPROJECTS_CONFIG

  • Value — список проектов с расписаниями в формате 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 (обновить список).