Použití streamovacího enginu
Vracíme se k týmu seattleské knihovny. Historie výpůjček stále roste a dotazy se začínají přibližovat paměťovým limitům. Nejjednodušší řešení je spouštět líné dotazy přes streamovací engine Polars místo výchozího in-memory enginu.
polars je načten jako pl. LazyFrame monthly_digital je předem připravený a obsahuje celkové digitální výpůjčky po měsících.
Toto cvičení je součástí kurzu
Scaling and Optimizing Data Pipelines with Polars
Pokyny k cvičení
- Spusť
monthly_digitalpomocí streamovacího enginu.
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
# Run the query on the streaming engine
result = monthly_digital.collect(____="____")
print(result)