BaşlayınÜcretsiz başlayın

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:

  1. Dags görünümünde, varlık olayı geldiğinde tepki verebilsin diye önce sales_report'u etkinleştir.
  2. Sonra sales_pipeline_v3'ü etkinleştir; bu her dakika çalışır ve her çalıştırmada bölümlenmiş bir daily_sales olayı yayar.
  3. sales_pipeline_v3'ün tamamlanması için yaklaşık bir dakika bekle — ardından sales_report varlık olayından otomatik olarak tetiklenir.
  4. 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

Kursa Göz Atın

Uygulamalı etkileşimli egzersiz

Teoriyi etkileşime dönüştürün, interaktif egzersizlerimizden biriyle

Egzersize başla