สตรีมข้อมูลค้าปลีกเข้า Delta Lake

ไฟล์ออร์เดอร์ใหม่จะถูกวางในโวลุ่มของทีมที่ Global Retail Analytics ทุกวัน

แทนที่จะโหลดข้อมูลทั้งหมดใหม่ทุกเช้า เราจะสร้าง streaming pipeline ที่คอยดึงไฟล์ CSV ใหม่โดยอัตโนมัติ เขียนข้อมูลลง Delta Lake และกู้คืนสถานะได้อย่างราบรื่นหลังรีสตาร์ตด้วย checkpoint

แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร