Использование потокового движка
Вы снова работаете с командой библиотеки Сиэтла. История выдачи книг растёт, и запросы начинают упираться в ограничения памяти. Самое простое решение — выполнять ленивые запросы с помощью потокового движка Polars вместо стандартного режима обработки в памяти.
polars загружен как pl. LazyFrame monthly_digital заранее загружен и содержит суммарное количество цифровых выдач по месяцам.
Это упражнение является частью курса
Масштабирование и оптимизация конвейеров данных с Polars
Инструкции к упражнению
- Запустите
monthly_digital, используя потоковый движок.
Интерактивное практическое упражнение
Попробуйте выполнить это упражнение, дополнив этот пример кода.
# Run the query on the streaming engine
result = monthly_digital.collect(____="____")
print(result)