node Red -> MQTT

  • bloody27370
  • Auteur du sujet
  • Hors Ligne
  • Nouveau membre
  • Nouveau membre
Plus d'informations
16 Aoû 2023 20:58 #1 par bloody27370
node Red -> MQTT a été créé par bloody27370
Bonjour,

Je cherche à récupérer toutes les secondes certaines valeurs du M'Sun PV pour les utiliser dans ma domotique. J'ai eu l'idée peut être un peu bête d'utiliser Node RED pour convertir le XML status en MQTT. Pour qu'ensuite je puisse utiliser les valeurs dans ma domotique sans charger le processeur de la domotique à gérer les scénario d'analyse du XML.

Ma connaissance de Node Red est très limité car je le découvre aujourd'hui. Après plusieurs heures à chercher en m'aidant un peu de chatGPT je sèche. Et MQTT je l'utilise depuis quelques mois mais j'essaye d'apprendre encore son fonctionnement.
Je vous joint une capture de mon Node pour comprendre.

1) un timestamp à la seconde pour l'actualisation en continue => fonctionnel
2) http request avec le lien "http://mon-ip/status.xml" => fonctionnel
3) un node xml pour convertir le XML en JSON. Cela me donne le JSON suivant :
{
  "xml": {
    "rtcc": [
      "22:41:58 ME"
    ],
    "paramSys": [
      "22:41:58;16/08/2023;On;01:00;0,0;MS_PV2_2;5.0.1;0000220;102e;102c;00:00;00:00"
    ],
    "inAns": [
      "493,0;-3,3; 0; 0;228,2;0,0;0,0;0,0; 0; 0; 0; 0; 0; 0; 0; 0;"
    ],
    "survMm": [
      "0;0;0;0;0;0;0;0;0;0;0;0;0;0;0;0;"
    ],
    "cmdPos": [
      "a;a;0;0;0;0;0;1;"
    ],
    "outStat": [
      "0;0;0;0;0;0;0;0;0;0;0;0;0;0;0;0;"
    ],
    "cptVals": [
      "24c67;fffff15d;fffdeded;fe80e657;0;0;0;0;"
    ],
    "chOutVal": [
      "0;0;0;ff;:0,0;0,0;0,0;0,0;"
    ]
  }
}

4) Ensuite et c'est là que je pense être ma première erreur, je voulais le convertir, j'ai essayé avec ChatGPT, mais rien n'a l'air de fonctionner. Une de ses propositions est :
var inAnsData = msg.payload.xml.inAns[0];
var cptValsData = msg.payload.xml.cptVals[0];
var outStatData = msg.payload.xml.outStat[0];
var cmdPosData = msg.payload.xml.cmdPos[0];

// Traitement des données de inAns
var inAnsValues = inAnsData.split(';');
// ... Traitez les données de inAns comme vous le faisiez dans la fonction PHP

// Traitement des données de cptVals
var cptValsValues = cptValsData.split(';');
// ... Traitez les données de cptVals comme vous le faisiez dans la fonction PHP

// Traitement des données de outStat
var outStatValues = outStatData.split(';');
// ... Traitez les données de outStat comme vous le faisiez dans la fonction PHP

// Traitement des données de cmdPos
var cmdPosValues = cmdPosData.split(';');
// ... Traitez les données de cmdPos comme vous le faisiez dans la fonction PHP

Pour finir j'ai le MQTT Out, j'ai bien renseigné mon brocker et il s'y connecte mais je ne sais pas quoi mettre en payload

Si vous avez d'autres solution je suis preneur ...

En l'occurence je n'ai que 5 infos qu'il m'intéresse de récupérer en gras ci-dessous :

"inAns": [
"493,0;-3,3; 0; 0;228,2;0,0;0,0;0,0; 0; 0; 0; 0; 0; 0; 0; 0;"

cptVals": [
"24c67;fffff15d;fffdeded;fe80e657;0;0;0;0;"
Pièces jointes :

Connexion ou Créer un compte pour participer à la conversation.

  • bloody27370
  • Auteur du sujet
  • Hors Ligne
  • Nouveau membre
  • Nouveau membre
Plus d'informations
17 Aoû 2023 09:01 #2 par bloody27370
Réponse de bloody27370 sur le sujet node Red -> MQTT
Je me réponds à moi même, après avoir été guidé sur le forum Jeedom.

Voici la solution que m'a donné chatGPT et qui fonctionne pour récupérer les deux premières valeurs de InAns qui m'intéresse.
// Récupérer le message JSON d'entrée
var inputJSON = msg.payload;

// Extraire l'objet "inAns"
var inAnsArray = inputJSON.xml.inAns;

// Join des éléments de l'array et remplacement des virgules par des points
var inAnsString = inAnsArray.join('').replace(/,/g, '.');

// Séparer les valeurs par des points-virgules et prendre les 2 premières
var numericValues = inAnsString.split(';').slice(0, 2).map(item => parseFloat(item));

// Créer l'objet de sortie avec les valeurs numériques
var outputObj = { "inAns": numericValues };

// Envoyer l'objet de sortie
msg.payload = outputObj;
return msg;

Connexion ou Créer un compte pour participer à la conversation.

Plus d'informations
11 Fév 2024 12:55 - 11 Fév 2024 13:53 #3 par ilco
Réponse de ilco sur le sujet node Red -> MQTT
Salut,

J’ai un peu complété le code avec l’envoi de toutes les infos sur un topic msunpv/data. J’ai converti la valeur des compteurs avec le fameux complément a 2 pour avoir les nombres negatifs!
[{"id":"5c1f49a2f0842fa0","type":"function","z":"999280016ff24882","name":"function 1","func":"// Récupérer le message JSON d'entrée\nvar inputJSON = msg.payload;\n\n// Extraire l'objet \"inAns\"\n\nvar inRTCC = inputJSON.xml.rtcc;\nvar inParamSys = inputJSON.xml.paramSys;\nvar inAnsArray = inputJSON.xml.inAns;\nvar inSurvMm = inputJSON.xml.survMm;\nvar inCmdPos = inputJSON.xml.cmdPos;\nvar inOutStat = inputJSON.xml.outStat;\nvar inCptVals = inputJSON.xml.cptVals;\nvar inChOutVal = inputJSON.xml.chOutVal;\n\n\nvar RTCCStringValues = inRTCC.join('').split(' ');\nvar ParamSysStringValues = inParamSys.join('').split(';');\n\n// Join des éléments de l'array et remplacement des virgules par des points\nvar ansStringValues = inAnsArray.join('').replace(/,/g, '.').replace(/\\;$/,'');\n// Séparer les valeurs par des points-virgules et prendre les 2 premières\nvar ansNumericValues = ansStringValues.split(';').map(item => parseFloat(item));\n\nvar SurvMmStringValues = inSurvMm.join('').replace(/\\;$/, '').split(';').map(item => parseInt(item));\nvar CmdPosStringValues = inCmdPos.join('').replace(/\\;$/, '').split(';').map(item => parseInt(item));\nvar OutStatStringValues = inOutStat.join('').replace(/\\;$/, '').split(';').map(item => parseInt(item));\nvar CptValsNumericValues = inCptVals.join('').replace(/\\;$/, '').split(';').map(item => hexToInt(item));\nvar ChOutValStringValues = inChOutVal.join('').replace(/\\;$/, '').split(';');\n\n// Créer l'objet de sortie avec les valeurs numériques\nvar outputObj = {\"RTCC\": RTCCStringValues, \"ParamSys\": ParamSysStringValues, \"inAns\": ansNumericValues, \"SurvMm\": SurvMmStringValues, \"CmdPos\": CmdPosStringValues, \"OutStat\": OutStatStringValues, \"CptVals\": CptValsNumericValues, \"ChOutVal\": ChOutValStringValues};\n\n// Envoyer l'objet de sortie\nmsg.payload = outputObj;\nreturn msg;\n\nfunction hexToInt(hex) {\n    if (hex.length % 2 != 0) {\n        hex = \"0\" + hex;\n    }\n    var num = parseInt(hex, 16);\n    var maxVal = Math.pow(2, hex.length / 2 * 8);\n    if (num > maxVal / 2 - 1) {\n        num = num - maxVal\n    }\n    return num;\n}","outputs":1,"timeout":0,"noerr":0,"initialize":"","finalize":"","libs":[],"x":700,"y":500,"wires":[["7d266cee5180b2e6","e1cf2e08bb917aa2"]]}]

Il me manque encore la partie de « surveille un topic msunpv/data pour envoyer les commandes POST » et modifier le routeur. Je ne sais pas trop quelle strategie adopter…
Dernière édition: 11 Fév 2024 13:53 par ilco.

Connexion ou Créer un compte pour participer à la conversation.

Propulsé par Kunena