Tóm tắt dữ liệu Parquet
Báo cáo đầu tiên dựa trên Parquet là bản tóm tắt thanh toán kỹ thuật số mà nhóm đã xây dựng ở Chương 1, nhưng lần này bắt đầu từ một truy vấn scan_parquet. Hãy xây dựng lại cùng một pipeline ở chế độ lười để nhóm có thể tái sử dụng mẫu này trên toàn bộ kho lưu trữ của họ.
LazyFrame requests đã được tạo sẵn cho bạn từ tệp Parquet.
Bài tập này là một phần của khóa học
Mở rộng và tối ưu hóa pipeline dữ liệu với Polars
Hướng dẫn bài tập
- Lọc
requestsđể chỉ giữ các hàng cóuselà"Digital". - Gom nhóm các hàng đã lọc theo
format. - Kích hoạt thực thi ở cuối cùng của pipeline.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
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)