Podsumowanie cyfrowych wypożyczeń
Zespół raportujący potrzebuje łącznej liczby cyfrowych wypożyczeń według typu materiału na potrzeby podsumowania tygodnia. Zbuduj cały potok w trybie leniwym i wywołaj .collect() dopiero na samym końcu, żeby Polars mógł zaplanować całe zapytanie naraz.
To ćwiczenie jest częścią kursu
Skalowanie i optymalizacja potoków danych w Polars
Instrukcje do ćwiczenia
- Przefiltruj
library, zostawiając wiersze, w którychusema wartość"Digital". - Zgrupuj przefiltrowane wiersze według
format. - Uruchom wykonanie na samym końcu potoku.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
result = (
library
# Filter to digital checkouts
.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)