添加人工审批

在开发一个工作流时，您的主管提到，销售团队分析数据库中发布的数据曾出现问题。他们希望在将销售数据发布到数据仓库之前，先确认数据没有问题。您意识到，在数据插入前加入一个 HITL（人机协同）审批步骤，是进行最后检查的好办法。

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

编辑并运行代码