1. Uczyć się
    2. /
  2. Courses
    3. /
  3. Wprowadzenie do Apache Airflow w Pythonie
Connected

Exercise

Implementacja SmtpNotifier

Po pomyślnym utworzeniu callbacku do obsługi błędów twój lider zespołu poprosił, aby informacje o udanych uruchomieniach DAG-a były wysyłane e-mailem na adres aliasu zespołu. Po przejrzeniu dokumentacji Airflow dochodzisz do wniosku, że najlepszym rozwiązaniem będzie skorzystanie z wbudowanego mechanizmu powiadomień Airflow.

Obiekty dag i task są już zaimportowane, funkcja callbacku alert_on_failure oraz zadania get_sales_data i process_sales_data są już dla ciebie zdefiniowane.

Instrukcje

100 XP
  • Zaimportuj obiekt notyfikatora SMTP.
  • Dodaj atrybut callbacku sukcesu do DAG-a.
  • Wyślij powiadomienie na adres [email protected].
  • Dodaj temat wiadomości.