1. Apprendre
    2. /
  2. Cours
    3. /
  3. Introduction à Apache Airflow en Python
Connected

Exercice

Implémenter un SmtpNotifier

Maintenant que vous avez créé avec succès un rappel en cas d'échec, votre chef d'équipe demande que toutes les exécutions de Dag réussies soient envoyées par courriel à un alias d'équipe. Après avoir consulté la documentation d'Airflow, vous décidez que le cadre intégré de notification d'Airflow est votre meilleure option.

Les objets dag et task sont déjà importés, la fonction de rappel alert_on_failure ainsi que les tâches get_sales_data et process_sales_data sont déjà définies pour vous.

Instructions

100 XP
  • Importez l'objet de notification SMTP.
  • Ajoutez un attribut de rappel de réussite au Dag.
  • Envoyez l'avis à [email protected].
  • Incluez un objet (subject).