Meneruskan data dengan XCom

Anda sedang memperbarui alur kerja ETL untuk menggunakan XCom agar lebih mudah melacak informasi. Karena itu, Anda perlu memperbarui dependensi antar tugas dalam Dag Anda.

Anda sudah memiliki empat tugas yang didefinisikan dan dapat digunakan sebagai berikut:

extract() - Mengembalikan order_data
transform(order_data) - Mengembalikan data yang diringkas
load(summary_data) - Tidak mengembalikan informasi XCom
send_report() - Tugas non-XCom yang menangani notifikasi

Latihan ini adalah bagian dari kursus

Pengantar Apache Airflow dengan Python

Lihat Kursus

Petunjuk latihan

Sisipkan tugas transform di antara extract() dan load() untuk melengkapi rantai.
Tetapkan hasilnya ke variabel bernama etl_result.
Atur send_report agar berjalan setelah variabel etl_result.

Latihan interaktif praktis

Cobalah latihan ini dengan menyelesaikan kode contoh berikut.

@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()

Edit dan Jalankan Kode