การ Denormalize ข้อมูล

โดยทั่วไป ตาราง dimension ควรถูก denormalize ในแบบฝึกหัดนี้ เราจะใช้ PySpark เพื่อโหลดตาราง dimension สองตาราง ได้แก่ products และ categories จากนั้น denormalize ตาราง products โดยแทนที่คอลัมน์ categoryID ด้วยค่า categoryName ที่สอดคล้องกันจากตาราง categories

หมายเหตุ: หากเกิดข้อผิดพลาดเกี่ยวกับ API rate limit มักเป็นเพราะ Fabric task ก่อนหน้ายังทำงานไม่เสร็จ สามารถดู Fabric task ที่กำลังทำงานอยู่ได้จากหน้า Monitor (อยู่ในเมนูแนวตั้งด้านซ้าย) การยกเลิก Fabric task เก่าในหน้า Monitor มักช่วยแก้ปัญหา rate limit ได้