Script MQTT-Fehlertolleranz

Frank Berges · June 2, 2023 at 5:41 AM Autor

Ich habe auf einem i4 ein Script laufen das im Normalfall auch immer funktioniert.

Ab und an steht das Script auf Stop und nach einem erneuten Start per Weboberfläche läuft es wieder.

Das Script steht auch auf Autostart und sollte bei Spannungsausfall eigentlich auch sofort wieder laufen (nach Test macht es das auch).

Ich vermute das der MQTT-Server ab und an nicht erreichbar ist (Warum auch immer er ist Intern im ioBroker).

Das sind aber nur Vermutungen und ich finde den Fehler nicht.

Hier das Script das Tastendrücke auf den Eingängen Zählt, diese an den MQTT weiter gibt und der Zähler kann vom MQTT beeinflusst werden.

Code

// Script für den SHELLY i4 Taster-Anschluss
// Tastendruck SW1-SW4 auswerten 0-2 und diese dem MQTT übergeben
// Zählerbeeinflussung vom MQTT den Tastenzählern zuweisen
// --------------------------------------------------------------
//Variabeln deffinieren

let CONFIG = {
  device_id: "",
  device_mac: "",
  device_model: "",
  fw_ver: "",
  topic_prefix: "",
  wifi_ip: "",
};

let Taste = [0,0,0,0]; //Tate SW1 - SW4
let T_Name = ["Nr:1","Nr:2","Nr:3","Nr:4"]; //Name der Taste im MQTT

function isConfigReady() {
  for (let key in CONFIG) {
    if (CONFIG[key] === "") return false;
  }
  return true;
}

Shelly.call("Shelly.GetDeviceInfo", null, function (info) {
  CONFIG.device_id = info.id;
  CONFIG.device_mac = info.mac;
  CONFIG.device_model = info.model;
  CONFIG.fw_ver = info.fw_id;
});

//Read ip from status
Shelly.call("WiFi.GetStatus", null, function (status) {
  if (status.status === "got ip") {
    CONFIG.wifi_ip = status.sta_ip;
  }
});

//Monitor ip changes
Shelly.addStatusHandler(function (status) {
  if (status.component === "wifi" && status.delta.status === "got ip") {
    CONFIG.wifi_ip = status.delta.sta_ip;
  }
});

//Read mqtt topic prefix
Shelly.call("MQTT.GetConfig", null, function (config) {
  CONFIG.topic_prefix = config.topic_prefix;
});


// Eingänge abfragen und Tastendruck von 0 - 2 zählen
Shelly.addEventHandler
(
  function (event)
  // Event aktivieren
  {
    if(event.name==="input" && event.info.state === true)
    {
      let id = event.info.id; //id = Welcher Eingang
      if (id > -1 && id < 4) //SW1 - SW3
      {
        Taste[id] = Taste[id] + 1;
        if (Taste[id] === 3)
        {
          Taste[id] = 0;
        }
        //print(deviceInfo.id,"/Taste/",T_Name[id],JSON.stringify(Taste[id]));
        MQTT.publish(CONFIG.topic_prefix + "/Taste/"+T_Name[id], JSON.stringify(Taste[id]));
      }
    }
  }
)

// Announcen die MQTT ankommen bearbeiten
function announceHandler(topic, message) 
{
let kanal = 0;
  print("topic = ",topic,"   message = ",message);
  kanal = JSON.parse(topic.slice(topic.length - 1,topic.length)) -1; 
  if (message !== "0" && message !== "1" && message !== "2") return;
  Taste[kanal] = JSON.parse(message);
  MQTT.publish(CONFIG.topic_prefix + "/Taste/"+T_Name[kanal], message);
}

// Announcen im MQTT anmelden
function subscribeToTopics() 
{
  MQTT.subscribe(CONFIG.topic_prefix  + "/Taste/command_Nr_1", announceHandler);
  MQTT.subscribe(CONFIG.topic_prefix  + "/Taste/command_Nr_2", announceHandler);
  MQTT.subscribe(CONFIG.topic_prefix  + "/Taste/command_Nr_3", announceHandler);
  MQTT.subscribe(CONFIG.topic_prefix  + "/Taste/command_Nr_4", announceHandler);
}


//Start a timer that checks if all fields in CONFIG are populated
let configReadyTimer;
function connectToMQTT() {
  configReadyTimer = Timer.set(3000, true, function () {
    if (!isConfigReady()) return;
    if (!MQTT.isConnected()) return;

    subscribeToTopics();
    Timer.clear(configReadyTimer);
  });
}

connectToMQTT();

MQTT.setDisconnectHandler(function () {
  connectToMQTT();
});

Display More

Könnt Ihr Euch das bitte mal ansehen und Möglicherweise findet Ihr da Verbesserungen so das das Script nicht auf Stop geht.

Sonst kontrolliere ich das per Blockly ob es läuft und starte es auf dem Wege wieder Neu.

Das ist aber eigentlich nur eine Übergangslösung und keine Problemlösung.

mfg

f.b.

_[Deleted]_ · June 2, 2023 at 6:10 PM

Hallo Frank,

Ich hab dein Skript mal grob überflogen, sieht eigentlich ganz gut aus (bis auf den fehlenden Error Handling Part), vielleicht handelt es sich um nen abgefragten null Wert.

Man muss immer davon ausgehen, dass jeder Shelly Wert den man abfragt auch null sein kann, das ist bei manchen Werten von den Entwicklern so gewollt, dieser "null" Zustand kann von deiner Logik nicht weiter verarbeitet werden und löst dann einen Fehler aus, der zu einem Stop führt. Sowas passiert meistens nur beim Start, wenn der Shelly weder Zeit noch IP kennt, aber trotzdem versucht dein Skript auszuführen.

