Передавання даних за допомогою XCom

Ви оновлюєте ETL‑робочий процес, щоб використовувати XCom і зручніше відстежувати інформацію. Тому вам потрібно оновити залежності між завданнями у вашому Dag.

У вас уже визначено чотири завдання, які використовуються так:

extract() — повертає order_data
transform(order_data) — повертає підсумовані дані
load(summary_data) — не повертає інформації XCom
send_report() — завдання без XCom, що відповідає за сповіщення

Ця вправа є частиною курсу

Вступ до Apache Airflow на Python

Переглянути курс

Інструкції до вправи

Вставте завдання transform між extract() і load(), щоб завершити ланцюжок.
Присвойте результат змінній etl_result.
Налаштуйте send_report на запуск після змінної etl_result.

Інтерактивна практична вправа

Спробуйте виконати цю вправу, доповнивши цей зразок коду.

@dag(start_date=datetime(2026,4,1))
def etl_example():
    # Chain extract, transform, and load, assigning the result
    ____ = load(____(extract()))
    # Run send_report after the ETL tasks
    etl_result ____ ____()
    
etl_example()

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