# Creating tasks, agreggates - help

**URL:** <https://community.influxdata.com/t/creating-tasks-agreggates-help/26522>\
**Category:** InfluxDB 2\
**Created:** [September 13, 2022, 7:13am UTC](https://community.influxdata.com/t/creating-tasks-agreggates-help/26522 "2022-09-13T07:13:28Z")\
**Posts on this page:** 4\
**Page:** 1

<div class="post-metadata">

**Author:** ![mojInfluxDb](https://sea1.discourse-cdn.com/flex023/user_avatar/community.influxdata.com/mojinfluxdb/32/10977_2.png) [@mojInfluxDb](https://community.influxdata.com/u/mojInfluxDb)\
**Post date:** [September 13, 2022, 7:13am UTC](https://community.influxdata.com/t/creating-tasks-agreggates-help/26522/1 "2022-09-13T07:13:28Z")

</div>

Hi,

this is my first try with influxdb tasks.

So i have my main “mydb”.  
Than i have 3 tasks “aggregates5min”, “aggregatesHourly”, “aggregatesDaily”.  
Aggregates5min was created on mydb.  
AggregatesHourly was created on Aggregates5min.  
AggregatesDailywas created on AggregatesHourly.

I am getting data in all my buckets aggregates but i think they are off. Let me explain on temperature example reading.

If i compare MAX temperature reading between aggregates5min and aggregatesHourly i would expect to have the same MAX temp in some period. But this is not the case. In aggregates5min max temp is 65C in aggregatesHourly is let say 62C. So the problem is probably how i create this aggregates.

Aggregates5min from mydb (This one is ok. Correct data.)

```auto
option task = {name: "aggregates5min", every: 5m}

data =
    from(bucket: "mydb")
        |> range(start: -5m)
        |> filter(fn: (r) => r["_measurement"] == "sensors")
        |> filter(
            fn: (r) =>
                r["device"] == "raspberry-pi-4" or r["device"] == "water-irrigation" or r["device"]
                    ==
                    "weather-station",
        )
        |> filter(
            fn: (r) =>
                r["_field"] == "available_memory" or r["_field"] == "cpu_temperature" or r["_field"] == "waterflow"
                    or
                    r["_field"] == "battery" or r["_field"] == "deviceboot" or r["_field"] == "infrared" or r["_field"]
                    ==
                    "light" or r["_field"] == "lux" or r["_field"] == "moisture" or r["_field"] == "rain" or r["_field"]
                    ==
                    "temperature",
        )
        |> filter(
            fn: (r) =>
                r["sensor"] == "cpu_tmp-1" or r["sensor"] == "cpu_available_memory" or r["sensor"] == "flow-1"
                    or
                    r["sensor"] == "flow-2" or r["sensor"] == "battery-procent" or r["sensor"] == "battery-units"
                    or
                    r["sensor"] == "battery-voltage" or r["sensor"] == "deviceboot-1" or r["sensor"] == "ir-1"
                    or
                    r["sensor"] == "light-1" or r["sensor"] == "lux-1" or r["sensor"] == "moisture-1" or r["sensor"]
                    ==
                    "moisture-2" or r["sensor"] == "rain-1" or r["sensor"] == "reboot-tmp-1" or r["sensor"] == "tmp-1"
                    or
                    r["sensor"] == "tmp-2" or r["sensor"] == "tmp-3",
        )

data
    |> aggregateWindow(every: 5m, fn: mean, createEmpty: false)
    |> set(key: "_field", value: "mean")
    |> yield(name: "mean")
    |> to(bucket: "aggregates5min")

data
    |> aggregateWindow(every: 5m, fn: max, createEmpty: false)
    |> set(key: "_field", value: "max")
    |> yield(name: "max")
    |> to(bucket: "aggregates5min")

data
    |> aggregateWindow(every: 5m, fn: min, createEmpty: false)
    |> set(key: "_field", value: "min")
    |> yield(name: "min")
    |> to(bucket: "aggregates5min")

data
    |> aggregateWindow(every: 5m, fn: sum, createEmpty: false)
    |> set(key: "_field", value: "sum")
    |> yield(name: "sum")
    |> to(bucket: "aggregates5min")

```

AggregatesHourly from Aggregates5min

```auto
option task = {name: "aggregatesHourly", every: 1h}

data =
    from(bucket: "aggregates5min")
        |> range(start: -1h)
        |> filter(fn: (r) => r["_measurement"] == "sensors")
        |> filter(
            fn: (r) =>
                r["device"] == "raspberry-pi-4" or r["device"] == "water-irrigation" or r["device"]
                    ==
                    "weather-station",
        )
        |> filter(fn: (r) => r["_field"] == "mean")
        |> filter(
            fn: (r) =>
                r["sensor"] == "cpu_tmp-1" or r["sensor"] == "cpu_available_memory" or r["sensor"] == "flow-1"
                    or
                    r["sensor"] == "flow-2" or r["sensor"] == "battery-procent" or r["sensor"] == "battery-units"
                    or
                    r["sensor"] == "battery-voltage" or r["sensor"] == "deviceboot-1" or r["sensor"] == "ir-1"
                    or
                    r["sensor"] == "light-1" or r["sensor"] == "lux-1" or r["sensor"] == "moisture-1" or r["sensor"]
                    ==
                    "moisture-2" or r["sensor"] == "rain-1" or r["sensor"] == "reboot-tmp-1" or r["sensor"] == "tmp-1"
                    or
                    r["sensor"] == "tmp-2" or r["sensor"] == "tmp-3",
        )

data
    |> aggregateWindow(every: 1h, fn: mean, createEmpty: false)
    |> set(key: "_field", value: "mean")
    |> yield(name: "mean")
    |> to(bucket: "aggregatesHourly")

data
    |> aggregateWindow(every: 1h, fn: max, createEmpty: false)
    |> set(key: "_field", value: "max")
    |> yield(name: "max")
    |> to(bucket: "aggregatesHourly")

data
    |> aggregateWindow(every: 1h, fn: min, createEmpty: false)
    |> set(key: "_field", value: "min")
    |> yield(name: "min")
    |> to(bucket: "aggregatesHourly")

data
    |> aggregateWindow(every: 1h, fn: sum, createEmpty: false)
    |> set(key: "_field", value: "sum")
    |> yield(name: "sum")
    |> to(bucket: "aggregatesHourly")

```

I have also tried to replace this line:

|\> filter(fn: (r) =\> r[“\_field”] == “mean”)

with this line:

|\> filter(fn: (r) =\> r[“\_field”] == “mean” or r[“\_field”] == “max” or r[“\_field”] == “min” or r[“\_field”] == “sum”)

but than i get values instead of around 60 let say around 300

So what is wrong if anything?

---

<div class="post-metadata">

**Author:** ![mojInfluxDb](https://sea1.discourse-cdn.com/flex023/user_avatar/community.influxdata.com/mojinfluxdb/32/10977_2.png) [@mojInfluxDb](https://community.influxdata.com/u/mojInfluxDb)\
**Post date:** [September 13, 2022, 5:34pm UTC](https://community.influxdata.com/t/creating-tasks-agreggates-help/26522/2 "2022-09-13T17:34:25Z")

</div>

Example for cpu raspberry 4 temperature:

mydb(ok):

agreggates5min(ok):

 ![](https://us1.discourse-cdn.com/flex023/uploads/influxdata/original/2X/8/878189826d3b3daa48cf9ff14920dbdc63bca331.png)  
aggregatesHourly(not ok weird numbers; it should be around 60C):  
 ![](https://us1.discourse-cdn.com/flex023/uploads/influxdata/original/2X/5/5a4b958a44b8e0dc92e51f6f62bdbadc26f3fb3c.png)

---

<div class="post-metadata">

**Author:** ![mojInfluxDb](https://sea1.discourse-cdn.com/flex023/user_avatar/community.influxdata.com/mojinfluxdb/32/10977_2.png) [@mojInfluxDb](https://community.influxdata.com/u/mojInfluxDb)\
**Post date:** [September 16, 2022, 2:43pm UTC](https://community.influxdata.com/t/creating-tasks-agreggates-help/26522/3 "2022-09-16T14:43:25Z")

</div>

I just dont get it … why is see difference?

My main bucket is showing max peak temp at 64.7C

 ![](https://us1.discourse-cdn.com/flex023/uploads/influxdata/original/2X/9/98bac920461d0aa763350261ab981099eb6c0dd1.png)  
And my bucket aggregates5min showing max peak at temp 65.7C  
 ![](https://us1.discourse-cdn.com/flex023/uploads/influxdata/original/2X/7/7292518e42774e0d77a818d71ddac56d98c174db.png)  
Why is the difference? Max value from aggregates5min should be the same (64.7C) as peak value from main bucket? What i am not seeing?

I am using Task fro 5min aggregate:

```auto
option task = {name: "aggregates5min", every: 5m}

data =
    from(bucket: "mydb")
        |> range(start: -5m)
        |> filter(fn: (r) => r["_measurement"] == "sensors")
        |> filter(
            fn: (r) =>
                r["device"] == "raspberry-pi-4" or r["device"] == "water-irrigation" or r["device"]
                    ==
                    "weather-station",
        )
        |> filter(
            fn: (r) =>
                r["_field"] == "available_memory" or r["_field"] == "cpu_temperature" or r["_field"] == "waterflow"
                    or
                    r["_field"] == "battery" or r["_field"] == "deviceboot" or r["_field"] == "infrared" or r["_field"]
                    ==
                    "light" or r["_field"] == "lux" or r["_field"] == "moisture" or r["_field"] == "rain" or r["_field"]
                    ==
                    "temperature",
        )
        |> filter(
            fn: (r) =>
                r["sensor"] == "cpu_tmp-1" or r["sensor"] == "cpu_available_memory" or r["sensor"] == "flow-1"
                    or
                    r["sensor"] == "flow-2" or r["sensor"] == "battery-procent" or r["sensor"] == "battery-units"
                    or
                    r["sensor"] == "battery-voltage" or r["sensor"] == "deviceboot-1" or r["sensor"] == "ir-1"
                    or
                    r["sensor"] == "light-1" or r["sensor"] == "lux-1" or r["sensor"] == "moisture-1" or r["sensor"]
                    ==
                    "moisture-2" or r["sensor"] == "rain-1" or r["sensor"] == "reboot-tmp-1" or r["sensor"] == "tmp-1"
                    or
                    r["sensor"] == "tmp-2" or r["sensor"] == "tmp-3",
        )

data
    |> aggregateWindow(every: 5m, fn: mean, createEmpty: false)
    |> set(key: "_field", value: "mean")
    |> to(bucket: "aggregates5min")
    |> yield(name: "mean")

data
    |> aggregateWindow(every: 5m, fn: max, createEmpty: false)
    |> set(key: "_field", value: "max")
    |> to(bucket: "aggregates5min")
    |> yield(name: "max")
data
    |> aggregateWindow(every: 5m, fn: min, createEmpty: false)
    |> set(key: "_field", value: "min")
    |> to(bucket: "aggregates5min")
    |> yield(name: "min")
data
    |> aggregateWindow(every: 5m, fn: sum, createEmpty: false)
    |> set(key: "_field", value: "sum")
    |> to(bucket: "aggregates5min")
    |> yield(name: "sum")`Preformatted text`

```

---

<div class="post-metadata">

**Author:** ![Anaisdg](https://sea1.discourse-cdn.com/flex023/user_avatar/community.influxdata.com/anaisdg/32/6401_2.png) [@Anaisdg](https://community.influxdata.com/u/Anaisdg)\
**Post date:** [September 21, 2022, 5:59pm UTC](https://community.influxdata.com/t/creating-tasks-agreggates-help/26522/4 "2022-09-21T17:59:15Z")

</div>

Hello @mojInfluxDb,  
Welcome!  
Thanks for giving tasks a try!  
I agree that’s super weird I don’t know what’s happening.

Can you please share some data from aggregates5min like query it and limit to the last hour and share with me in annotatedCSV?

When you run the AggregatesHourly query outside of a task do you also get unexpected values? I.E when you run:

```auto
data =
    from(bucket: "aggregates5min")
        |> range(start: -1h)
        |> filter(fn: (r) => r["_measurement"] == "sensors")
        |> filter(
            fn: (r) =>
                r["device"] == "raspberry-pi-4" or r["device"] == "water-irrigation" or r["device"]
                    ==
                    "weather-station",
        )
        |> filter(fn: (r) => r["_field"] == "mean")
        |> filter(
            fn: (r) =>
                r["sensor"] == "cpu_tmp-1" or r["sensor"] == "cpu_available_memory" or r["sensor"] == "flow-1"
                    or
                    r["sensor"] == "flow-2" or r["sensor"] == "battery-procent" or r["sensor"] == "battery-units"
                    or
                    r["sensor"] == "battery-voltage" or r["sensor"] == "deviceboot-1" or r["sensor"] == "ir-1"
                    or
                    r["sensor"] == "light-1" or r["sensor"] == "lux-1" or r["sensor"] == "moisture-1" or r["sensor"]
                    ==
                    "moisture-2" or r["sensor"] == "rain-1" or r["sensor"] == "reboot-tmp-1" or r["sensor"] == "tmp-1"
                    or
                    r["sensor"] == "tmp-2" or r["sensor"] == "tmp-3",
        )

data
    |> aggregateWindow(every: 1h, fn: mean, createEmpty: false)
    |> set(key: "_field", value: "mean")
    |> yield(name: "mean")

```

?

Also sorry for the delay, the team was onsite last week. Typically we respond much faster.