แปลง Dag แบบคลาสสิกให้เป็น TaskFlow
ทีมของคุณตัดสินใจนำ TaskFlow API มาใช้กับ pipeline ใหม่ทุกตัว ผู้จัดการจึงขอให้คุณเขียน ETL pipeline เดิมใหม่ ซึ่งเวอร์ชันเดิมใช้ PythonOperator และเชื่อมต่อด้วย >> แบบแมนวล
ดูโค้ดเวอร์ชันคลาสสิกได้ที่ dags/classic_etl.py เพื่อใช้เป็นข้อมูลอ้างอิง ส่วนโครงสร้าง TaskFlow เตรียมไว้ให้แล้ว รอเพียงคุณเติมให้สมบูรณ์
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
การสร้าง Data Pipeline ด้วย Airflow
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง
เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา
เริ่มแบบฝึกหัด