(20.01.2021, 07:40)admin Wrote: Have you managed to check if that data is being published to the broker? You can use this application to connect to the broker: http://mqtt-explorer.com/
From the docs it looks like the correct topic for data is servicelocation/<UUID>/realtime where <UUID> must be replaced with the unique ID. Or you can simply subscribe to servicelocation/+/realtime to receive data from all devices.

(20.01.2021, 09:19)admin Wrote: Resident script (sleep time = 0), log(msg) will output the received real-time data decoded from JSON.

Code:

if not broker then
  require('json')
  require('socket')

  broker, port = '127.0.0.1', 1883
  mclient = require('mosquitto').new()

  mclient.ON_CONNECT = function(res, rc, msg)
    log('mqtt connect status', res, rc, msg)

    if res then
      mclient:subscribe('servicelocation/+/realtime')
    else
      mclient:disconnect()
    end
  end

  mclient.ON_MESSAGE = function(mid, topic, payload)
    local msg = json.pdecode(payload)
    if type(msg) == 'table' then
      log(msg)
    end
  end

  mclient.ON_DISCONNECT = function(...)
    log('mqtt disconnect', ...)
    mclientfd = nil
  end

  mclient.ON_ERROR = function(...)
    log('callback error', ...)
  end

  function mconnect()
    local fd

    mclient:connect(broker, port)
    fd = mclient:socket()

    -- fd ref is valid
    if fd then
      mclientfd = fd
    end
  end

  mconnect()

  -- run timer every 5 seconds
  timer = require('timerfd').new(5)
  timerfd = socket.fdmaskset(timer:getfd(), 'r')
end

-- mqtt connected
if mclientfd then
  mclientfdset = socket.fdmaskset(mclientfd, mclient:want_write() and 'rw' or 'r')
  res, timerstat, mclientstat = socket.selectfds(10, timerfd, mclientfdset)
-- mqtt not connected
else
  res, timerstat = socket.selectfds(10, timerfd)
end

if res then
  if mclientfd and mclientstat then
    if socket.fdmaskread(mclientstat) then
      mclient:loop_read()
    end

    if socket.fdmaskwrite(mclientstat) then
      mclient:loop_write()
    end
  end

  if timerstat then
    -- clear armed timer
    timer:read()

    if mclientfd then
      mclient:loop_misc()
    else
      mconnect()
    end
  end
end

Quote:LogicMachine Uitloggen StartpaginaTaal:

Versie: 20211215






CPU/IO: 0.00 0.05 0.07, Geheugen: 16% Schijf: 40%, KNX/TP: OK

* table:
["totalPower"]
  * number: 300
["totalExportEnergy"]
  * number: 500922000
["channelPowers"]
  * table:
  [1]
    * table:
    ["publishIndex"]
      * number: 0
    ["power"]
      * number: -1159
    ["formula"]
      * string: $5500047832/0$
    ["exportEnergy"]
      * number: 237502800
    ["current"]
      * number: 53
    ["apparentPower"]
      * number: 1267
    ["phaseId"]
      * number: 0
    ["cosPhi"]
      * number: -91
    ["importEnergy"]
      * number: 77511600
  [2]
    * table:
    ["publishIndex"]
      * number: 1
    ["power"]
      * number: 2730
    ["formula"]
      * string: $5500047832/1$
    ["exportEnergy"]
      * number: 6998400
    ["current"]
      * number: 227
    ["apparentPower"]
      * number: 5218
    ["phaseId"]
      * number: 1
    ["cosPhi"]
      * number: 52
    ["importEnergy"]
      * number: 590248800
  [3]
    * table:
    ["publishIndex"]
      * number: 2
    ["power"]
      * number: -1414
    ["formula"]
      * string: $5500047832/2$
    ["exportEnergy"]
      * number: 221806800
    ["current"]
      * number: 86
    ["apparentPower"]
      * number: 2097
    ["phaseId"]
      * number: 2
    ["cosPhi"]
      * number: -67
    ["importEnergy"]
      * number: 44172000
  [4]
    * table:
    ["publishIndex"]
      * number: 3
    ["power"]
      * number: 144
    ["formula"]
      * string: $5500047832/3$
    ["exportEnergy"]
      * number: 0
    ["current"]
      * number: 8
    ["apparentPower"]
      * number: 187
    ["phaseId"]
      * number: 1
    ["cosPhi"]
      * number: 76
    ["importEnergy"]
      * number: 72900000
  [5]
    * table:
    ["publishIndex"]
      * number: 4
    ["power"]
      * number: -1169
    ["formula"]
      * string: $5520006145/0$
    ["exportEnergy"]
      * number: 22492800
    ["current"]
      * number: 53
    ["apparentPower"]
      * number: 1282
    ["phaseId"]
      * number: 0
    ["cosPhi"]
      * number: -91
    ["importEnergy"]
      * number: 2746800
  [6]
    * table:
    ["publishIndex"]
      * number: 5
    ["power"]
      * number: 2726
    ["formula"]
      * string: $5520006145/1$
    ["exportEnergy"]
      * number: 6116400
    ["current"]
      * number: 228
    ["apparentPower"]
      * number: 5245
    ["phaseId"]
      * number: 1
    ["cosPhi"]
      * number: 51
    ["importEnergy"]
      * number: 18313200
  [7]
    * table:
    ["publishIndex"]
      * number: 6
    ["power"]
      * number: -1415
    ["formula"]
      * string: $5520006145/2$
    ["exportEnergy"]
      * number: 6004800
    ["current"]
      * number: 83
    ["apparentPower"]
      * number: 2035
    ["phaseId"]
      * number: 2
    ["cosPhi"]
      * number: -69
    ["importEnergy"]
      * number: 1047600
["totalReactivePower"]
  * number: -12977
["monitorStatus"]
  * number: 0
["utcTimeStamp"]
  * number: 1686054839000
["measuredFrequency"]
  * number: 49994600
["voltages"]
  * table:
  [1]
    * table:
    ["voltage"]
      * number: 240
    ["phaseId"]
      * number: 0
  [2]
    * table:
    ["voltage"]
      * number: 230
    ["phaseId"]
      * number: 1
  [3]
    * table:
    ["voltage"]
      * number: 245
    ["phaseId"]
      * number: 2
["totalImportEnergy"]
  * number: 806940000