Hi everyone,
I have MQTT Brokwer installed and the MQTT Integration enabled.
I can confirm it works because the “HoyMiles Solar Gateway stable Addon” is able to connect.
I have created a user “mqtest” which is allowed to have “local network logins only” and has a password of “abcdefg”.
In Integrations → MQTT → Re-configure:
Broker: core-mosquitto
Port: 1883
user: mqtest
pw: abcdefg
In the MQTT Options I have enabled discovery, birth messsage and will message.
For the Shelly 3EM Pro I configured it like this:
MQTT: Enable
Connection type: No TLS
MQTT prefix: shellypro3em_123456
Enable MQTT Control
Enable RPC over MQTT
Enable RPC Status notifications over MQTT
Enable Generic status update over MQTT
Server: IP_of_HA_Green_device:1883
Client ID: shellypro3em-123456 (I didn’t change this)
user: mqtest
pw: abcdefg
The HA MQTT Explorer doesn’t show any connection of the Shelly.
Additionally the Shelly created two entities with this script:
let energyReturnedWs = 0.0;
let energyConsumedWs = 0.0;
let energyReturnedKWh = 0.0;
let energyConsumedKWh = 0.0;
let log = 0;
// set this to false to stop publishing on MQTT
let MQTTpublish = true;
// set this to false if you DONT want to update the name
// (the updated name is necessary to read the data with the iobroker shelly plugin)
let updateName = false;
// query the MQTT prefix on startup
let SHELLY_ID = undefined;
Shelly.call("Mqtt.GetConfig", "", function (res, err_code, err_msg, ud) {
SHELLY_ID = res["topic_prefix"];
});
function SetKVS(key, value)
{
Shelly.call(
"KVS.Set", {
"key": key,
"value": value,
},
function(result) {
if (log > 0)
print("KVS Saved, rev:", result.rev);
}
);
}
function SaveCounters()
{
SetKVS("EnergyConsumedKWh", energyConsumedKWh );
SetKVS("EnergyReturnedKWh", energyReturnedKWh );
}
Shelly.call(
"KVS.Get", {
"key": "EnergyReturnedKWh",
},
function callback(result, error_code, error_message, userdata) {
if (error_code === 0)
{
energyReturnedKWh = Number(result.value);
print("Loaded returned energy: ", energyReturnedKWh, " KWh");
}
}
);
Shelly.call(
"KVS.Get", {
"key": "EnergyConsumedKWh",
},
function callback(result, error_code, error_message, userdata) {
if (error_code === 0)
{
energyConsumedKWh = Number(result.value);
print("Loaded consumed energy: ", energyConsumedKWh, " KWh");
}
}
);
let counter3600 = 0;
let counter20 = 18;
let lastPublishedMQTTConsumed = "";
let lastPublishedMQTTReturned = "";
function timerHandler(user_data)
{
let em = Shelly.getComponentStatus("em", 0);
if (typeof em.total_act_power !== 'undefined') {
let power = em.total_act_power;
if (power >= 0)
{
energyConsumedWs = energyConsumedWs + power * 0.5;
}
else
{
energyReturnedWs = energyReturnedWs - power * 0.5;
}
// once a full Wh is accumulated, move it to the KWh counter
let fullWh = Math.floor((energyConsumedWs / 3600));
if (fullWh > 0)
{
energyConsumedKWh += fullWh / 1000;
energyConsumedWs -= fullWh * 3600;
if (log > 0)
print("Changed consumed KWh: ",energyConsumedKWh);
}
fullWh = Math.floor((energyReturnedWs / 3600));
if (fullWh > 0)
{
energyReturnedKWh += fullWh / 1000;
energyReturnedWs -= fullWh * 3600;
if (log > 0)
print("Changed returned KWh: ",energyReturnedKWh);
}
if (log > 0)
print(power , "W");
counter3600 = counter3600 + 1;
if (counter3600 > 3600)
{
counter3600 = 0;
SaveCounters();
}
counter20 = counter20 + 1;
if ( counter20 > 20)
{
counter20 = 0;
if (updateName)
{
Shelly.call(
"Sys.SetConfig", {
config: {device:{name:energyConsumedKWh.toFixed(3)+" KWh ; "+(energyReturnedKWh+energyReturnedWs / 3600000).toFixed(5)+" KWh"}},
},
function(result, error_code, error_message, userdata) {
//print("error ", error_code, " : ", error_message);
//print("result", JSON.stringify(result));
}
);
}
if (typeof SHELLY_ID !== "undefined" && MQTTpublish === true)
{
let value = energyConsumedKWh.toFixed(3);
if (value !== lastPublishedMQTTConsumed)
{
MQTT.publish(
SHELLY_ID + "/energy_counter/consumed",
value,
0,
false
);
lastPublishedMQTTConsumed = value;
}
let value = energyReturnedKWh.toFixed(3);
if (value !== lastPublishedMQTTReturned)
{
MQTT.publish(
SHELLY_ID + "/energy_counter/returned",
value,
0,
false
);
lastPublishedMQTTReturned = value;
}
}
}
};
}
Timer.set(500, true, timerHandler, null);
function httpServerHandler(request, response) {
response.code = 200;
// create JSON object
const energyData = {
energyConsumed: energyConsumedKWh.toFixed(3) + " KWh",
energyReturned: (energyReturnedKWh+(energyReturnedWs / 3600000)).toFixed(5) + " KWh"
};
// convert JSON object to string and send it as reply
response.body = JSON.stringify(energyData);
response.send();
return;
}
HTTPServer.registerEndpoint("energy_counter", httpServerHandler);While in my configurations.yaml I created these sensors:
mqtt:
sensor:
- name: shellypro3em_123456-diff_total_energy-consumed
unique_id: shellypro3em_123456-c
state_topic: "shellypro3em_123456/energy_counter/consumed"
unit_of_measurement: "kWh"
state_class: total_increasing
device_class: energy
- name: shellypro3em_123456-diff_total_energy-returned
unique_id: shellypro3em_123456-r
state_topic: "shellypro3em_123456/energy_counter/returned"
unit_of_measurement: "kWh"
state_class: total_increasing
device_class: energyThe entitiy “shellypro3em_123456-diff_total_energy-consumed” is unknown.
It seems like the shelly doesn’t connect via MQTT at all.
Does anyone have hints on why this isn’t working?
THanks!