Filtrování a agregace podle časového období

Data Transformation with Polars

Liam Brannigan

Data Scientist & Polars Contributor

Hledání konkrétních cen

Tabulka časových řad

Hledání konkrétních cen

Tabulka časových řad se zvýrazněným řádkem

Hledání konkrétních cen

Tabulka časových řad se třemi zvýrazněnými řádky

Filtrování pomocí pl.datetime

prices.filter(

)

Úkol: najdi ceny v poledne 5. července

Filtrování pomocí pl.datetime

prices.filter(
    pl.col("time") == 
)

Filtrování pomocí pl.datetime

prices.filter(
    pl.col("time") == pl.datetime(                                  )
)

Filtrování pomocí pl.datetime

prices.filter(
    pl.col("time") == pl.datetime(year=2025, month=7, day=5, hour=12)
)

| time                | price | solar |
| ---                 | ---   | ---   |
| datetime[µs]        | f64   | f64   |
|---------------------|-------|-------|
| 2025-07-05 12:00:00 | 0.0   | 462.0 |

Filtrování podle data pomocí pl.date

prices.filter(
    pl.col("time").dt.date() == 
)

Filtrování podle data pomocí pl.date

prices.filter(
    pl.col("time").dt.date() == pl.date(year=2025, month=7, day=5)
)

Filtrování podle data pomocí pl.date

prices.filter(
    pl.col("time").dt.date() == pl.date(year=2025, month=7, day=5)
)

| time                | price | solar |
| ---                 | ---   | ---   |
| datetime[µs]        | f64   | f64   |
|---------------------|-------|-------|
| 2025-07-05 00:00:00 | 34.2  | 0.0   |
| 2025-07-05 01:00:00 | 28.7  | 0.0   |
| ...                 | ...   | ...   |
| 2025-07-05 23:00:00 | 72.3  | 0.0   |

Filtrování časového rozsahu

prices.filter(
    pl.col("time").is_between(


    )
)

Filtrování časového rozsahu

prices.filter(
    pl.col("time").is_between(
        pl.datetime(2025, 7, 5, 8),
        pl.datetime(2025, 7, 5, 18)
    )
)

Filtrování časového rozsahu

prices.filter(
    pl.col("time").is_between(
        pl.datetime(2025, 7, 5, 8),
        pl.datetime(2025, 7, 5, 18)
    )
)

| time                | price | solar |
| ---                 | ---   | ---   |
| datetime[µs]        | f64   | f64   |
|---------------------|-------|-------|
| 2025-07-05 08:00:00 | 1.7   | 180.0 |
| 2025-07-05 09:00:00 | 1.3   | 243.0 |
| ...                 | ...   | ...   |
| 2025-07-05 17:00:00 | 77.8  | 153.0 |
| 2025-07-05 18:00:00 | 87.3  | 119.0 |

Agregace podle časového období

Řádky k agregaci do časových oken

Agreguj data pomocí .group_by_dynamic()

Agregace podle časového období

prices.sort("time")

Agregace podle časového období

prices.sort("time").group_by_dynamic("time",          )

Agregace podle časového období

prices.sort("time").group_by_dynamic("time", every="6h")

Agregace do 6hodinových oken

prices.sort("time").group_by_dynamic("time", every="6h").agg(

)

Agregace do 6hodinových oken

prices.sort("time").group_by_dynamic("time", every="6h").agg(
    pl.col("price").mean().alias("avg_price")
)

Agregace do 6hodinových oken

prices.sort("time").group_by_dynamic("time", every="6h").agg(
    pl.col("price").mean().alias("avg_price")
)

| time                | avg_price |
| ---                 | ---       |
| datetime[µs]        | f64       |
|---------------------|-----------|
| 2025-07-05 00:00:00 | 28.4      |
| 2025-07-05 06:00:00 | 15.2      |
| 2025-07-05 12:00:00 | 42.1      |
| 2025-07-05 18:00:00 | 68.7      |

Agregace po dnech

prices.sort("time").group_by_dynamic("time", every="1d").agg(

    pl.col("price").mean().alias("avg_price"),
    pl.col("solar").mean().alias("avg_solar")

)

Agregace po dnech

prices.sort("time").group_by_dynamic("time", every="1d").agg(
    pl.col("price").mean().alias("avg_price"),
    pl.col("solar").mean().alias("avg_solar")
)

| time                | avg_price | avg_solar |
| ---                 | ---       | ---       |
| datetime[µs]        | f64       | f64       |
|---------------------|-----------|-----------|
| 2025-07-05 00:00:00 | 36.7      | 147.1     |
| 2025-07-06 00:00:00 | 42.1      | 133.8     |

Nastavení velikosti okna

every – jak často začíná nové okno
period – délka každého okna
Ve výchozím nastavení se period rovná every

Nastavení velikosti okna

prices.group_by_dynamic("time", every="2h")

Nastavení velikosti okna

Nepřekrývající se 2hodinová okna

Nastavení velikosti okna

prices.group_by_dynamic("time", every="1h", period="2h")

Nastavení velikosti okna

První překrývající se okno začínající v 10

Nastavení velikosti okna

Druhé překrývající se okno začínající v 11

Pojďme cvičit!

Data Transformation with Polars