Використання потокового рушія
Ви знову працюєте з командою бібліотеки Сіетла. Їхня історія видач зростає, і запити вже підходять до меж пам'яті. Найпростіше рішення — запускати ледачі запити на потоковому рушії Polars замість типового в пам'яті.
polars завантажено як pl. LazyFrame monthly_digital попередньо підготовлено; він підсумовує цифрові видачі за місяцями.
Ця вправа є частиною курсу
Масштабування й оптимізація конвеєрів даних з Polars
Інструкції до вправи
- Запустіть
monthly_digital, використовуючи потоковий рушій.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# Run the query on the streaming engine
result = monthly_digital.collect(____="____")
print(result)