Получить глобальную переменную

Описание

Блок предназначен для работы с переменными оркестратора.

Создание глобальной переменной Глобальные переменные - общее хранилище ключей/значений в оркестраторе Airflow. Подробнее...

Описание параметров

Требуется указать:

Ключ переменной - ключ значения в хранилище ключей/значений оркестратора Airflow.

Тип данных: str (Строка)

Пример: airflow_var

Ключ переменной отображается в веб-интерфейсе Airflow в разделе Администрирование >> Переменные - в поле Ключ окна переменной:

Можно указать одну или несколько переменных в виде массива:

Получить параметры роботом можно с помощью блока Использовать аргумент запуска. Блок получает от оркестратора Airflow параметры в виде массива.

Глобальные переменные в полученном массиве будут располагаться подряд, начиная с первого элемента, в том порядке, в котором они указаны в DAG-файле.

В последнем элементе массива будет словарь с параметрами запуска.

Пример:

[
    'Значение первой глобальной переменной',
    'Значение второй глобальной переменной',
    {
        'Параметр запуска 1': 'Значение параметра запуска',
        'Параметр запуска 2': 'Значение параметра запуска'
    }
]

Пример использования

В данном примере демонстрируется передача и работа с переменными Airflow:

В веб-интерфейсе Airflow в разделе Администрирование >> Переменные создаются переменные с паролями к двум базам данных:
Создается робот, который перебирает полученные параметры с помощью цикла:

Сохранение созданного робота как Python-скрипт Сохранение созданного робота как Python-скрипт. Подробнее...

Сохранение созданного робота как исполняемый файл Сохранение созданного робота как исполняемый файл. Подробнее...
Создается процесс DAG для оркестратора Airflow:

При запуске передается значения глобальных переменных (mssql_password и postgre_password).

Запустить робота Блок предназначен для описания выполняемых задач в процессе (DAG). Подробнее...

Результат

Уведомление пользователя №1 - Переменная Airflow mssql_password (индекс в массиве 0):

Уведомление пользователя №2 - Переменная Airflow postgre_password (индекс в массиве 1):

Уведомление пользователя №3 - Параметры по умолчанию (последний элемент массива):