XCom ile veri aktarma

Bir ETL iş akışını, bilgileri daha kolay takip etmek için bir XCom kullanacak şekilde güncelleme sürecindesin. Bu nedenle Dag'ındaki görevler arasındaki bağımlılıkları güncellemen gerekiyor.

Kullanabileceğin dört görev zaten tanımlı:

extract() - order_data döndürür
transform(order_data) - Özetlenmiş veri döndürür
load(summary_data) - XCom bilgisi döndürmez
send_report() - Bildirimleri yöneten XCom olmayan bir görev

Bu egzersiz, kursun bir parçasıdır

Python ile Apache Airflow’a Giriş

Kursa Göz Atın

Egzersiz talimatları

Zinciri tamamlamak için transform görevini extract() ile load() arasına yerleştir.
Sonucu etl_result adlı bir değişkene ata.
send_report görevini, etl_result değişkeninden sonra çalışacak şekilde ayarla.

Uygulamalı etkileşimli egzersiz

Bu egzersizi bu örnek kodu tamamlayarak deneyin.

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

Kodu Düzenle ve Çalıştır