diff --git a/app/Monitor.py b/app/Monitor.py index b153dd0..0b63310 100644 --- a/app/Monitor.py +++ b/app/Monitor.py @@ -2,9 +2,9 @@ import os import time from datetime import datetime, timedelta 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 app.utils_sms import envoyer_sms +from utils_sms import envoyer_sms 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')}" ) if ENVOI_SMS: - envoyer_sms(message, lieu) + envoyer_sms(lieu, message) alertes_actives[nom_sonde] = maintenant @@ -103,7 +103,7 @@ def surveiller(): f"Heure : {maintenant.strftime('%Y-%m-%d %H:%M:%S')}" ) if ENVOI_SMS: - envoyer_sms(message, lieu) + envoyer_sms(lieu, message) alertes_actives[nom_sonde] = maintenant # Vérifier retour à la normale (Acquittement) @@ -131,10 +131,11 @@ def surveiller(): import pandas as pd df_logs = pd.DataFrame(log_entries) - df_logs.to_csv(log_dir / "monitor.csv", sep=";", index=False) - - if os.name != 'nt': - df_logs.to_csv("/var/log/monitor.csv", sep=";", index=False) + try: + df_logs.to_csv(log_dir / "monitor.csv", sep=";", index=False) + print(f"✅ Log écrit dans {log_dir}/monitor.csv", flush=True) + except Exception as e: + print(f"❌ Erreur lors de l'écriture du fichier de log : {e}", flush=True) except Exception as e: print(f"Erreur : {e}", flush=True) diff --git a/app/mqtt_logger.py b/app/mqtt_logger.py index e01fa71..9ffb9de 100644 --- a/app/mqtt_logger.py +++ b/app/mqtt_logger.py @@ -2,7 +2,7 @@ import argparse import paho.mqtt.client as mqtt_client from dotenv import load_dotenv import logging -from app.logger_config import setup_logger +from logger_config import setup_logger from utils_db import connect_to_mysql from functools import partial