maj 29/7/25
This commit is contained in:
@@ -4,6 +4,7 @@ import sys
|
|||||||
import os
|
import os
|
||||||
import logging
|
import logging
|
||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
|
from datetime import datetime
|
||||||
|
|
||||||
# Charger les variables d'environnement
|
# Charger les variables d'environnement
|
||||||
load_dotenv()
|
load_dotenv()
|
||||||
@@ -46,9 +47,13 @@ def on_message(_client, _userdata, msg):
|
|||||||
try:
|
try:
|
||||||
logging.info(f"Message reçu sur {msg.topic}: {msg.payload.decode()}")
|
logging.info(f"Message reçu sur {msg.topic}: {msg.payload.decode()}")
|
||||||
cursor = mydb.cursor()
|
cursor = mydb.cursor()
|
||||||
|
|
||||||
frigo_name = msg.topic.split('/')[-1]
|
frigo_name = msg.topic.split('/')[-1]
|
||||||
sql = "INSERT INTO Chaufferie (Sonde, Temperature) VALUES (%s, %s)"
|
temperature = float(msg.payload.decode())
|
||||||
val = (frigo_name, msg.payload.decode())
|
|
||||||
|
sql = "INSERT INTO Chaufferie (Sonde, Temperature, Date) VALUES (%s, %s, %s)"
|
||||||
|
val = (frigo_name, temperature, datetime.now())
|
||||||
|
|
||||||
cursor.execute(sql, val)
|
cursor.execute(sql, val)
|
||||||
mydb.commit()
|
mydb.commit()
|
||||||
logging.info(f"Insertion réussie : {val}")
|
logging.info(f"Insertion réussie : {val}")
|
||||||
|
|||||||
Reference in New Issue
Block a user