Ö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?

Varlık Bölümleri ile bölümlerin farkında olan zamanlama

Create Your Free Account