Vielleicht hilft es deinen Config Check etwas anzupassen:

Code

function isConfigReady() {
  for (let key in CONFIG) {
    if (CONFIG[key] === "" || typeof CONFIG[key] === 'null') return false; //Auch auf null prüfen.
  }
  return true;
}

Wenn das net reicht, kann man immer noch einen Error Handler in jeden Shelly Call einbauen und versuchen den Fehler abzufangen, über das MQTT Debug Log kann man sich dann den abgefangenen Fehler genau ansehen.

Hier ein Beispiel für nen Call Error Handler:

Code

 //Shelly Call Error Check
function Call_ErrorCheck(response, shellyCall_error_code, shellyCall_error_message, extra) {
        if (shellyCall_error_code !== 0) {
            print('Error: Shelly.call()');
            print('Response: ', JSON.stringify(response));
            print('eMsg: ', shellyCall_error_message);
            print('Response type is: ', typeof (response));
            if (typeof (response) !== 'object') {
                response = { callError: true, orgResponse: response };
            } else {
                response.callError = true;
            }
        }
        if (typeof (response) !== 'object') {
            response = { changedToObj: true, orgResponse: response };
        }
        if (typeof (extra) !== 'undefined') {
            if (typeof (extra) === 'function') extra(response);
            if (typeof (extra) === 'object') extra.CallBack(response, extra.data);
        }
}   

//Shelly call
Shelly.call('Switch.Toggle', {id: 0}, Call_ErrorCheck);

Display More

Außerdem bedenke das du maximal 10 MQTT topic subscriptions sowie 5 Timer, in einem Skript haben kannst!

In diesem Sinne sind hier noch weitere Verbesserungsvorschläge von mir:

Code

let configReadyTimer;
function connectToMQTT() {
  Timer.clear(configReadyTimer); //Timer vor dem Start löschen damit max eine aktiver Timer läuft.
  configReadyTimer = Timer.set(3000, true, function () {
    if (!isConfigReady()) return;
    if (!MQTT.isConnected()) return;

    //vorher MQTT.unsubscribe() für alle Topics durchführen.
    subscribeToTopics();
    Timer.clear(configReadyTimer);
  });
}

Display More

Frank Berges · June 2, 2023 at 7:07 PM Autor

Quote from De kat

Vielleicht hilft es deinen Config Check etwas anzupassen:

Ja das mit dem Config hatte ich auch als Fehlerquelle angesehen und habe darum eine Verzögerung eingebaut :

Code

//Start a timer that checks if all fields in CONFIG are populated
let configReadyTimer;
function connectToMQTT() {
  configReadyTimer = Timer.set(3000, true, function () {
    if (!isConfigReady()) return;
    if (!MQTT.isConnected()) return;

    subscribeToTopics();
    Timer.clear(configReadyTimer);
  });
}

Display More

Das führt dazu das eine weitere Bearbeitung erst nach 3000ms weitergefügrt wird.

Ohne das läuft das Script fast nicht an.

_[Deleted]_ · June 2, 2023 at 7:13 PM

... dein Satz über deinem Code Ausschnitt war verdeckt,

Ok, ja du hast recht, aber du prüfst nicht direkt auf Nullwerte, sondern nur auf leere Strings, deswegen solltest du auch zusätzlich auf Nullwerte prüfen und solange deine Timer Schleifen wiederholen bis es funktioniert, deine Timer Schleife solltest du übrigens auch anpassen, da man deinen Timer gerade über 5 mal gleichzeigt aufrufen kann.

Schau dir bitte die von mir überarbeiten Code Stellen nochmal genau an.

Meine Verbesserungsvorschläge:

1. Filtern auf null Werte,

2. Clear Timer vor dem Timer Call

3. unsubscribe() topics vor nem neuen subscribe()

Frank Berges · June 2, 2023 at 10:46 PM Autor

Quote from De kat

Ok, ja du hast recht, aber du prüfst nicht direkt auf Nullwerte, sondern nur auf leere Strings, deswegen solltest du auch zusätzlich auf Nullwerte prüfen und solange deine Timer Schleifen wiederholen bis es funktioniert, deine Timer Schleife solltest du übrigens auch anpassen, da man deinen Timer gerade über 5 mal gleichzeigt aufrufen kann.

Das mit dem Timer ist nicht auf meinem Mist gewachsen, das ist eine Vorlage schau hier :

shelly-script-examples/mqtt-announce-control.js at main · ALLTERCO/shelly-script-examples · GitHub

Da ich Probleme mit dem Script abbruch beim Starten hatte, habe ich nach Lösungen gesucht und nachgesehen was ALLTERCO da so bastelt und bin genau darauf gestoßen.

Code

//Start a timer that checks if all fields in CONFIG are populated
let configReadyTimer;
function connectToMQTT() {
  Timer.clear(configReadyTimer);
  configReadyTimer = Timer.set(3000, true, function () {
    if (!isConfigReady()) return;
    if (!MQTT.isConnected()) return;

    subscribeToTopics();
    Timer.clear(configReadyTimer);
  });
}

Display More

Ich habe es mal eingebaut wie du geschrieben hast.

Das klingt logisch, wenn das mehrfach hintereinander aufgerufen wird läuft irgendwann der Stack voll.

Nur sollte ALLTERCO das in seinen Beispielen dann auch so machen damit nicht Andere das genau so falsch machen.