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

Airflow DAG'leri

Airflow'da bir veri hattı, Yönlendirilmiş Çevrimsiz Grafik yani DAG olarak temsil edilir. Grafikteki düğümler, yürütülen görevleri temsil eder. Düğümler arasındaki yönlendirilmiş bağlantılar ise görevler arasındaki bağımlılıkları gösterir.

Bir veri hattını DAG olarak temsil etmek mantıklıdır; çünkü bazı görevlerin başlamadan önce diğerlerinin bitmesi gerekir. Bunu bir araba fabrikasındaki montaj hattına benzetebilirsin. Görevler üst üste inşa edilir ve her görev, önceki görevlerin tamamlanmasına bağlı olabilir. Kurgusal bir DAG şöyle görünebilir:

Example DAG

Önce şasi birleştirilir, sonra gövde ve lastikler gelir ve en son boyama yapılır. Hadi yukarıdaki örneği kodla yeniden kuralım.

Bu egzersiz, kursun bir parçasıdır

Data Engineering'e Giriş

Kursa Göz Atın

Uygulamalı etkileşimli egzersiz

Bu egzersizi bu örnek kodu tamamlayarak deneyin.

# Create the DAG
@dag(dag_id="car_factory_simulation",
     start_date=datetime(2024, 1, 1),
     schedule="____")
def car_factory_simulation():
    pass

# Run the DAG
car_factory_simulation()
Kodu Düzenle ve Çalıştır