Dodawanie ludzkiego zatwierdzenia
Podczas pracy nad przepływem danych twój szef wspomina, że pojawiły się problemy z danymi publikowanymi w bazie analitycznej zespołu sprzedaży. Chce mieć pewność, że dane wyglądają poprawnie przed ich przesłaniem do hurtowni danych. Dostrzegasz, że dodanie kroku zatwierdzenia HITL to dobry sposób na przeprowadzenie ostatniej weryfikacji przed wstawieniem danych.
Obiekty dag, task oraz timedelta zostały już dla ciebie zaimportowane.
To ćwiczenie jest częścią kursu
Wprowadzenie do Apache Airflow w Pythonie
Instrukcje do ćwiczenia
- Zaimportuj odpowiednią bibliotekę, aby utworzyć zadanie zatwierdzania / odrzucania.
- Utwórz zadanie zatwierdzania
approve_gate. - Ustaw tytuł żądania zatwierdzenia, który będzie widoczny dla recenzenta w interfejsie Airflow UI.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
# 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()