เรียกใช้ Streaming Engine
กลับมาที่โปรเจกต์ของทีมห้องสมุดซีแอตเทิลกันอีกครั้ง ประวัติการยืมหนังสือเพิ่มขึ้นเรื่อย ๆ จนคิวรีเริ่มใกล้ถึงขีดจำกัดของหน่วยความจำ วิธีแก้ที่ตรงไปตรงมาที่สุดคือรันคิวรีแบบ lazy บน streaming engine ของ Polars แทนการประมวลผลแบบ in-memory ตามค่าเริ่มต้น
polars โหลดไว้เป็น pl และ LazyFrame ชื่อ monthly_digital ถูกโหลดไว้ล่วงหน้าแล้ว โดยเก็บข้อมูลสรุปจำนวนการยืมสื่อดิจิทัลรายเดือน
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
การปรับขนาดและเพิ่มประสิทธิภาพ Data Pipeline ด้วย Polars
คำแนะนำการฝึกหัด
- รัน
monthly_digitalโดยใช้ streaming engine
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
# Run the query on the streaming engine
result = monthly_digital.collect(____="____")
print(result)