Michel/Gestion_sondes
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Réparation des liens

Browse Source
This commit is contained in:
Michel
2025-07-26 15:01:54 +02:00
parent 81c680b412
commit 51bafc1b09
2 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
app/Monitor.py
View File

@@ -2,9 +2,9 @@ import os
import time import time
from datetime import datetime, timedelta from datetime import datetime, timedelta
from pathlib import Path from pathlib import Path
from app.utils_db import connect_to_mysql from utils_db import connect_to_mysql
from dotenv import load_dotenv from dotenv import load_dotenv
from app.utils_sms import envoyer_sms from utils_sms import envoyer_sms
if os.name != 'nt': if os.name != 'nt':
@@ -91,7 +91,7 @@ def surveiller():
f"depuis plus de 30 minutes.\nHeure : {maintenant.strftime('%Y-%m-%d %H:%M:%S')}" f"depuis plus de 30 minutes.\nHeure : {maintenant.strftime('%Y-%m-%d %H:%M:%S')}"
) )
if ENVOI_SMS: if ENVOI_SMS:
envoyer_sms(message, lieu) envoyer_sms(lieu, message)
alertes_actives[nom_sonde] = maintenant alertes_actives[nom_sonde] = maintenant
@@ -103,7 +103,7 @@ def surveiller():
f"Heure : {maintenant.strftime('%Y-%m-%d %H:%M:%S')}" f"Heure : {maintenant.strftime('%Y-%m-%d %H:%M:%S')}"
) )
if ENVOI_SMS: if ENVOI_SMS:
envoyer_sms(message, lieu) envoyer_sms(lieu, message)
alertes_actives[nom_sonde] = maintenant alertes_actives[nom_sonde] = maintenant
# Vérifier retour à la normale (Acquittement) # Vérifier retour à la normale (Acquittement)
@@ -131,10 +131,11 @@ def surveiller():
import pandas as pd import pandas as pd
df_logs = pd.DataFrame(log_entries) df_logs = pd.DataFrame(log_entries)
try:
df_logs.to_csv(log_dir / "monitor.csv", sep=";", index=False) df_logs.to_csv(log_dir / "monitor.csv", sep=";", index=False)
print(f"✅ Log écrit dans {log_dir}/monitor.csv", flush=True)
if os.name != 'nt': except Exception as e:
df_logs.to_csv("/var/log/monitor.csv", sep=";", index=False) print(f"❌ Erreur lors de l'écriture du fichier de log : {e}", flush=True)
except Exception as e: except Exception as e:
print(f"Erreur : {e}", flush=True) print(f"Erreur : {e}", flush=True)

2
app/mqtt_logger.py
View File

@@ -2,7 +2,7 @@ import argparse
import paho.mqtt.client as mqtt_client import paho.mqtt.client as mqtt_client
from dotenv import load_dotenv from dotenv import load_dotenv
import logging import logging
from app.logger_config import setup_logger from logger_config import setup_logger
from utils_db import connect_to_mysql from utils_db import connect_to_mysql
from functools import partial from functools import partial