Varlık tabanlı zamanlamayı iş başında görmek
Önceki egzersizlerdeki sales_producer ve sales_consumer Dag'leri Airflow UI'a yüklendi. Üretici, satış verilerini yazar ve s3://data-lake/sales/daily.csv varlığını günceller. Tüketici ise bu varlık üzerinden zamanlanır.
Şu adımları izle:
- Dags görünümünde
sales_producervesales_consumer'ı bul ve anahtar düğmesiyle etkinleştir. - Oynat simgesine tıklayıp Single Run'ı, ardından Trigger'ı seçerek
sales_producer'ı tetikle. - Üretici çalışmasının tamamlanmasını bekle (tüm görevler yeşil olmalı).
- Sen herhangi bir şeye tıklamadan
sales_consumer'ın otomatik olarak tetiklenip tetiklenmediğini kontrol et.
sales_producer çalışması tamamlandıktan sonra, sales_consumer'a ne olur?
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