1. Learn
    2. /
  2. Cursuri
    3. /
  3. Introducere în Apache Airflow în Python
Connected

exercițiu

Implementarea unui SmtpNotifier

Acum că ai creat cu succes un callback de eșec, team lead-ul tău a solicitat ca toate rulările reușite ale DAG-ului să fie trimise prin email la un alias al echipei. După ce ai consultat documentația Airflow, decizi că framework-ul integrat de notificări al Airflow este cea mai bună opțiune.

Obiectele dag și task sunt deja importate, funcția de callback alert_on_failure și task-urile get_sales_data și process_sales_data sunt deja definite pentru tine.

Instrucțiuni

100 XP
  • Importă obiectul notificator SMTP.
  • Adaugă un atribut de callback pentru succes în DAG.
  • Trimite notificarea la [email protected].
  • Include un subiect.