Чтение переменной в Python

Вы поняли, что использование Variables внутри DAG-ов даёт определённый контроль над конфигурацией в разных окружениях — в том числе на серверах Airflow для разработки и тестирования. Чтобы не менять код DAG-а при каждом переключении между окружениями, вы решаете создать переменную Output_Path, в которой будет храниться путь к директории с файлами на вашем сервере.

Объекты dag и task уже импортированы, а также datetime.

Это упражнение является частью курса

Введение в Apache Airflow на Python

Посмотреть курс

Инструкции к упражнению

Импортируйте библиотеку, необходимую для работы с Variables.
Прочитайте переменную Output_Path из Airflow.
Укажите резервное значение /home, если переменная Output_Path не определена.

Интерактивное практическое упражнение

Попробуйте выполнить это упражнение, дополнив этот пример кода.

# Import the proper library to read Variables
from airflow.____ import ____

@dag(dag_id='process_sales', start_date=datetime(2026, 4, 15))
def process_sales():
    @task()
    def parse_file():
        # Get the output file location, otherwise default to "/home"
        output_path = ____.____("Output_Path", ____="/home")      
        # Logging only currently - processing to be added later
        print(f"File parsed and saved to {output_path}/sales_report.pdf")
    
    parse_file()
process_sales()

Редактировать и запускать код