Зчитування змінної в Python

Ви зрозуміли, що використання Variables у ваших Dags дасть змогу керувати конфігурацією в різних середовищах, зокрема на серверах розробки та тестування 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()

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