समय अवधि के आधार पर फ़िल्टरिंग और एग्रीगेशन

Polars के साथ Data Transformation

Liam Brannigan

Data Scientist & Polars Contributor

विशिष्ट कीमतें ढूँढना

टाइम सीरीज़ डेटा की तालिका

विशिष्ट कीमतें ढूँढना

1 पंक्ति हाइलाइट वाली टाइम सीरीज़ तालिका

विशिष्ट कीमतें ढूँढना

3 पंक्तियाँ हाइलाइट वाली टाइम सीरीज़ तालिका

pl.datetime के साथ फ़िल्टरिंग

prices.filter(

)

कार्य: 5 जुलाई को दोपहर 12 बजे की कीमतें खोजें

pl.datetime के साथ फ़िल्टरिंग

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

pl.datetime के साथ फ़िल्टरिंग

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

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 |

pl.date के साथ तारीख से फ़िल्टरिंग

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

pl.date के साथ तारीख से फ़िल्टरिंग

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

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   |

Datetime रेंज को फ़िल्टर करना

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


    )
)

Datetime रेंज को फ़िल्टर करना

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

Datetime रेंज को फ़िल्टर करना

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 |

समय अवधि के हिसाब से एग्रीगेशन

समय विंडो में एग्रीगेट करने हेतु पंक्तियाँ

.group_by_dynamic() से डेटा एग्रीगेट करें

समय अवधि के हिसाब से एग्रीगेशन

prices.sort("time")

समय अवधि के हिसाब से एग्रीगेशन

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

समय अवधि के हिसाब से एग्रीगेशन

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

6-घंटे की विंडो से एग्रीगेशन

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

)

6-घंटे की विंडो से एग्रीगेशन

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

6-घंटे की विंडो से एग्रीगेशन

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      |

दिन के हिसाब से एग्रीगेशन

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

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

)

दिन के हिसाब से एग्रीगेशन

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     |

विंडो आकार नियंत्रित करना

every - नई विंडो कितनी बार शुरू होती है
period - हर विंडो की अवधि
डिफ़ॉल्ट रूप से, period = every

विंडो आकार नियंत्रित करना

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

विंडो आकार नियंत्रित करना

नॉन-ओवरलैपिंग 2-घंटे की विंडो

विंडो आकार नियंत्रित करना

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

विंडो आकार नियंत्रित करना

10 से शुरू होती पहली ओवरलैपिंग विंडो

विंडो आकार नियंत्रित करना

11 से शुरू होती दूसरी ओवरलैपिंग विंडो

अഭ्यास करते हैं!

Polars के साथ Data Transformation