Wishing to post smart electricity meter (P1 from EN-IEC 62056-21, Part 21) measurements stored every second in InfluxDB 2.0.4 to the pvoutput.org " Add Status Service" API, I was searching for some Influxdb task creation examples.
Docs has a json example. Over here, a search with keywords “task import http” gives 15 results, though none of the topics provide me help.
Selecting the last measurement data is already challenging. Using “Data Explorer” query:
from(bucket: "dsm")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r["equipment_id_electricity"] == "39")
|> filter(fn: (r) => r["_field"] == "mr_byclient_t1" or r["_field"] == "mr_byclient_t2" or r["_field"] == "mr_toclient_t1" or r["_field"] == "mr_toclient_t2")
|> last(column: "_time")
I can get 4 resulting lines just below the “Filter tables…” input. On the right side the table gives the correct value in column “_value”. With 2 individual queries and some grouping, lasting and summing, I get something similar though not exactly what I wish.
I’d wish to sum the values mr_toclient_t1 of mr_toclient_t2 as “v3”. For example the sum I can get in column _value with this query:
from(bucket: "dsm")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r["equipment_id_electricity"] == "39")
|> filter(fn: (r) => r["_field"] == "mr_toclient_t1" or r["_field"] == "mr_toclient_t2")
|> last(column: "_value")
|> group(columns: ["_time"], mode:"by")
|> sum(column: "_value")
And add mr_byclient_t1 to mr_byclient_t2 as “v1”, using query:
from(bucket: "dsm")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r["equipment_id_electricity"] == "39")
|> filter(fn: (r) => r["_field"] == "mr_byclient_t1" or r["_field"] == "mr_byclient_t2")
|> last(column: "_value")
|> group(columns: ["_time"], mode:"by")
|> sum(column: "_value")
Then I wish to post split the value of column “_time” to a date (f.e. 20210228) and to a time (f.e. 14:08).
I’d wish to post the highest out of any of the 3 phase voltages. I managed to build that query:
from(bucket: "dsm")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r["equipment_id_electricity"] == "39")
|> filter(fn: (r) => r["_field"] == "inst_volt_l1" or r["_field"] == "inst_volt_l2" or r["_field"] == "inst_volt_l3")
|> max(column: "_value")
|> group(columns: ["_start"], mode:"by")
|> max(column: "_value")
Additionally I need variable c1=1.
Those 6 (date, time, v1, v3, v6, c1) variables and its values should be sent to https://pvoutput.org/service/r2/addstatus.jsp using a post or get request.
Any help how to accomplish this task, especially extracting and transforming the individual values to corresponding http key value pairs, will be appreciated.
The http.post request should look something like:
http.post(
url: "https://pvoutput.org/service/r2/addstatus.jsp",
headers: {"X-Pvoutput-Apikey":"321", "X-Pvoutput-SystemId":"123", "content-type":"application/x-www-form-urlencoded"},
data: bytes(v: "d=........&t=..:..&v1=...&v3=...&v6=...&c1=1")
)
In other words: how to build/fill in the http.post ( data: bytes(v: part?
