Сохранение созданного процесса (Dag)

Процесс DAG (Directed Acyclic Graph) в Airflow — это смысловое объединение задач, которые необходимо выполнить в строго определённой последовательности согласно указанному расписанию.

Создание процесса (DAG)

Подробная инструкция по созданию процесса (DAG) описана в категории Оркестрация >> Интеграция с Airflow.

Создать процесс (Dag) Блок предназначен для создания процесса и последующей передачи его в оркестратор. Подробнее...

Сохранение созданного процесса (DAG)

Для сохранения созданного процесса необходимо:

1. Открыть настройки студии;

2. Перейти раздел Окно выполнения;

3. Отключите отображение окна выполнения;

   

4. Сохраните изменения настроек;

5. Откройте раздел Процесс;

   

6. Для генерации Python-скрипта кликните на кнопку Сгенерировать;

   

7. Для запуска процесса сохранения кликните на кнопку Сохранить;

   

8. Выберите тип сохранения Python-скрипт и сохраните процесс;

   

9. Откроется папка с сохраненными процессом (DAG) как Python-скрипт;

   

10. Переименуйте Python-файл, чтобы он совпадал с названием вашего процесса (DAG).

11. Загрузить созданную папку на сервер Airflow в директорию ../dags.

    Отправить процесс в оркестратор Блок отправляет процесс с локального ПК в оркестратор. Подробнее...

    Подробнее о файловой системе сервиса Airflow:

    Файловая система сервиса Airflow Настройка и запуск оркестратора Airflow. Подробнее...