Parquet verilerini özetleme
İlk Parquet tabanlı rapor, ekip tarafından Bölüm 1'de oluşturulan dijital ödeme özetiydi; ancak şimdi bir scan_parquet sorgusundan başlıyoruz. Aynı lazy veri hattını kur ki ekip bu deseni arşiv genelinde yeniden kullanabilsin.
requests adlı LazyFrame, Parquet dosyasından senin için zaten oluşturuldu.
Bu egzersiz, kursun bir parçasıdır
Polars ile Veri Hatlarını Ölçeklendirme ve Optimize Etme
Egzersiz talimatları
requestsiçindenusedeğeri"Digital"olan satırları filtrele.- Filtrelenen satırları
formatsütununa göre grupla. - Çalıştırmayı veri hattının en sonunda tetikle.
Uygulamalı etkileşimli egzersiz
Bu egzersizi bu örnek kodu tamamlayarak deneyin.
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)