Додавання ручного затвердження
Під час роботи над робочим процесом ваш керівник згадує, що виникали проблеми з даними, які публікуються в аналітичну базу даних команди продажів. Вони хочуть бути певні, що дані про продажі виглядають коректно перед публікацією у сховищі даних. Ви розумієте, що крок затвердження HITL — хороший спосіб додати фінальну перевірку перед вставлянням даних.
Обʼєкти dag, task і timedelta уже імпортовано для вас.
Ця вправа є частиною курсу
Вступ до Apache Airflow на Python
Інструкції до вправи
- Імпортуйте відповідну бібліотеку, щоб створити завдання Approve / Reject.
- Створіть завдання затвердження
approve_gate. - Задайте заголовок запиту на затвердження, який побачить рецензент в інтерфейсі Airflow.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# 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()