Ajouter une approbation humaine
Pendant que vous travaillez sur un enchaînement de tâches, votre supérieur mentionne des problèmes liés aux données envoyées à la base de données d'analytique de l'équipe des ventes. On veut s'assurer que les données de ventes sont correctes avant de les verser dans un entrepôt de données. Vous réalisez qu'un point de contrôle HITL (approbation humaine) est une bonne option pour ajouter une dernière vérification avant l'insertion des données.
Les objets dag, task et timedelta ont déjà été importés pour vous.
Cette activité fait partie du cours
Introduction à Apache Airflow en Python
Instructions de l’exercice
- Importez la bibliothèque appropriée pour créer une tâche Approve / Reject.
- Créez la tâche d'approbation
approve_gate. - Définissez le titre de la demande d'approbation qui apparaîtra à la personne réviseuse dans l'interface Airflow.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
# Import ApprovalOperator
from airflow.providers.standard.operators.____ import ____
@dag(start_date=datetime(2026,4,15))
def data_warehouse_dag():
# Create the approve_gate approval task
approve_gate = ____(
task_id="approve_sales_data",
# Set the title for the approval request shown to the reviewer
____="Sales data processing - Approval Required",
body=(
"Please review the sales data produced by the *pull_raw_data* task."
"Approve to push leads to the data warehouse, or Reject to halt the run."
),
)
pull_raw_data() >> approve_gate >> push_to_warehouse()
data_warehouse_dag()