1. Nauka
    2. /
  2. Kursy
    3. /
  3. Wprowadzenie do Apache Airflow w Pythonie
Connected

ćwiczenie

Implementacja funkcji zwrotnej

Dostałeś ostatnio zadanie dodania funkcji zwrotnych przy błędach do DAG-ów tworzonych przez twój zespół. Na początek chcesz dodać prostą funkcję zwrotną, która zapisuje komunikat do dziennika audytu, gdy sales_etl_dag zakończy się niepowodzeniem.

Obiekt dag i task są już zaimportowane, a zadania get_sales_data i process_sales_data zostały utworzone.

Instrukcje

100 XP
  • Utwórz funkcję zwrotną o nazwie alert_on_failure.
  • Zdefiniuj tę funkcję tak, aby przyjmowała dowolne obiekty przekazywane przez Airflow.
  • Wskaż funkcję alert_on_failure jako funkcję zwrotną wywoływaną przy błędzie.