Thêm bước phê duyệt của con người
Khi đang xây dựng một workflow, sếp bạn cho biết gần đây có vấn đề với dữ liệu được đăng vào cơ sở dữ liệu phân tích của đội bán hàng. Họ muốn đảm bảo dữ liệu bán hàng ổn trước khi đẩy vào data warehouse. Bạn nhận ra rằng thêm một bước phê duyệt HITL là lựa chọn tốt để có lần kiểm tra cuối trước khi chèn dữ liệu.
Các đối tượng dag, task, và timedelta đã được import sẵn cho bạn.
Bài tập này là một phần của khóa học
Giới thiệu về Apache Airflow bằng Python
Hướng dẫn bài tập
- Import thư viện phù hợp để tạo tác vụ Approve / Reject.
- Tạo tác vụ phê duyệt
approve_gate. - Đặt tiêu đề cho yêu cầu phê duyệt sẽ xuất hiện với người duyệt trong Airflow UI.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
# 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()