การทดสอบ task ใน Airflow
คุณเพิ่งเริ่มศึกษาการใช้ Airflow ภายในบริษัท และต้องการทดลองรัน task บนแพลตฟอร์ม Airflow จำได้ว่าสามารถใช้คำสั่ง airflow tasks test เพื่อรัน task เฉพาะเจาะจงภายใน workflow ได้
มี Airflow DAG ถูกตั้งค่าไว้ให้แล้ว โดยมี dag_id คือ etl_pipeline, task_id คือ download_file และ start_date คือ 2026-01-08 ส่วนประกอบอื่น ๆ ที่จำเป็นถูกกำหนดไว้ให้ครบแล้ว
ควรพิมพ์คำสั่งใดใน console เพื่อรัน task ที่ต้องการ?
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
Apache Airflow เบื้องต้นด้วย Python
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง
เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา
เริ่มแบบฝึกหัด