Shrnutí digitálních výpůjček
Reportingový tým potřebuje celkový počet digitálních výpůjček podle typu materiálu pro týdenní přehled. Sestav celý pipeline líně a zavolej .collect() až úplně na konci, aby Polars mohl naplánovat celý dotaz najednou.
Toto cvičení je součástí kurzu
Scaling and Optimizing Data Pipelines with Polars
Pokyny k cvičení
- Vyfiltruj z
libraryřádky, kdeuseje"Digital". - Seskup vyfiltrované řádky podle
format. - Spusť vykonání až úplně na konci pipeline.
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
result = (
library
# Filter to digital checkouts
.filter(pl.col("use") == "____")
# Group by format
.group_by("____")
.agg(pl.col("checkouts").sum().alias("total"))
.sort("total", descending=True)
# Trigger execution at the end
.____()
)
print(result)