Shelly - WiFi IoT-Devices

[Todayslife]

Hi, 

Has anyone collected practical experiences with IoT-Devices from Shelly - particularly controlling them from KNX via LM5?

e.g.: interesting applications are mainly in budget-sensitive environments: 
- Power-measurement with LM3 for visualisation and triggering event based actions 
- Using the Shelly i3 as a wireless-KNX-sensor in a retrofit environment
- Using the Shelly RGBW2 as a KNX to WiFi-RGBW-LED-dimmer in a retrofit environment
... to name a few


Thanks

[admin]

This can be implemented either by using MQTT broker in LM (two-way) or HTTP (remote services to LM, HTTP requests from LM scripts).

[Todayslife]

This can be implemented either by using MQTT broker in LM (two-way) or HTTP (remote services to LM, HTTP requests from LM scripts).

Thanks for the very quick reply :-)

Very well so far, using the MQTT Broker in LM5 sounds indeed promising.
Therefor, one might be really happy getting a more specific answer to the original question; in particular about actual practical experiences - if any exists already - in terms of how to integrate Shelly' IoT-Devices within the LogicMachine's "ecosystem". 
(eg. using the LM5's new MQTT Broker).

Hence, trying to precise above question as follows (and please excuse, if this may sound amateurish):
"Has anyone already made practical experiences with IoT-Devices from Shelly? In particular; successfully controlling Shelly-Devices from the KNX-bus via LM5's MQTT Broker"?


Thanks again

[admin]

I don't think that anybody has made an integration yet but it's very easy to do. On LM side you need to enable broker and create a script to exchange values between MQTT and LM objects. On Shelly device you need to set MQTT broker address and topic.

[Todayslife]

I don't think that anybody has made an integration yet but it's very easy to do. On LM side you need to enable broker and create a script to exchange values between MQTT and LM objects. On Shelly device you need to set MQTT broker address and topic.

Thank you for the - again - quick response. 


Well, just enabling the MQTT-Broker on the LM5 (SW: 20200720) wasn't bringing up much questions as it seemed.
So it appeared as easy on the Shelly-Device to set the MQTT broker's address and topic.

Whereis - for someone being unexperienced and feeling rather uncomfortable writing software - creating a script to exchange values between MQTT and LM objects seems indeed much more troublesome - hence, please excuse, if asking for your help in writing such scripts may try your patience.

[admin]

See this thread for a fully working script with two-way exchange between LM objects and MQTT: https://forum.logicmachine.net/showthrea...6#pid10926
You need to set the broker address to 127.0.0.1 and edit mqtt_to_object/object_to_mqtt tables. Make sure that you don't have the same topic mapped to both tables otherwise you can get a loop.

[mdisilvestro]

Sorry, but I'm not able to use the script.

I changed the broker address with 127.0.0.1 (local borker) and modified the mqtt_to_object/object_to_mqtt tables in order to do a simple ON /OFF of an mqtt object (shelly) as example.

My tables has:
mqtt_to_object = {
['shellies/shellyplug-s-??????/relay/0'] = '0/0/12'
}

where 0/0/12 is the On/Off knx status
and

object_to_mqtt = {
    ['0/0/11'] = 'shellies/shellyplug-s-??????/relay/0/command'
  }


where 0/0/11 is the On/Off knx command

Shelly want on and off command, not 0 or 1. I used custom value to modify that, but doesn't work

Here is my log:
* arg: 1
  * string: mqtt connect status
* arg: 2
  * bool: true
* arg: 3
  * number: 0
* arg: 4
  * string: connection accepted
* arg: 5
  * number: 0
* arg: 6
  * nil


Thank you

[admin]

Modify the script around line 108, change this:

Code:

123

if type(value) == 'boolean' then   value = value and 1 or 0 end

To this:

Code:

123

if type(value) == 'boolean' then   value = value and 'on' or 'off' end

Also make sure that Shelly MQTT address is not 127.0.0.1 but LM IP address.

[mdisilvestro]

Thanks, but something is wrong.

Here is my script:

Code:

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158

if not broker then   broker = '127.0.0.1'   function multiply(mult)     return function(value)       local num = tonumber(value)       if num then         return num * mult       else         return value       end     end   end   -- topic to object map   mqtt_to_object = {     ['shellies/shellyplug-s-?????/relay/0'] = '3/0/2'   }   -- optional topic value conversion function -- mqtt_to_object_conv = { --   ['in/topic1'] = multiply(100),   --  ['in/topic2'] = multiply(0.01), -- }   -- object to topic map   object_to_mqtt = {     ['3/0/3'] = 'shellies/shellyplug-s-??????/relay/0/command'   }   datatypes = {}   grp.sender = 'mq'   require('socket')   for addr, _ in pairs(object_to_mqtt) do     local obj = grp.find(addr)     if obj then       datatypes[ addr ] = obj.datatype     end   end   mclient = require('mosquitto').new()   mclient.ON_CONNECT = function(res, ...)     log('mqtt connect status', res, ...)     if res then       for topic, _ in pairs(mqtt_to_object) do         mclient:subscribe(topic)       end     else       mclient:disconnect()     end   end   mclient.ON_MESSAGE = function(mid, topic, payload)     local addr = mqtt_to_object[ topic ]     if addr then       local fn = mqtt_to_object_conv[ topic ]       if fn then         payload = fn(payload)       end       grp.write(addr, payload)     end   end   mclient.ON_DISCONNECT = function(...)     log('mqtt disconnect', ...)     mclientfd = nil   end   function mconnect()     local fd     mclient:connect(broker)     fd = mclient:socket()     -- fd ref is valid     if fd then       mclientfd = fd     end   end   mconnect()   function publishvalue(event)     -- message from us or client is not connected     if event.sender == 'mq' or not mclientfd then       return     end     local addr = event.dst     local dpt = datatypes[ addr ]     local topic = object_to_mqtt[ addr ]     -- unknown object     if not dpt or not topic then       return     end     local value = busdatatype.decode(event.datahex, dpt)     if value ~= nil then       if type(value) == 'boolean' then         value = value and 'on' or 'off'       end       mclient:publish(topic, tostring(value))     end   end   lbclient = require('localbus').new(1)   lbclient:sethandler('groupwrite', publishvalue)   lbclientfd = socket.fdmaskset(lbclient:getfd(), 'r')   -- 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, lbclientstat, timerstat, mclientstat =       socket.selectfds(10, lbclientfd, timerfd, mclientfdset) -- mqtt not connected else   res, lbclientstat, timerstat =     socket.selectfds(10, lbclientfd, timerfd) end 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 lbclientstat then   lbclient:step() end if timerstat then   -- clear armed timer   timer:read()   if mclientfd then     mclient:loop_misc()   else     mconnect()   end end

LOG1:
* arg: 1
  * string: mqtt connect status
* arg: 2
  * bool: false
* arg: 3
  * number: 5
* arg: 4
  * string: connection refused - not authorized
* arg: 5
  * number: 0
* arg: 6
  * nil

LOG2:
* arg: 1
  * string: mqtt disconnect
* arg: 2
  * bool: false
* arg: 3
  * number: 0
* arg: 4
  * string: unexpected disconnect
* arg: 5
  * nil

logging continusly, every 10 seconds

Shelly use correct LM IP for broker device. The MQTT communication works fine, I tested it whit MQTT.fx software.

Simplifing: I want that an "ON" knx telegram became ad an "ON" request through mqtt, and viceversa.

Thanks

[admin]

Are you able to control your Shelly device using an external MQTT client? You can monitor what LM is writing to these topics and check what's wrong. The last change will publish on/off for binary objects.

[a455115]

Hello,

I also have a problem with the shelly connection and I don't know what I'm doing wrong. Please if anyone can help.

LM Mqtt broker

MQTT explorer

Code:

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160

if not broker then   broker = '127.0.0.1'   function multiply(mult)     return function(value)       local num = tonumber(value)       if num then         return num * mult       else         return value       end     end   end   -- topic to object map   mqtt_to_object = {     ['shellies/shellyplug-s-D9AA39/relay/0'] = '32/1/1',     ['shellies/shellyplug-s-D9AA39/temperature'] = '32/1/2',   } -- optional topic value conversion function mqtt_to_object_conv = {   ['shellies/shellyplug-s-D9AA39/relay/0'] = multiply(1),    ['shellies/shellyplug-s-D9AA39/temperature'] = multiply(1), }   -- object to topic map object_to_mqtt = {    -- ['1/1/1'] = 'out/topic1',    -- ['1/1/2'] = 'out/topic2',   }   datatypes = {}   grp.sender = 'mq'   require('socket')   for addr, _ in pairs(object_to_mqtt) do     local obj = grp.find(addr)     if obj then       datatypes[ addr ] = obj.datatype     end   end   mclient = require('mosquitto').new()   mclient.ON_CONNECT = function(res, ...)     log('mqtt connect status', res, ...)     if res then       for topic, _ in pairs(mqtt_to_object) do         mclient:subscribe(topic)       end     else       mclient:disconnect()     end   end   mclient.ON_MESSAGE = function(mid, topic, payload)     local addr = mqtt_to_object[ topic ]     if addr then       local fn = mqtt_to_object_conv[ topic ]       if fn then         payload = fn(payload)       end       grp.write(addr, payload)     end   end   mclient.ON_DISCONNECT = function(...)     log('mqtt disconnect', ...)     mclientfd = nil   end   function mconnect()     local fd     mclient:connect(broker)     fd = mclient:socket()     -- fd ref is valid     if fd then       mclientfd = fd     end   end   mconnect()   function publishvalue(event)     -- message from us or client is not connected     if event.sender == 'mq' or not mclientfd then       return     end     local addr = event.dst     local dpt = datatypes[ addr ]     local topic = object_to_mqtt[ addr ]     -- unknown object     if not dpt or not topic then       return     end     local value = busdatatype.decode(event.datahex, dpt)     if value ~= nil then       if type(value) == 'boolean' then         value = value and 1 or 0       end       mclient:publish(topic, tostring(value))     end   end   lbclient = require('localbus').new(1)   lbclient:sethandler('groupwrite', publishvalue)   lbclientfd = socket.fdmaskset(lbclient:getfd(), 'r')   -- 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, lbclientstat, timerstat, mclientstat =       socket.selectfds(10, lbclientfd, timerfd, mclientfdset) -- mqtt not connected else   res, lbclientstat, timerstat =     socket.selectfds(10, lbclientfd, timerfd) end 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 lbclientstat then   lbclient:step() end if timerstat then   -- clear armed timer   timer:read()   if mclientfd then     mclient:loop_misc()   else     mconnect()   end end

LM log

LM Objects

[admin]

Add logging to ON_MESSAGE to check that you are getting the data. Also do a full script restart the script via disable/enable.

Code:

1234567891011121314151617

mclient.ON_MESSAGE = function(mid, topic, payload)     local addr = mqtt_to_object[ topic ]     log('message', topic, payload, addr)     if addr then       local fn = mqtt_to_object_conv[ topic ]       if fn then         payload = fn(payload)       end       log('write', addr, payload)       grp.write(addr, payload)     end   end

[a455115]

Add logging to ON_MESSAGE to check that you are getting the data. Also do a full script restart the script via disable/enable.

Code:

1234567891011121314151617

  mclient.ON_MESSAGE = function(mid, topic, payload)     local addr = mqtt_to_object[ topic ]     log('message', topic, payload, addr)     if addr then       local fn = mqtt_to_object_conv[ topic ]       if fn then         payload = fn(payload)       end       log('write', addr, payload)       grp.write(addr, payload)     end   end

nothing different is logged..

Code:

123456789101112

* arg: 1   * string: mqtt connect status * arg: 2   * bool: true * arg: 3   * number: 0 * arg: 4   * string: connection accepted * arg: 5   * number: 0 * arg: 6   * nil

[admin]

The same script works for me when sending messages from MQTT explorer. Do you have "Allow anonymous connection" enabled in MQTT broker configuration on LM? If not then you need to specify the login/password in the script.

Modify the script around line 45 by adding login_set call and restart it via disable/enable:

Code:

12

mclient = require('mosquitto').new() mclient:login_set('test', '123456')

[a455115]

Hello admin!

I did it and my script is already working! I still didn't understand where the problem was. I returned the original settings to LM, I wrote the same script and it already works!
Thanks again for your help and time

[a455115]

I have another problem. The value I take from shelly is string, how do I convert it so I can use it as int or bool? And is there a way to add all the shelly functions to a library and call them only by name and serial number?

[admin]

You can write a custom conversion function and add it to mqtt_to_object_conv table. What kind of string value is it?

[admin]

In case somebody else needs this, here's an example that logs all messages for all topics from the local broker. If anonymous access is disabled then remove the comment (--) from line 23 and set username and password as needed.

Code:

12345678910111213141516171819202122232425262728

broker = '127.0.0.1' mclient = require('mosquitto').new() mclient.ON_CONNECT = function(res, ...)   log('mqtt connect status', res, ...)   if res then     mclient:subscribe('#')   else     mclient:disconnect()   end end mclient.ON_MESSAGE = function(mid, topic, payload)   log('mqtt message', topic, payload) end mclient.ON_DISCONNECT = function(...)   log('mqtt disconnect', ...) end -- mclient:login_set('test', '123456') mclient:connect(broker) mclient:loop_forever() os.sleep(1)

[a455115]

You can write a custom conversion function and add it to mqtt_to_object_conv table. What kind of string value is it?

It returns me an On / Off value but as a string.

[admin]

Add before multiply function:

Code:

123

function onofftobool(payload)   return tostring(payload):lower() == 'on' end

Then modify mqtt_to_object_conv table:

Code:

123

mqtt_to_object_conv = {   ['shellies/shellyplug-s-D9AA39/relay/0'] = onofftobool, }