Yeniden denemeler ekleme
Belirli bir Dag'de, verilen bir kaynaktan veri çıkaran bir görevin sık sık başarısız olduğunu fark ettin. Can sıkıcı bir şekilde, görevi birkaç dakika sonra çalıştırmak sorunu çözüyor gibi görünüyor. Airflow Dag'lerdeki yeniden deneme işlevini öğrendikten sonra, bu göreve yeniden denemeler ekleyerek onu elle yeniden başlatma zahmetinden kurtulmaya karar verdin.
dag, task ve timedelta senin için zaten içe aktarıldı.
Bu egzersiz, kursun bir parçasıdır
Python ile Apache Airflow’a Giriş
Egzersiz talimatları
extract_datagörevini, başarısız olmadan önce 3 kez yeniden denenecek şekilde ayarla.extract_datagörevi için yeniden denemeler arasında 10 dakikalık gecikme ekle.
Uygulamalı etkileşimli egzersiz
Bu egzersizi bu örnek kodu tamamlayarak deneyin.
@dag(schedule="@daily", start_date=datetime(2026, 5, 1))
def etl_pipeline():
# Set retries and retry delay on extract_data
@task(____=3, ____=____(minutes=10))
def extract_data():
print("Extracting data from source...")
@task()
def process_source_data():
print("Now processing data...")
extract_data() >> process_source_data()
etl_pipeline()