(07.09.2022, 07:47)admin Wrote: LM is sending data to InfluxDB using HTTP. This thread has working examples: https://forum.logicmachine.net/showthread.php?tid=1531
Another option is MQTT: https://grafana.com/blog/2021/08/12/streaming-real-time-sensor-data-to-grafana-using-mqtt-and-grafana-live/

(14.09.2022, 11:33)admin Wrote: You only need to create a bucket once. It will store your data for a certain amount of time. There are examples of sending data to influx v2 in the topic I've linked to.
The setup part is a bit complicated but you only have to do it once

(15.09.2022, 09:23)admin Wrote: You're sending string data (10:57 and Thu 15-09-2022) which Influx does not understand. String values must be enclosed in quotes.
Try replacing lines 35..42 with this:

Code:

  local body

if type(value) == 'boolean' or type(value) == 'number' then
  body = string.format('%s,name=%s,addr=%s state=%s', table, name, addr, value)
elseif type(value) == 'string' then
  body = string.format('%s,name=%s,addr=%s value=%q', table, name, addr, value)
else
  log('invalid data type', addr, type(value))
  return
end

Currently this script sends values for all objects. There should be some filtering implemented so only the required data is pushed.

(15.09.2022, 12:55)admin Wrote: This example will push only objects that have influx tag attached.

Code:

local http = require('socket.http')
http.TIMEOUT = 5

local objs = {}
local tagobjs = grp.tag('influx')

for _, obj in ipairs(tagobjs) do
  objs[ obj.address ] = {
    name = obj.name:gsub(' ', '\\ '),
    datatype = obj.datatype,
  }
end

function callback(event)
  local addr = event.dst
  local obj = objs[ addr ]

  if obj then
    local value = knxdatatype.decode(event.datahex, obj.datatype)
    sendmetric('rawdata', obj.name, addr, value)
  end
end

function sendmetric(table, name, addr, value)
  local url = 'https://europe-west1-1.gcp.cloud2.influxdata.com/api/v2/write?bucket=XX&org=XXX'
  local body

  if type(value) == 'boolean' or type(value) == 'number' then
    body = string.format('%s,name=%s,addr=%s state=%s', table, name, addr, value)
  elseif type(value) == 'string' then
    body = string.format('%s,name=%s,addr=%s value=%q', table, name, addr, value)
  else
    log('invalid data type', addr, type(value))
    return
  end

  local res, code = http.request({
    url = url,
    method = 'POST',
    body = body,
    headers = {
      Authorization = 'Token XXXXXXXXXXXXXXXXXXX'
    }
  })

  if code ~= 204 then
    log('error sending to influx', res, code, body)
  end
end

local busclient = require('localbus').new()
busclient:sethandler('groupwrite', callback)

while true do
  busclient:loop(1)
end