스트리밍 엔진 사용하기
시애틀 도서관 팀과 다시 함께합니다. 대출 이력 데이터가 점점 늘어나면서 쿼리가 메모리 한계에 다가서고 있습니다. 가장 간단한 해결책은 기본 인메모리(in-memory) 엔진 대신 Polars의 스트리밍 엔진으로 지연 쿼리를 실행하는 것입니다.
polars는 pl로 로드되어 있습니다. LazyFrame monthly_digital은 월별 디지털 대출 수를 집계하며 미리 로드되어 있습니다.
이 연습은 강의의 일부입니다
Polars로 데이터 파이프라인 확장 및 최적화하기
연습 안내
- 스트리밍 엔진을 사용하여
monthly_digital을 실행하세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
# Run the query on the streaming engine
result = monthly_digital.collect(____="____")
print(result)