Hello,

I’m new to flux language and have a maybe naive question:

I’m using InfluxDB to monitor energy consumptions.

To do so a number of energy counters are installed, one for total consumption (Imp: imported energy, Exp for generated Energy, solar: for PV-power).

The energy counter show values rising with time, to calculate consumption you need to calculate difference of e.g. 15min intervals.

To be able to calculate Energy balance correctly, generated energy has a negative sign, consumed energy a positive

Data is stored in one measurement “Energy”, discriminated by the tag “sens”.

I now want to calculate one missing value, equation like: “E(Exp)+E(Imp)-E(solar)”

If I understand fluxQL correctly, the required math (negative Esolar) is not possible so I turned to flux.

I figured out most of the steps:

`from(bucket: "iobroker")`

|> range(start: dashboardTime)

|> filter(fn: ® => r._measurement == “Energy”)

|> filter(fn: ® => (r.sens == “Imp”) or (r.sens == “Exp”) or (r.sens == “solar”))

|> map(fn: ® => ({ r with _value:

if r.sens == “solar” then (-1.0)*r._value else r._value

}))

|> window(every: 15m)

|> last()

|> duplicate(column: “_stop”, as: “_time”)

|> group(columns: [“sens”], mode:“by”)

|> difference(nonNegative: false, columns: ["_value"])

|> drop(columns:[“room”,“channel”,“sens”])

At the end of this script table is as expected:

I thought I’m now only two steps away from the desired result:

-Group by the already aggregated timestamps (one row of data per sensor already aligned to the 15min timestamps)

-calculate sum of those values

Tried:

|> group(columns: ["_time"], mode:“by”)

|> sum(column:"_value")

But the server generates an error: “runtime error: invalid memory address or nil pointer dereference on sum()”.

I’m running influxdb on a raspberry Pi 3.

I would be grateful for any recommendation !