This commit is contained in:
2025-04-22 14:08:55 +02:00
parent f3aef233fd
commit d895c3fd91

View File

@@ -18,10 +18,12 @@ config = {
"database": os.getenv("DB_NAME") "database": os.getenv("DB_NAME")
} }
# --- Fonction de sélection des destinataires selon le site --- # --- Fonction de sélection des destinataires selon le site ---
def get_destinataires(lieu): def get_destinataires(lieu):
return os.getenv(f"EMAIL_{lieu.upper()}", os.getenv("EMAIL_DEFAULT")).split(",") return os.getenv(f"EMAIL_{lieu.upper()}", os.getenv("EMAIL_DEFAULT")).split(",")
# --- Fonction d'envoi de mail --- # --- Fonction d'envoi de mail ---
def envoyer_mail(sujet, message, destinataires): def envoyer_mail(sujet, message, destinataires):
msg = MIMEText(message) msg = MIMEText(message)
@@ -36,6 +38,7 @@ def envoyer_mail(sujet, message, destinataires):
except Exception as e: except Exception as e:
print(f"Erreur envoi mail : {e}", flush=True) print(f"Erreur envoi mail : {e}", flush=True)
# --- Fonction de surveillance --- # --- Fonction de surveillance ---
def surveiller(): def surveiller():
log_entries = [] log_entries = []
@@ -64,7 +67,6 @@ def surveiller():
""", (nom_sonde,)) """, (nom_sonde,))
relevés = cursor.fetchall() relevés = cursor.fetchall()
# Log CSV : tous les relevés analysés
for r in relevés: for r in relevés:
log_entries.append({ log_entries.append({
"Date": r['Date'], "Date": r['Date'],
@@ -124,9 +126,3 @@ def surveiller():
except Exception as e: except Exception as e:
print(f"Erreur : {e}", flush=True) print(f"Erreur : {e}", flush=True)
# --- Boucle principale ---
while True:
print(f"🛁 Vérification à {datetime.now()}", flush=True)
surveiller()
time.sleep(300) # 5 minutes