Adăugarea aprobării umane
În timp ce lucrezi la un workflow, șeful tău menționează că au apărut probleme cu datele publicate în baza de date de analiză a echipei de vânzări. El vrea să se asigure că datele de vânzări arată bine înainte de a fi încărcate într-un data warehouse. Îți dai seama că un pas de aprobare HITL este o opțiune bună pentru a adăuga o verificare finală înainte de inserarea datelor.
Obiectele dag, task și timedelta au fost deja importate pentru tine.
Acest exercițiu face parte din cursul
Introducere în Apache Airflow în Python
Instrucțiuni pentru exercițiu
- Importă biblioteca corespunzătoare pentru a crea o sarcină de tip Aprobare / Respingere.
- Creează sarcina de aprobare
approve_gate. - Setează titlul cererii de aprobare care va fi afișat recenzorului în interfața Airflow.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
# 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()