Hi, I’ve made my first query with Flux to extract data that comes from Home Assistant, like so: from(bucket: "homeassistant") |> range(start: 2022-08-10T00:00:00Z) |> filter(fn: (r) => r["entity_id"] == "previous_car_charge_distance") |> filter(fn: (r) => r["_field"] == "value") |> drop(col…

OK, I think this will work… from(bucket: "homeassistant") |> range(start: 2022-08-10T00:00:00Z) |> filter(fn: (r) => r["entity_id"] == "previous_car_charge_distance") |> filter(fn: (r) => r["_field"] == "value") |> drop(columns: ["_measurement", "_field", "_start", "_stop", "domain", "en…

Welcome @virtualdj Nice job on the query and clear explanation. What result does this give you? from(bucket: "homeassistant") |> range(start: 2022-08-10T00:00:00Z) |> filter(fn: (r) => r["entity_id"] == "previous_car_charge_distance") |> filter(fn: (r) => r["_field"] == "value") |> drop(…

Thanks. Your query gives: table _value _time 0 0 2022-08-13T14:15:15.366Z 0 104 2022-08-14T10:01:26.947Z 0 3 2022-08-15T03:52:06.659Z 0 0 2022-08-20T08:21:56.017Z 0 48 2022-09-08T03:29:43.150Z 0 9 2022-09-11T05:25:16.556Z 0 0 2022-09-19T16:10:27.721Z So it …

Let’s try this (I did not check the syntax of the map() function, so an error may pop up). You should see a new column called ChangeInKilometers as well as the original column. from(bucket: "homeassistant") |> range(start: 2022-08-10T00:00:00Z) |> filter(fn: (r) => r["entity_id"] == "previous_…

It complains of an error on the line: |> map(fn: (r) => ({r with ChangeInKilometers: (difference(v: r._value))})) The error is: error @7:65-7:73: found unexpected argument v error @7:51-7:74: missing required argument tables

Yep, sorry about that. Still learning all this Flux stuff myself. Try this: from(bucket: "homeassistant") |> range(start: 2022-08-10T00:00:00Z) |> filter(fn: (r) => r["entity_id"] == "previous_car_charge_distance") |> filter(fn: (r) => r["_field"] == "value") |> drop(columns: ["_measureme…

I’m away from my home (and Influxdb instance) now, so you should settle for a picture as Influxdb is not very mobile-friendly. However it doesn’t seem the query gives the correct results… It skips so much data? [Results]

[image] grant1: |> filter(fn: (r) => r["Difference"] > 0) The above is what is causing the some results to get filtered out. Delete it and then run again and see how the data looks, then we’ll go from there…

Yes! You’ve done it! [Results] So basically I had to duplicate the column and apply difference only to that column and then filter it out. Clear! Thank you very much for your help!

So it is not necessary to sort explicitly?

Glad it’s working. I do not think the sort() by time function is required, since your data already appears to be sorted by time. [image] virtualdj: |> sort(columns: ["_time"], desc: false)

How to filter out unchanged values (with difference() == 0) in Flux?

InfluxDB 2

Hukondora February 1, 2023, 12:20pm 13

Hi @grant1,

I think I have a similar issue and hope that you might be able to help with that too, so I will post it here:

Thank you!

Topic		Replies	Views
Compare consecutive values of the same field Fluxlang influxdb , time-series , query , flux	0	569	October 25, 2021
Create column based on previous row value Fluxlang influxdb , query , flux	3	1835	January 24, 2022
How to filter data to show only changes in InfluxDB? InfluxDB 2 influxdb	0	138	November 21, 2024
Difference Between 2 values in a query? InfluxDB 2 query	11	4279	January 5, 2023
Filter out rows based on the row directly before and after that InfluxDB 2 influxdb , query , flux	4	798	February 2, 2023

How to filter out unchanged values (with difference() == 0) in Flux?

Related topics