Bölümlenmiş varlıkların aşağı akıştaki bir Dag'i tetiklemesini izlemek
Önceki egzersizdeki yukarı akış sales_pipeline_v3 ve aşağı akış sales_report Dag'leri dağıtıldı ve çalışmaya hazır. Satış hattı her dakika çalışır ve her çalıştırmada bölümlenmiş bir daily_sales olayı yayar; rapor ise yalnızca tarih ile ilgilenir. İşte tam da bunun için StartOfDayMapper var. Şimdi bunların birlikte nasıl çalıştığını izleyelim.
Aşağıdaki adımları sırayla uygula:
- Dags görünümünde, varlık olayı geldiğinde tepki verebilsin diye önce
sales_report'u etkinleştir. - Sonra
sales_pipeline_v3'ü etkinleştir; bu her dakika çalışır ve her çalıştırmada bölümlenmiş birdaily_salesolayı yayar. sales_pipeline_v3'ün tamamlanması için yaklaşık bir dakika bekle — ardındansales_reportvarlık olayından otomatik olarak tetiklenir.sales_report'u aç, Runs sekmesine git, en son çalıştırmayı aç ve çalıştırma detaylarının üst kısmında Mapped Partition key'i bul.
Mapped Partition key'in tarih biçimi nedir?
Bu egzersiz, kursun bir parçasıdır
Airflow ile Veri İş Hatları Oluşturma
Uygulamalı etkileşimli egzersiz
Teoriyi etkileşime dönüştürün, interaktif egzersizlerimizden biriyle
Egzersize başla