Basit bir Dag oluşturma
Airflow bileşenlerini bir süre inceledin ve artık kendi iş akışlarını denemek istiyorsun. Başlamak için, varsayılan parametreleri tanımlayıp iş akışın için bir Dag nesnesi oluşturmayı seçtin.
datetime nesnesi senin için içe aktarıldı.
Bu egzersiz, kursun bir parçasıdır
Python ile Apache Airflow’a Giriş
Egzersiz talimatları
- Airflow Dag nesnesini içe aktar; büyük/küçük harfe duyarlı olduğunu unutma.
- Dag dekoratörünü tanımla ve Dag’e
example_etladını ver. - Kod dosyasının sonunda Dag fonksiyonunu çalıştır.
Uygulamalı etkileşimli egzersiz
Bu egzersizi bu örnek kodu tamamlayarak deneyin.
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()