Ajout d'un delai entre l'insertion de 2 trames dans influxdb

teleinfo_delay.py

@@ -0,0 +1,138 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+# __author__ = "Sébastien Reuiller"
+# __licence__ = "Apache License 2.0"
+
+# Python 3, prerequis : pip install pySerial influxdb
+#
+# Exemple de trame:
+# {
+#  'OPTARIF': 'HC..',        # option tarifaire
+#  'IMAX': '007',            # intensité max
+#  'HCHC': '040177099',      # index heure creuse en Wh
+#  'IINST': '005',           # Intensité instantanée en A
+#  'PAPP': '01289',          # puissance Apparente, en VA
+#  'MOTDETAT': '000000',     # Mot d'état du compteur
+#  'HHPHC': 'A',             # Horaire Heures Pleines Heures Creuses
+#  'ISOUSC': '45',           # Intensité souscrite en A
+#  'ADCO': '000000000000',   # Adresse du compteur
+#  'HCHP': '035972694',      # index heure pleine en Wh
+#  'PTEC': 'HP..'            # Période tarifaire en cours
+# }
+#
+#
+#   2024-02-16:	pbrinett ajout d'un delai de 1mn  entre l'insertion de 2 valeurs
+
+
+import serial
+import logging
+import time
+import requests
+from datetime import datetime
+from influxdb import InfluxDBClient
+
+# clés téléinfo
+int_measure_keys = ['IMAX', 'HCHC', 'IINST', 'PAPP', 'ISOUSC', 'ADCO', 'HCHP']
+
+# delais entre 2 insert (1mn)
+interval = 60
+
+# création du logguer
+logging.basicConfig(filename='/var/log/teleinfo/releve.log',
+                    level=logging.INFO, format='%(asctime)s %(message)s')
+logging.info("Teleinfo starting..")
+
+# connexion a la base de données InfluxDB
+# client = InfluxDBClient('localhost', 8086) # , username='teleinfo', password='PWDteleinfo2021')
+# , username='teleinfo', password='PWDteleinfo2021')
+client = InfluxDBClient('192.168.0.101', 8086)
+db = "teleinfo"
+connected = False
+while not connected:
+    try:
+        logging.info("Database %s exists?" % db)
+        if not {'name': db} in client.get_list_database():
+            logging.info("Database %s creation.." % db)
+            client.create_database(db)
+            logging.info("Database %s created!" % db)
+        client.switch_database(db)
+        logging.info("Connected to %s!" % db)
+    except requests.exceptions.ConnectionError:
+        logging.info('InfluxDB is not reachable. Waiting 5 seconds to retry.')
+        time.sleep(5)
+    else:
+        connected = True
+
+
+def add_measures(measures, time_measure):
+    points = []
+    for measure, value in measures.items():
+        point = {
+            "measurement": measure,
+            "tags": {
+                "host": "raspberry",
+                        "region": "linky"
+            },
+            "time": datetime.utcnow().strftime("%Y-%m-%dT%H:%M:%SZ"),
+            "fields": {
+                "value": value
+            }
+        }
+        points.append(point)
+
+    client.write_points(points)
+
+
+def main():
+    with serial.Serial(port='/dev/ttyUSB0', baudrate=1200, parity=serial.PARITY_EVEN, stopbits=serial.STOPBITS_ONE,
+                       bytesize=serial.SEVENBITS, timeout=1) as ser:
+
+        logging.info("Teleinfo is reading on /dev/ttyUSB0..")
+
+        trame = dict()
+
+        # boucle pour partir sur un début de trame
+        line = ser.readline()
+        while b'\x02' not in line:  # recherche du caractère de début de trame
+            line = ser.readline()
+
+        # lecture de la première ligne de la première trame
+        line = ser.readline()
+
+        # timestamp de la derniere insertion de valeur
+        last_insert = 0
+
+        while True:
+            line_str = line.decode("utf-8")
+            ar = line_str.split(" ")
+            try:
+                key = ar[0]
+                if key in int_measure_keys:
+                    value = int(ar[1])
+                else:
+                    value = ar[1]
+
+                checksum = ar[2]
+                trame[key] = value
+                if b'\x03' in line:  # si caractère de fin dans la ligne, on insère la trame dans influx
+                    del trame['ADCO']  # adresse du compteur : confidentiel!
+                    time_measure = time.time()
+
+                    if (int(time_measure) - last_insert) >= interval:
+                        # insertion dans influxdb
+                        add_measures(trame, time_measure)
+
+                        # ajout timestamp pour debugger
+                        trame["timestamp"] = int(time_measure)
+                        last_insert = int(time_measure)
+                        logging.debug(trame)
+
+                    trame = dict()  # on repart sur une nouvelle trame
+            except Exception as e:
+                logging.error("Exception : %s" % e)
+            line = ser.readline()
+
+
+if __name__ == '__main__':
+    if connected:
+        main()