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

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:

  1. Dags görünümünde sales_producer ve sales_consumer'ı bul ve anahtar düğmesiyle etkinleştir.
  2. Oynat simgesine tıklayıp Single Run'ı, ardından Trigger'ı seçerek sales_producer'ı tetikle.
  3. Üretici çalışmasının tamamlanmasını bekle (tüm görevler yeşil olmalı).
  4. 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

Kursa Göz Atın

Uygulamalı etkileşimli egzersiz

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

Egzersize başla