Підсумовування даних 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)

Редагувати та запускати код