การกำหนดพารามิเตอร์ให้ SQL และแยกไปเก็บในไฟล์
การเขียน SQL แบบ inline ยาวขึ้นเรื่อย ๆ และทีมข้อมูลไม่สามารถ review ได้สะดวก ทีมจึงแยก query การรวมข้อมูลออกไปไว้ที่ include/sql/aggregate_sales.sql เพื่อให้อยู่ใกล้กับส่วนอื่น ๆ ของโปรเจกต์ ให้ปรับ query ให้รับรู้วันที่ เพื่อให้แต่ละครั้งที่รันประมวลผลเพียงหนึ่งวัน แล้วชี้ pipeline ไปที่ไฟล์ดังกล่าว โดยใช้ /home/repl/workspace/include/sql เป็น path ของโฟลเดอร์ SQL
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
การสร้าง Data Pipeline ด้วย Airflow
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง
เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา
เริ่มแบบฝึกหัด