เริ่มต้นใช้งานเริ่มต้นใช้งานได้ฟรี

การ Branch ด้วย HITLBranchOperator

Pipeline สำหรับจัดการข้อร้องเรียนใช้ HITLBranchOperator เพื่อให้มนุษย์เลือกว่าทีมใดจะรับผิดชอบแต่ละ ticket Dag ถูก deploy แล้ว — ลองทริกเกอร์ run เลือก branch และดูว่า Airflow จัดการส่วนที่เหลืออย่างไร

ทำตามขั้นตอนต่อไปนี้:

  1. ใน Dags view เปิดใช้งาน complaint_router แล้วทริกเกอร์ run
  2. เปิด run ล่าสุด และรอจนกว่า task route_complaint จะแสดงสถานะ deferred
  3. ในแท็บ Required Actions เลือก Billing Issue แล้วส่งคำตอบ
  4. สลับไปที่ Graph view และดูสถานะของแต่ละ task

หลังจากเลือก "Billing Issue" แล้ว task ที่ไม่ได้เลือกจะเกิดอะไรขึ้น?

แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร

การสร้าง Data Pipeline ด้วย Airflow

ดูคอร์ส

แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง

เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา

เริ่มแบบฝึกหัด