汇总 Parquet 数据
第一个基于 Parquet 的报告是团队在第 1 章构建的数字结账汇总，但这次从 scan_parquet 查询开始。请搭建同样的惰性管道，方便团队在整个归档中复用这一模式。
LazyFrame requests 已经从 Parquet 文件为您构建完成。
本练习是课程的一部分
使用 Polars 扩展与优化数据流水线
练习说明
- 将
requests过滤为use等于"Digital"的行。 - 按
format对过滤后的行进行分组。 - 仅在管道的最后一步触发执行。
交互式实操练习
通过完成这段示例代码来试试这个练习。
result = (
requests
# Filter to digital
.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)