Přidání lidského schválení
Při práci na workflow ti nadřízený zmíní, že nastaly problémy s daty publikovanými do analytické databáze obchodního týmu. Chce mít jistotu, že prodejní data jsou v pořádku, než se odešlou do datového skladu. Uvědomíš si, že HITL krok schválení je dobrou volbou, jak přidat poslední kontrolu před vložením dat.
Objekty dag, task a timedelta jsou pro tebe už naimportované.
Toto cvičení je součástí kurzu
Úvod do Apache Airflow v Pythonu
Pokyny k cvičení
- Importuj příslušnou knihovnu pro vytvoření úlohy Schválit / Zamítnout.
- Vytvoř schvalovací úlohu
approve_gate. - Nastav název žádosti o schválení, který se recenzentovi zobrazí v Airflow UI.
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
# 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()