การทดสอบ Unit Test สำหรับฟังก์ชัน Task
หัวใจของการทำ unit test กับโค้ด Airflow คือการแยก business logic ออกจากฟังก์ชัน @task ให้เป็นฟังก์ชัน Python แบบ standalone ที่ทดสอบได้โดยไม่ต้องรัน Airflow ทีมของคุณได้ทำสิ่งนี้กับฟังก์ชัน clean_record ใน dags/data_cleaning.py ซึ่งตัดช่องว่างออกจากชื่อและแปลงอีเมลให้เป็นตัวพิมพ์เล็ก
ตอนนี้ให้เขียน unit test สำหรับฟังก์ชันนี้ให้สมบูรณ์
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
การสร้าง Data Pipeline ด้วย Airflow
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง
เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา
เริ่มแบบฝึกหัด