Bir geri çağırma (callback) fonksiyonu uygulama
Ekibinin oluşturduğu Dag'lere hata geri çağırmaları eklemekle yeni görevlendirildin. Başlamak için, sales_etl_dag başarısız olduğunda denetim günlüğüne (audit log) bir mesaj yazan basit bir hata geri çağırması eklemek istiyorsun.
dag ve task nesneleri zaten içe aktarıldı ve get_sales_data ile process_sales_data görevleri oluşturuldu.
Bu egzersiz, kursun bir parçasıdır
Python ile Apache Airflow’a Giriş
Egzersiz talimatları
alert_on_failureadlı bir geri çağırma (callback) fonksiyonu oluştur.- Fonksiyonu, Airflow'un ona ileteceği herhangi bir nesneyi kabul edecek şekilde tanımla.
alert_on_failurefonksiyonunu kullanarak bir hata geri çağırması belirt.
Uygulamalı etkileşimli egzersiz
Bu egzersizi bu örnek kodu tamamlayarak deneyin.
# Create the callback function
def ____(____):
dag_id = context["dag"].dag_id
task_id = context["task_instance"].task_id
print(f"Task {task_id} in Dag {dag_id} has failed.")
# Specify the Dag with a failure callback
@dag(dag_id='sales_etl_dag',
____=alert_on_failure
)
def sales_etl_dag():
get_sales_data() >> process_sales_data()
sales_etl_dag()