diff --git a/Chaufferie.py b/Chaufferie.py index b36c90c..c92a2a0 100644 --- a/Chaufferie.py +++ b/Chaufferie.py @@ -4,6 +4,7 @@ import sys import os import logging from dotenv import load_dotenv +from datetime import datetime # Charger les variables d'environnement load_dotenv() @@ -46,9 +47,13 @@ def on_message(_client, _userdata, msg): try: logging.info(f"Message reçu sur {msg.topic}: {msg.payload.decode()}") cursor = mydb.cursor() + frigo_name = msg.topic.split('/')[-1] - sql = "INSERT INTO Chaufferie (Sonde, Temperature) VALUES (%s, %s)" - val = (frigo_name, msg.payload.decode()) + temperature = float(msg.payload.decode()) + + sql = "INSERT INTO Chaufferie (Sonde, Temperature, Date) VALUES (%s, %s, %s)" + val = (frigo_name, temperature, datetime.now()) + cursor.execute(sql, val) mydb.commit() logging.info(f"Insertion réussie : {val}")