Używanie silnika strumieniowego
Wracasz do pracy z zespołem biblioteki w Seattle. Historia wypożyczeń stale rośnie i zapytania zaczynają ocierać się o limity pamięci. Najprostszym rozwiązaniem jest uruchamianie leniwych zapytań na silniku strumieniowym Polars zamiast domyślnego silnika działającego w pamięci.
polars jest załadowany jako pl. LazyFrame monthly_digital jest wstępnie załadowany i zawiera zsumowane cyfrowe wypożyczenia według miesięcy.
To ćwiczenie jest częścią kursu
Skalowanie i optymalizacja potoków danych w Polars
Instrukcje do ćwiczenia
- Uruchom
monthly_digital, korzystając z silnika strumieniowego.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
# Run the query on the streaming engine
result = monthly_digital.collect(____="____")
print(result)