Lecture Linky via dongle et compteur via GPIO
-
Test concluant avec le dongle branché sur la sortie TIC de mon Sagem :
pi@raspberrypi:~ $ picocom -b 1200 -d 7 -p e -f n /dev/ttyUSB0
picocom v3.1port is : /dev/ttyUSB0
flowcontrol : none
baudrate is : 1200
parity is : even
databits are : 7
stopbits are : 1
escape is : C-a
local echo is : no
noinit is : no
noreset is : no
hangup is : no
nolock is : no
send_cmd is : sz -vv
receive_cmd is : rz -vv -E
imap is :
omap is :
emap is : crcrlf,delbs,
logfile is : none
initstring : none
exit_after is : not set
exit is : noType [C-a] [C-h] to see available commands
Terminal ready
<tL1766843 .
PTEC TH.. $
IINST 000 W
IMAX 012 B
PAPP 00000 !
MOTDETAT 000000 B
ADCO 021628001921 7
OPTARIF BASE 0
ISOUSC 30 9
BASE 001766843 .
PTEC TH.. $
IINST 000 W
IMAX 012 B
PAPP 00060 '
MOTDETAT 000000 B
ADCO 021628001921 7
OPTARIF BASE 0
ISOUSC 30 9
BASE 001766843 .
PTEC TH.. $
IINST 000 W
IMAX 012 B
PAPP 00060 '
MOTDETAT 000000 B
ADCO 021628001921 7
OPTARIF BASE 0
ISOUSC 30 9
BASE 001766843 .
PTEC TH.. $
IINST 000 W
IMAX 012 BDonc c'est ce RPi qi va relever le Linky via le shield et le Sagem via le dongle.
-
Par contre, pour l'instant, je lis la sortie TIC du Linky via un programme Python qui utilise la bibliothèque PITinfo mais je dois bidouiller dans un script pour lancer le programme python en arrière plan puis au bout de 10s, je fais un grep et je kill le process car le programme python ne rend jamais la main.
Pour le dongle, je pense utiliser ton programme :
http://hallard.me/teleinfo-emoncms/
Mais si je veux un programme qui sache lire le Linky et un autre qui sache lire le Sagem, il faut que je le compile 2 fois avec des options différentes (pour qu'ils se nomment différemment, pour qu'ils aient des fichiers de conf différents, ...) ? Va falloir que je me plonge de le makefile et le fichier .c, ça va me rappeler ma jeunesse
-
@mikebzh44 je crois que tu te complique la vie, la vrai question est comment traites tu les données après et qu'en fait-tu ?
A ta place sur le PI je monterais un node red qui écoute sur les 2 serial et qui les envoi ou tu veux (en plus c'est graphique c'est top)
Sinon ton script python peut faire l'affaire tu le copie et tu le renommes
script_cpt1.pyetscript_cpt2.pyet tu lances les 2 en arrière plan chacun avec ses propres options par exemple.Ya plein d'option mais compiler du C juste pour lire la téléinfo c'est du taff.
-
Je remonte mes index de compteur dans une base MySQL à une cadence d'une minute.
Avec le Node Red, je peux faire une boucle pour lire les 2 serial et envoyer les infos dans ma base MySQL toutes les minutes ?
Sinon, je vais dupliquer mon shell + script python pour que chacun lise un serial.
-
@mikebzh44 oui bien sur tu peux tout faire avec node red, tu peux le lancer en auto au démarrage, ensuite tu peux faire des modifs de code à la volée ou ajouter des modules (envoi dans mysql par exemple) dans la GUI, c'est super pratique, t'as pas besoin de gérer les redémarrages et tout. Tu peux même le faire tourner dans une instance docker, ca ne polluera pas ta machine.
pour ton script tu peux aussi regrouper la lecture des 2 serials dans le même script.
-
@mikebzh44 ce qui m'inquiète c'est que ton dongle ne lise pas le mode standard, peux tu ré essayer en ne mettant que le dongle connecté à la sortie du linky et bien vérifier les connexions ?
-
Je vais installer Node Red ce soir et je vais tester le dongle sur le Linky en étant seul sur la sortie TIC.
-
je fais partir au courrier demain:
- un autre uTeleinfo avec
- 1K2 entrée opto
- 4.7K sortie opto
- Un Shield PITinfo (1K2 / 4K7)
Ensuite pourras tu faire des tests avec et nous dire si les deux fonctionnent en mode standard avec ton Linky ?
Merci à toi, tu pourra garder le tout.
- un autre uTeleinfo avec
-
@charles Merci, je sais pas si ca vaut le coup, je viens de tester le dongle sur mon Linky sans la double liaison et picocom lit sans problème les trames.
C'était soit un soucis de branchement, soit le fait d'avoir dérivé la sortie TIC vers 2 serials
J'ai installé Node-Red, je m'attaque à la lecture de mes compteurs maintenant
-
Par contre, j'essaie de lire ma sortie TIC via le dongle et Node Red et d'insérer l'index dans ma base MySQL :
Ca marche mais j'ai un décalage d'une seconde à chaque ajout :
Donc avec cette dérive, je vais avoir un moment ou je vais louper une minute. Je sais, c'est pas la mort mais j'aimerais bien garder mon intervalle d'une minute.
Si tu as une idée
-
@mikebzh44 ah ok très bien, ça me rassure. merci pour le suivit
-
@mikebzh44 ouais j'suis pas fan des limit je m'en sers uniquement quand ca va très vite et que je veux limiter.
T'as essayer de faire un limit 1msg/59s pour voir ?
Sinon moi je stocke les valeurs de chaque trame dans le contexte (espèce de variable globale node Red) puis je mets des inject node (mode trigger) qui viennent récupérer les valeurs du contexte
Un toutes les 10s pour les valeurs temps réel et un autre tt les 5 min pour toutes les valeurs (inutile de charger la BDD pour les index par exemple) ce qui donne un truc comme ça
je te mets le flow (t'as juste à l'importer dans node red) pour que tu puisses trouver des idées
[{"id":"21d0dbd3.42c4f4","type":"function","z":"8b43a51b.e87958","name":"Valeurs Temps Réel","func":"var str = \"\";\nvar ti = context.global.teleinfo;\n\nfor (var label in ti)\n{\n\tif (label==\"ADPS\" || label==\"PAPP\" || label==\"TENSION\" || label==\"IINST1\" || label==\"IMAX1\" )\n\t{\n if (str.length>0)\n str+=\",\";\n \n str += label + \":\"+ ti[label];\n\t} \n\n\tif ( label==\"PAPP\" )\n\t{\n if (str.length>0)\n str+=\",\";\n\n str += label + \"_\" + ti[\"PTEC\"] +\":\"+ ti[label];\n\t}\n\n}\n\nreturn [ { payload: str } ];\n","outputs":1,"noerr":0,"initialize":"","finalize":"","x":350,"y":180,"wires":[[]]}] -
Cool, merci pour le tuyau, je teste ça ce soir.
Et avec ce fameux contexte, je peux avoir un flow qui va lire la sortie TIC de mon Sagem via /dev/ttyUSB0, un 2éme qui va lire celle du Linky via /dev/ttyAMA0 et un 3ème qui va récupérer les données de mon sous-compteur d'injection du surplus dans mon chauffe via une requête HTTP (c'est un Wemos sous EspEasy qui est branché à la sortie RS485 du sous-compteur) puis agréger toutes ces informations pour ne faire qu'un seul ordre INSERT dans ma BDD ?
Je suppose qu'il faut que mon flow Linky stocke les données qui m'intéressent dans context.global.Linky (par exemple), de même pour context.global.Sagem et context.global.ECS et toutes les 1m, j'ai une fonction qui récupères les valeurs de ces 3 variables "globales" et je génère mon ordre INSERT, j'ai bon ?
Merci pour ton aide en tout cas, car cette programmation "graphique" est toute nouvelle pour moi
-
@mikebzh44 said in Lecture Linky via dongle et compteur via GPIO:
Cool, merci pour le tuyau, je teste ça ce soir.
Et avec ce fameux contexte, je peux avoir un flow qui va lire la sortie TIC de mon Sagem via /dev/ttyUSB0, un 2éme qui va lire celle du Linky via /dev/ttyAMA0 et un 3ème qui va récupérer les données de mon sous-compteur d'injection du surplus dans mon chauffe via une requête HTTP (c'est un Wemos sous EspEasy qui est branché à la sortie RS485 du sous-compteur) puis agréger toutes ces informations pour ne faire qu'un seul ordre INSERT dans ma BDD ?
Tout à fait
Je suppose qu'il faut que mon flow Linky stocke les données qui m'intéressent dans context.global.Linky (par exemple), de même pour context.global.Sagem et context.global.ECS et toutes les 1m, j'ai une fonction qui récupères les valeurs de ces 3 variables "globales" et je génère mon ordre INSERT, j'ai bon ?
C'est exactement ça
Merci pour ton aide en tout cas, car cette programmation "graphique" est toute nouvelle pour moi
c'est pratique et rapide hein ?
-
@charles Pratique, c'est certain ! Rapide, pas au début quand tu maîtrise que dalle
J'ai encore du mal à comprendre ces histoires de flow.
On met tous sur le même "graphe" ? On peut avoir plusieurs "graphes" qui peuvent être déployés ou non ?
Pour l'instant, tant que mon dongle n'est pas en production, je reste avec mes 2 RPi qui remplissent mes tables. Hier soir, j'ai donc dû arrêter le service Node Red pour ne pas qu'il continue à faire des INSERT alors que le dongle était débranché.
Mais si j'avais un autre flow (qui fait autre chose) et qui devait continuer à tourner, j'aurais dû faire comment pour désactiver uniquement la lecture TIC ?
Faut que je lise les tutos, ça doit bien être abordé
-
@mikebzh44 said in Lecture Linky via dongle et compteur via GPIO:
@charles Pratique, c'est certain ! Rapide, pas au début quand tu maîtrise que dalle
J'ai encore du mal à comprendre ces histoires de flow.
On met tous sur le même "graphe" ? On peut avoir plusieurs "graphes" qui peuvent être déployés ou non ?
oui tu peux créer des flow différents, tu as une option aussi pour désactiver un flow.
Pour l'instant, tant que mon dongle n'est pas en production, je reste avec mes 2 RPi qui remplissent mes tables. Hier soir, j'ai donc dû arrêter le service Node Red pour ne pas qu'il continue à faire des INSERT alors que le dongle était débranché.
Mais si j'avais un autre flow (qui fait autre chose) et qui devait continuer à tourner, j'aurais dû faire comment pour désactiver uniquement la lecture TIC ?
Perso je reste basique, moi je coupe les liens dans le flow (et tu déploie) exemple ton insert de bdd ou celui en sortie de la série.
Le vieil adage simpler is better
Faut que je lise les tutos, ça doit bien être abordé
-
Ca commence à rentrer, merci pour les tuyaux
Ce WE, je rajoute la lecture du Linky via ttyAMA0 et je fusionne mes 2 tabes (car j'avais une table pour les index du Linky et une table pour l'index du Sagem + ECS).
Restera ensuite à intégrer les sondes de T° DHT11 et DS18B20 mais y a des nodes pour ça donc ça devrait le faire sans problème
Par contre, pour sauvegarder l'index du compteur Sagem dans le contexte, je fais flow.set('WH',value) mais pour lire la variable, je ne peux pas faire comme dans ton exemple (context.flow.WH) mais je dois passer par flow.get('WH')
-
La lecture de /dev/ttyAMA0 marche bien debug :
ADSC 061961603260 5 VTIC 02 J DATE E210424091645 D NGTF H PLEINE/CREUSE \ LTARF HEURE PLEINE A EAST 010893318 0 EASF01 005110053 1 EASF02 005783265 G EASF03 000000000 $ EASF04 000000000 % EASF05 000000000 & EASF06 000000000 ' EASF07 000000000 ( EASF08 000000000 ) EASF09 000000000 * EASF10 000000000 " EASD01 005110053 / EASD02 005783265 E EASD03 000000000 " EASD04 000000000 # EAIT 000038838 # ERQ1 000007904 O ERQ2 000007294 R ERQ3 000040821 L ERQ4 004086122 U IRMS1 002 0 URMS1 234 C PREF 09 H PCOUP 09 " SINSTS 00465 U SMAXSN E210424063606 01899 G SMAXSN-1 E210423060619 02700 S SINSTI 00000 < SMAXIN E210424000000 00000 M SMAXIN-1 E210423134052 00634 F CCASN E210424090000 00460 8 CCASN-1 E210424083000 00836 _ CCAIN E210424090000 00000 $ CCAIN-1 E210424083000 00000 D UMOY1 E210424091000 234 + STGE 001A4501 A MSG1 PAS DE MESSAGE < PRM 14275687320408 : RELAIS 000 B NTARF 02 O NJOURF 00 & NJOURF+1 00 B PJOURF+1 0000C001 ...Mais quand je branche ma fonction de décodage :
// Enlever les codes début et fin de trame var lines = msg.payload.toString().replace("\u0002\n","").replace("\r\u0003",""); // Récupérer chaque ligne une à une lines = lines.split("\r\n"); for (var line in lines) { var i; var checksum = 32; // Recupérer le label, la valeur et la checksum // si la checksum est un espace on le remplace par un caractère non // autorisé en checksum (ici 's') pour eviter pb de split // donc espace espace devient espace s var myline = lines[line].toString().replace(" "," s").split(" "); // on dépile nos 3 valeurs var check = myline.pop(); var value = myline.pop(); var label = myline.pop(); // On peu repositionner la checksum à espace si c'était le cas if (check == "s") check = " "; // Calcul de la checksum sur ce qu'on a reçu, on balaye tous les caractères for (i = 0; i < label.length; i++) checksum += label.charCodeAt(i); for (i = 0; i < value.length; i++) checksum += value.charCodeAt(i); checksum = ((checksum%256) & 63) + 32; checksum = String.fromCharCode(checksum); // Checksum correcte ? if (checksum == check ) { if ( label == "EASF01") { flow.set("HC",parseInt(value,10)); } if ( label == "EASF02") { flow.set("HP",parseInt(value,10)); } if ( label == "LTARF") { if (value == 'HEURE PLEINE') { flow.set("TARIF",'HP..'); } else { flow.set("TARIF",'HC..'); } } if ( label == "IRMS1") { flow.set(label,parseInt(value,10)); } if ( label == "SINSTS") { flow.set(label,parseInt(value,10)); } if ( label == "EAIT") { flow.set(label,parseInt(value,10)); } } else { console.log("'%s' '%s' '%s' => Bad Checksum '%s'", label, value, check, checksum ); } }J'ai un message d'erreur dans le debug :
TypeError: Cannot read property 'length' of undefined
Le parsing est différent entre les trames Historiques et Standard ?
Car j'ai pris le code dans ton exemple sur une trame Historique :
Si ça peut aider, voici les trames reçues avec picocom :
-
En bidouillant un peu la lecture des trames (je vire le calcul des checksums entre autre), j'arrive à décoder les trames et extraire les couples label/values qui m'intéressent :
// Enlever les codes début et fin de trame var lines = msg.payload.toString().replace("\u0002\n","").replace("\r\u0003",""); // Récupérer chaque ligne une à une lines = lines.split("\r\n"); for (var line in lines) { // Recupérer le label, la valeur et la checksum // si la checksum est un espace on le remplace par un caractère non // autorisé en checksum (ici 's') pour eviter pb de split // donc espace espace devient espace s var myline = lines[line].toString().replace(" "," s").split(" "); if (myline.length == 1) { var entries = myline[0].split("\t"); var label = entries[0]; var value = entries[1]; if ( label == "EASF01") { flow.set("HC",parseInt(value,10)); } if ( label == "EASF02") { flow.set("HP",parseInt(value,10)); } if ( label == "LTARF") { if (value == 'HEURE PLEINE') { flow.set("TARIF",'HP..'); } else { flow.set("TARIF",'HC..'); } } if ( label == "IRMS1") { flow.set(label,parseInt(value,10)); } if ( label == "SINSTS") { flow.set(label,parseInt(value,10)); } if ( label == "EAIT") { flow.set(label,parseInt(value,10)); } } } -
@mikebzh44 je te conseille vivement de garder les calculs de checksum histoire de ne pas te retrouver avec les valeurs aberrantes en database en cas de problème.
