Görevlerin sırasını tanımla
Bitshift söz dizimini öğrendiğine göre, şimdi görev sıralamasını tanımlama zamanı. Şu anda tanımlı üç görevin var: cleanup, consolidate ve push_data.
airflow.sdk içindeki dag ve task dekoratörleri zaten içe aktarılmış durumda.
Bu egzersiz, kursun bir parçasıdır
Python ile Apache Airflow’a Giriş
Egzersiz talimatları
- Bitshift söz dizimini kullanarak
cleanupgörevininconsolidategörevinden önce çalışacak şekilde yapılandır. consolidategörevini sırada sonraki,push_datagörevini ise en son çalışacak şekilde yapılandır.
Uygulamalı etkileşimli egzersiz
Bu egzersizi bu örnek kodu tamamlayarak deneyin.
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()