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

Exercice

Implémenter une fonction de rappel

On vous a récemment confié d'ajouter des fonctions de rappel en cas d'échec aux Dags créés par votre équipe. Pour commencer, vous souhaitez ajouter une simple fonction de rappel qui écrit un message dans le journal d'audit lorsque le sales_etl_dag échoue.

Les objets dag et task sont déjà importés et les tâches get_sales_data et process_sales_data ont été créées.

Instructions

100 XP
  • Créez une fonction de rappel nommée alert_on_failure.
  • Définissez la fonction pour accepter tout objet qu'Airflow lui transmet.
  • Spécifiez une fonction de rappel en cas d'échec en utilisant la fonction alert_on_failure.