Resumir datos Parquet
El primer informe basado en Parquet es el resumen de compras digitales que el equipo construyó en el Capítulo 1, pero ahora partiendo de una consulta con scan_parquet. Construye la misma canalización lazy para que el equipo pueda reutilizar este patrón en todo su archivo.
El LazyFrame requests ya está preparado a partir del archivo Parquet.
Este ejercicio forma parte del curso
Escala y optimiza canalizaciones de datos con Polars
Instrucciones del ejercicio
- Filtra
requestsa las filas dondeusesea"Digital". - Agrupa las filas filtradas por
format. - Lanza la ejecución al final de la canalización.
ejercicio interactivo práctico
Prueba este ejercicio completando este código de ejemplo.
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)