Lägga till mänskligt godkännande
Under arbetet med ett arbetsflöde nämner din chef att det har uppstått problem med data som publiceras till säljteamets analysdatabas. De vill försäkra sig om att säljdatan ser korrekt ut innan den publiceras till ett datalager. Du inser att ett HITL-godkännandesteg är ett bra sätt att lägga till en sista kontroll innan data infogas.
Objekten dag, task och timedelta har redan importerats åt dig.
Den här övningen är en del av kursen
Introduktion till Apache Airflow i Python
Övningsinstruktioner
- Importera rätt bibliotek för att skapa en Godkänn/Avvisa-uppgift.
- Skapa godkännandeuppgiften
approve_gate. - Ange titeln på godkännandebegäran som ska visas för granskaren i Airflow-gränssnittet.
Interaktiv övning med praktiskt arbete
Testa den här övningen genom att slutföra den här exempelkoden.
# 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()