加入人工核准

你在製作一個工作流程時，老闆提到銷售團隊的分析資料庫最近發生資料上傳問題。他們希望在將銷售資料上傳到資料倉儲之前，能先確認資料是否正常。你判斷在資料寫入前加入一個 HITL（Human-In-The-Loop）核准步驟，是很好的最後把關方式。

dag、task 和 timedelta 物件都已經為你匯入。

本練習屬於課程

Python 中的 Apache Airflow 入門

檢視課程

練習說明

匯入能建立 Approve／Reject 工作的對應函式庫。
建立 approve_gate 核准工作。
設定送審請求在 Airflow UI 中顯示給審核者看的標題。

動手互動練習

試著完成這個範例程式碼，體驗一下這個練習。

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

編輯並執行程式碼