Ajouter une approbation humaine
En travaillant sur un workflow, votre responsable mentionne des problèmes avec les données envoyées à la base analytique de l’équipe commerciale. Ils veulent s’assurer que les données de ventes sont correctes avant de les publier dans un entrepôt de données. Vous réalisez qu’une étape d’approbation HITL est une bonne option pour effectuer 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.
Cet exercice fait partie du cours
Introduction à Apache Airflow en Python
Instructions
- Importez la bibliothèque appropriée pour créer une tâche Approuver / Rejeter.
- Créez la tâche d’approbation
approve_gate. - Définissez le titre de la demande d’approbation qui apparaîtra à l’examinateur dans l’interface Airflow.
Exercice interactif pratique
Essayez cet exercice en complétant cet exemple de code.
# 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()