Summarizing digital checkouts
The reporting team needs the total number of digital checkouts by material type for this week's summary. Build the entire pipeline lazily and call .collect() only at the very end so Polars can plan the whole query at once.
Latihan ini merupakan bagian dari kursus
Scaling and Optimizing Data Pipelines with Polars
Instruksi latihan
- Filter
libraryto rows whereuseis"Digital". - Group the filtered rows by
format. - Trigger execution at the very end of the pipeline.
Latihan interaktif langsung praktik
Cobalah latihan ini dengan melengkapi kode contoh ini.
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)