Aggiungere l'approvazione umana
Mentre lavori su un workflow, il tuo capo ti dice che ci sono stati problemi con i dati inviati al database di analytics del team vendite. Vogliono assicurarsi che i dati di vendita siano a posto prima di pubblicarli in un data warehouse. Ti rendi conto che uno step di approvazione HITL è un’ottima opzione per aggiungere un ultimo controllo prima dell’inserimento dei dati.
Gli oggetti dag, task e timedelta sono già stati importati per te.
Questo esercizio fa parte del corso
Introduzione ad Apache Airflow in Python
Istruzioni dell'esercizio
- Importa la libreria appropriata per creare un task Approve / Reject.
- Crea il task di approvazione
approve_gate. - Imposta il titolo della richiesta di approvazione che apparirà al revisore nella UI di Airflow.
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
# 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()