Gruba göre veriyi dönüştürme

Polars ile Veri Dönüşümü

Liam Brannigan

Data Scientist & Polars Contributor

Neden grup istatistikleriyle karşılaştıralım?

Bir gün boyunca elektrik fiyatlarının zaman serisi grafiği

Fiyatlar normale göre daha yüksek mi, daha düşük mü?

Neden grup istatistikleriyle karşılaştıralım?

Saatlik ortalama fiyatlarla bir gün boyunca elektrik fiyatlarının zaman serisi grafiği

Neden grup istatistikleriyle karşılaştıralım?

Saatlik ortalamalar ve öğlen ucuz fiyatları vurgulayan notla, bir gün boyunca elektrik fiyatlarının zaman serisi grafiği

Neden grup istatistikleriyle karşılaştıralım?

Saatlik ortalamalar ve akşam normal fiyatları vurgulayan notla, bir gün boyunca elektrik fiyatlarının zaman serisi grafiği

Saati çıkarmak

prices.with_columns(
    pl.col("time").dt.hour().alias("hour")
)

| time                | price | solar   | hour |
| ---                 | ---   | ---     | ---  |
| datetime[µs]        | f64   | f64     | i8   |
|---------------------|-------|-------  |------|
| 2025-07-05 10:00:00 | 2.3   | 419.0   | 10   |
| 2025-07-05 11:00:00 | 0.5   | 481.0   | 11   |
| 2025-07-05 12:00:00 | 0.0   | 462.0   | 12   |

.over() ile pencere fonksiyonu

prices.with_columns(
    pl.col("price").mean()
)

.over() ile pencere fonksiyonu

prices.with_columns(
    pl.col("price").mean().over("hour")
)

.over() ile pencere fonksiyonu

prices.with_columns(
    pl.col("price").mean().over("hour").alias("hourly_avg")
)

.over() ile pencere fonksiyonu

prices.with_columns(
    pl.col("price").mean().over("hour").alias("hourly_avg")
)

| time                | price | solar | hour | hourly_avg |
| ---                 | ---   | ---   | ---  | ---        |
| datetime[µs]        | f64   | f64   | i8   | f64        |
|---------------------|-------|-------|------|------------|
| 2025-07-05 10:00:00 | 2.3   | 419.0 | 10   | 49.6       |
| 2025-07-05 11:00:00 | 0.5   | 481.0 | 11   | 44.4       |
| 2025-07-05 12:00:00 | 0.0   | 462.0 | 12   | 39.5       |

Hava durumu kategorisi oluşturma

Güneşli: solar > 400 W/m²
Bulutlu: solar <= 400 W/m²

Hava durumu kategorisi oluşturma

prices.with_columns(
    pl.when(pl.col("solar") > 400)
    .then(pl.lit("sunny"))
    .otherwise(pl.lit("cloudy"))

    .alias("weather")

)

| time                | price | solar | weather |
| ---                 | ---   | ---   | ---     |
| datetime[µs]        | f64   | f64   | str     |
|---------------------|-------|-------|---------|
| 2025-07-05 10:00:00 | 2.3   | 419.0 | sunny   |
| 2025-07-06 10:00:00 | 80.5  | 181.0 | cloudy  |
| 2025-07-07 10:00:00 | 41.5  | 150.0 | cloudy  |

Birden çok sütuna göre gruplama

prices.with_columns(
    pl.col("price").mean()
)

Birden çok sütuna göre gruplama

prices.with_columns(
    pl.col("price").mean().over("hour", "weather")
)

Birden çok sütuna göre gruplama

prices.with_columns(
    pl.col("price").mean().over("hour", "weather").alias("avg_by_hour_weather")
)

Birden çok sütuna göre gruplama

prices.with_columns(
    pl.col("price").mean().over("hour", "weather").alias("avg_by_hour_weather")
)

| time                | price | hour | weather | avg_by_hour_weather |
| ---                 | ---   | ---  | ---     | ---                 |
| datetime[µs]        | f64   | i8   | str     | f64                 |
|---------------------|-------|------|---------|---------------------|
| 2025-07-05 10:00:00 | 2.3   | 10   | sunny   | 34.2                |
| 2025-07-06 10:00:00 | 80.5  | 10   | cloudy  | 58.0                |
| 2025-07-07 10:00:00 | 41.5  | 10   | cloudy  | 58.0                |

Grup ortalamasıyla karşılaştırma

prices.with_columns(
    (pl.col("price")                                     )

)

Grup ortalamasıyla karşılaştırma

prices.with_columns(
    (pl.col("price") - pl.col("price").mean().over("hour"))

)

Grup ortalamasıyla karşılaştırma

prices.with_columns(
    (pl.col("price") - pl.col("price").mean().over("hour"))
    .alias("diff_from_hourly_avg")
)

| time                | price | hour | diff_from_hourly_avg |
| ---                 | ---   | ---  | ---                  |
| datetime[µs]        | f64   | i8   | f64                  |
|---------------------|-------|------|----------------------|
| 2025-07-05 10:00:00 | 2.3   | 10   | -47.3                |
| 2025-07-06 10:00:00 | 25.1  | 10   | -24.5                |
| 2025-07-07 10:00:00 | 2.7   | 10   | -46.9                |

Diğer pencere toplamaları

.over() birçok toplamaya çalışır:

.sum().over() - grup toplamları
.max().over() - grup maksimumları
.count().over() - grup boyutları

Hadi pratik yapalım!

Polars ile Veri Dönüşümü