Работа с интерфейсами Apache Airflow™

Для работы с Managed Service for Apache Airflow™ можно использовать веб-интерфейс или API Apache Airflow™.

Открыть веб-интерфейс или отправить API-запрос могут только пользователи с ролью не ниже managed-airflow.user. В API проверка роли происходит через IAM-токен, который используется для аутентификации.

Интерфейсы Apache Airflow™ доступны через интернет, поэтому проверка роли нужна для их дополнительной защиты. Даже если у злоумышленника есть ссылка на веб-интерфейс и пароль пользователя admin для аутентификации, злоумышленник не сможет обратиться к интерфейсу, так как у него нет нужной роли.

Работа с веб-интерфейсомРабота с веб-интерфейсом

1. В консоли управления откройте страницу кластера.

2. В поле Веб-сервер нажмите Перейти .

3. В открывшемся веб-интерфейсе веб-сервера Managed Service for Apache Airflow™ введите данные для аутентификации:

   • Логин — admin.
   • Пароль — пароль пользователя admin, который вы указали при создании кластера.

Подробности о работе в веб-интерфейсе читайте в документации Apache Airflow™.

Работа с API Apache Airflow™Работа с API Apache Airflow™

Запросы к API Apache Airflow™ можно выполнять с виртуальных машин (ВМ), расположенных в облачной сети кластера Managed Service for Apache Airflow™.

1. В облачной сети, в которой расположен кластер Managed Service for Apache Airflow™, создайте ВМ на основе Linux.

2. Настройте NAT-шлюз для подключения к ВМ.

3. Получите IAM-токен для субъекта с ролью не ниже managed-airflow.user. Процесс получения токена зависит от типа субъекта:

   • аккаунт на Яндексе;
   • сервисный аккаунт;
   • локальный аккаунт;
   • федеративный аккаунт.

4. Выполните запрос к API, например, с помощью cURL. В параметрах авторизации укажите имя пользователя и пароль.

   Пример запроса:

   curl \
       --request GET \
       'https://c-<идентификатор_кластера>.airflow.yandexcloud.net/api/v1/dags' \
       --user 'admin:<пароль_пользователя_admin>' \
       --header 'Content-Type: application/json' \
       --header 'X-Cloud-Authorization: Bearer <IAM-токен>'
   

   Запрос возвращает список DAG-файлов. Пример ответа в документации API Apache Airflow™.