Ö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ş bir daily_sales olayı yayar.
sales_pipeline_v3'ün tamamlanması için yaklaşık bir dakika bekle — ardından sales_report varlı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?

Tebrikler!

Create Your Free Account