Menschliche Freigabe hinzufügen

Während du an einem Workflow arbeitest, erwähnt deine Chefin/dein Chef, dass es Probleme mit den Daten gab, die in die Analytics-Datenbank des Vertriebsteams gepostet wurden. Bevor die Vertriebsdaten in ein Data Warehouse übernommen werden, soll sichergestellt sein, dass sie in Ordnung sind. Du erkennst, dass ein HITL-Approval-Schritt eine gute Option ist, um vor dem Einfügen der Daten einen letzten Check hinzuzufügen.

Die Objekte dag, task und timedelta wurden bereits für dich importiert.

Diese Übung ist Teil des Kurses

<Kurs>Einführung in Apache Airflow mit Python</Kurs>

Kurs ansehen

Übungsanweisungen

Importiere die passende Bibliothek, um eine Approve-/Reject-Aufgabe zu erstellen.
Erstelle die Approval-Aufgabe approve_gate.
Lege den Titel für die Freigabeanfrage fest, der der prüfenden Person in der Airflow-UI angezeigt wird.

Interaktive praktische Übung

Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.

# 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()

Code bearbeiten und ausführen