กำหนดลำดับการทำงานของ Tasks
เมื่อได้เรียนรู้เกี่ยวกับ bitshift syntax แล้ว ถึงเวลากำหนดลำดับการทำงานของ task กัน ตอนนี้มี task ที่กำหนดไว้แล้ว 3 ตัว ได้แก่ cleanup, consolidate และ push_data
ทั้ง dag และ task decorators จาก airflow.sdk ถูก import ไว้ให้แล้ว
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
Apache Airflow เบื้องต้นด้วย Python
คำแนะนำการฝึกหัด
- กำหนดให้ task
cleanupทำงานก่อน taskconsolidateโดยใช้ bitshift syntax - กำหนดให้
consolidateทำงานถัดไป และให้push_dataทำงานเป็นลำดับสุดท้าย
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()