Dodawanie niestandardowego wyrażenia
Twój zespół regularnie oblicza metryki na słuchacza w różnych raportach. Żeby ten schemat był jeszcze bardziej wielokrotnego użytku, stwórz niestandardowe wyrażenie, które można łączyć łańcuchowo jak każdą wbudowaną metodę Polars.
polars jest załadowany jako pl. Dostępny jest DataFrame spotify z danymi o streamingach albumów.
To ćwiczenie jest częścią kursu
Transformacje danych z Polars
Instrukcje do ćwiczenia
- Zdefiniuj
per_listener()tak, aby dzieliła swoje wejście przez kolumnęmonthly_listeners. - Dołącz funkcję do
pl.Expr, aby umożliwić jej łańcuchowanie. - Zastosuj niestandardową metodę na kolumnie
streams.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
# Define the per_listener function
def per_listener(input):
return ____ / pl.col("____")
# Attach the function to pl.Expr
pl.Expr.____ = ____
# Use the custom method on the streams column
result = spotify.with_columns(
pl.col("____").____().alias("streams_per_listener")
)
print(result.head())