Kategorische und Enum-Datentypen nutzen

Skalieren und Optimieren von Data-Pipelines mit Polars

Liam Brannigan

Data Scientist & Polars Contributor

Wiederholte Strings codieren

Diagramm einer Tabelle mit einer Eventtitel-Spalte und einer Bereichs-Spalte mit wiederholten Strings.

Skalieren und Optimieren von Data-Pipelines mit Polars

Wiederholte Strings codieren

Diagramm einer Tabelle mit einer Eventtitel-Spalte und einer Bereichs-Spalte, in der Strings durch Integer codiert sind.

Skalieren und Optimieren von Data-Pipelines mit Polars

Ein Datensatz mit wiederholten Labels

events = pl.read_parquet("chicago_events.parquet")
Skalieren und Optimieren von Data-Pipelines mit Polars

Ein Datensatz mit wiederholten Labels

events["area"].value_counts(sort=True).head(5)
shape: (5, 2)
| area          | count |
| ---           | ---   |
| str           | u32   |
|-------------  |-------|
| Loop          | 35982 |
| West Loop     | 27432 |
| Andersonville | 24660 |
| Downtown      | 24320 |
| Pullman       | 21985 |
Skalieren und Optimieren von Data-Pipelines mit Polars

Eine kategorische Spalte erstellen

events_cat = events.with_columns(
    pl.col("area").cast(pl.Categorical)
)
Skalieren und Optimieren von Data-Pipelines mit Polars

Eine kategorische Spalte erstellen

events_cat.select("event_title","area").head()
shape: (5, 2)
| event_title        | area          |
| ---                | ---           |
| str                | cat           |
|--------------------|---------------|
| Folk Festival      | Andersonville |
| Fireworks Night    | Downtown      |
| Greektown Market   | West Side     |
| Rail History Day   | Pullman       |
| Grant Park Concert | Loop          |
Skalieren und Optimieren von Data-Pipelines mit Polars

Eine kategorische Spalte erstellen

events_cat.select("event_title","area").with_columns(
    pl.col("area").to_physical().alias("physical")
).head(3)
shape: (3, 3)
| event_title        | area          | physical |
| ---                | ---           | ---      |
| str                | cat           | u32      |
|--------------------|---------------|----------|
| Folk Festival      | Andersonville | 0        |
| Fireworks Night    | Downtown      | 1        |
| Greektown Market   | West Side     | 2        |
Skalieren und Optimieren von Data-Pipelines mit Polars

Eine kategorische Expression nutzen

events_cat.select("event_title","area",
    pl.col("area").cat.starts_with("West").alias("westside"),
)
Skalieren und Optimieren von Data-Pipelines mit Polars

Eine kategorische Expression nutzen

events_cat.select("event_title","area",
    pl.col("area").cat.starts_with("West").alias("westside"),
).filter(pl.col("westside")).head(2)
shape: (2, 3)
| event_title             | area      | westside |
| ---                     | ---       | ---      |
| str                     | cat       | bool     |
|-------------------------|-----------|----------|
| Greektown Market        | West Side | true     |
| West Loop Chef Showcase | West Loop | true     |
  • Andere String-Operationen → zurück zu String casten
Skalieren und Optimieren von Data-Pipelines mit Polars

Categorical und Enum

Diagramm einer Tabelle mit einer Eventtitel-Spalte und einer Bereichs-Spalte, in der Strings durch Integer codiert sind.

Skalieren und Optimieren von Data-Pipelines mit Polars

Eine Enum-Spalte erstellen

area_enum = pl.Enum([
    "Albany Park",
    "Andersonville",
    ...
    "West Loop",
    "West Side",
    "Wicker Park",
])
Skalieren und Optimieren von Data-Pipelines mit Polars

Eine Enum-Spalte erstellen

events_enum = events.with_columns(
    pl.col("area").cast(area_enum)
)
Skalieren und Optimieren von Data-Pipelines mit Polars

Eine Enum-Spalte erstellen

events_enum.select("event_title", "area").head()
shape: (5, 2)
| event_title                  | area           |
| ---                          | ---            |
| str                          | enum           |
|------------------------------|----------------|
| Greektown Market             | West Side      |
| Folk Festival                | Andersonville  |
| West Loop Chef Showcase      | West Loop      |
| Rail History Day             | Pullman        |
| Fireworks Night              | Downtown       |
Skalieren und Optimieren von Data-Pipelines mit Polars

Den Enum-Datentyp prüfen

events_enum.schema["area"]
Enum(categories=['Albany Park', 'Andersonville', 'Chinatown', 'Downtown', ...])
  • Enum für festen Wortschatz
  • Categorical für variablen Wortschatz
Skalieren und Optimieren von Data-Pipelines mit Polars

Speichereffizienz von Enum

events_enum.select("event_title","area").with_columns(
    pl.col("area").to_physical().alias("physical")
).head(3)
shape: (3, 3)
| event_title        | area          | physical |
| ---                | ---           | ---      |
| str                | enum          | u8       |
|--------------------|---------------|----------|
| Folk Festival      | Andersonville | 1        |
| Fireworks Night    | Downtown      | 3        |
| Greektown Market   | West Side     | 16       |
Skalieren und Optimieren von Data-Pipelines mit Polars

Lass uns üben!

Skalieren und Optimieren von Data-Pipelines mit Polars

Preparing Video For Download...