Menselijke goedkeuring toevoegen
Terwijl je aan een workflow werkt, vertelt je baas dat er problemen zijn geweest met de data die naar de analysetabel van het salesteam wordt gepost. Ze willen er zeker van zijn dat de salesdata er goed uitziet voordat die naar een datawarehouse gaat. Je beseft dat een HITL-goedkeuringsstap een goede optie is om een laatste controle toe te voegen vóór het invoegen van data.
De objecten dag, task en timedelta zijn al voor je geïmporteerd.
Deze oefening maakt deel uit van de cursus
Introductie tot Apache Airflow in Python
Oefeninstructies
- Importeer de juiste bibliotheek om een Approve/Reject-taak te maken.
- Maak de goedkeuringstaak
approve_gate. - Stel de titel in voor het goedkeuringsverzoek dat in de Airflow-UI aan de beoordelaar verschijnt.
Praktische interactieve oefening
Probeer deze oefening eens door deze voorbeeldcode in te vullen.
# 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()