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.
To ćwiczenie jest częścią kursu
Wprowadzenie do Apache Airflow w Pythonie
Instrukcje do ćwiczenia
- Zaimportuj obiekt notyfikatora SMTP.
- Dodaj atrybut callbacku sukcesu do DAG-a.
- Wyślij powiadomienie na adres [email protected].
- Dodaj temat wiadomości.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
# Import the notifier
from airflow.providers.smtp.notifications.smtp import ____
# Add a success callback notifier
@dag(dag_id='sales_etl_dag',
on_failure_callback=alert_on_failure,
____=SmtpNotifier(
to="____",
from_email="[email protected]",
____="sales_etl_dag run succeeded!"
))
def sales_etl_dag():
get_sales_data() >> process_sales_data()
sales_etl_dag()