1. Učit se
    2. /
  2. Kurzy
    3. /
  3. Úvod do Apache Airflow v Pythonu
Connected

Cvičení

Implementace SmtpNotifier

Po úspěšném vytvoření callback funkce pro selhání tě vedoucí týmu požádal, aby se o každém úspěšném spuštění DAGu odeslal e-mail na týmový alias. Po prostudování dokumentace Airflow se rozhodneš využít vestavěný notifikační framework.

Objekty dag a task jsou už naimportované, callback funkce alert_on_failure a tasky get_sales_data a process_sales_data jsou pro tebe předem definované.

Pokyny

100 XP
  • Importuj SMTP notifikační objekt.
  • Přidej do DAGu atribut pro callback při úspěchu.
  • Nastav odesilatele notifikace na [email protected].
  • Zadej předmět zprávy.