Restauration des fichiers de develop depuis sauvegarde Synology
This commit is contained in:
158
.idea/workspace.xml
generated
158
.idea/workspace.xml
generated
@@ -4,11 +4,8 @@
|
||||
<option name="autoReloadType" value="SELECTIVE" />
|
||||
</component>
|
||||
<component name="ChangeListManager">
|
||||
<list default="true" id="a12d9762-568e-4ace-91c1-148c598387a7" name="Changes" comment=""Ajout bt impression rapports et dossier PDF crée"">
|
||||
<change afterPath="$PROJECT_DIR$/tools/deploy_product.sh" afterDir="false" />
|
||||
<list default="true" id="a12d9762-568e-4ace-91c1-148c598387a7" name="Changes" comment=""Ajout entrées au fichier Gitignore"">
|
||||
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/Scripts/.deploy.sh" beforeDir="false" afterPath="$PROJECT_DIR$/Scripts/.deploy.sh" afterDir="false" />
|
||||
<change beforePath="$PROJECT_DIR$/domo91.py" beforeDir="false" afterPath="$PROJECT_DIR$/domo91.py" afterDir="false" />
|
||||
</list>
|
||||
<option name="SHOW_DIALOG" value="false" />
|
||||
<option name="HIGHLIGHT_CONFLICTS" value="true" />
|
||||
@@ -28,7 +25,7 @@
|
||||
<component name="Git.Settings">
|
||||
<option name="RECENT_BRANCH_BY_REPOSITORY">
|
||||
<map>
|
||||
<entry key="$PROJECT_DIR$" value="develop" />
|
||||
<entry key="$PROJECT_DIR$" value="f136d15975db2b292a408727f76b3fce1b3f1351" />
|
||||
</map>
|
||||
</option>
|
||||
<option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
|
||||
@@ -50,55 +47,55 @@
|
||||
<option name="showLibraryContents" value="true" />
|
||||
<option name="showScratchesAndConsoles" value="false" />
|
||||
</component>
|
||||
<component name="PropertiesComponent"><![CDATA[{
|
||||
"keyToString": {
|
||||
"Python.AlerteMonitoring.executor": "Run",
|
||||
"Python.Alerte_journalière.executor": "Run",
|
||||
"Python.AlertesSondesSaclay.executor": "Run",
|
||||
"Python.Alertes_Saclay.executor": "Run",
|
||||
"Python.Alertes_Telegram.executor": "Run",
|
||||
"Python.Alertes_saclay.executor": "Run",
|
||||
"Python.Alertes_telegram.executor": "Run",
|
||||
"Python.Base.executor": "Run",
|
||||
"Python.Base2.executor": "Run",
|
||||
"Python.Chat-Id.executor": "Run",
|
||||
"Python.Chaufferie.executor": "Run",
|
||||
"Python.Code_général.executor": "Run",
|
||||
"Python.Connexion_mysql.executor": "Run",
|
||||
"Python.Cuisine_meudon.executor": "Run",
|
||||
"Python.Cuisine_saclay.executor": "Run",
|
||||
"Python.Général.executor": "Run",
|
||||
"Python.Insertion_tables_Msql.executor": "Run",
|
||||
"Python.Lecture_tableau_frigos.executor": "Run",
|
||||
"Python.Monitor.executor": "Run",
|
||||
"Python.Saclay.executor": "Run",
|
||||
"Python.Saclay_buffer.executor": "Run",
|
||||
"Python.Sondes tracker.executor": "Run",
|
||||
"Python.Streamlit.executor": "Run",
|
||||
"Python.Streamlit_Saaclay.executor": "Run",
|
||||
"Python.Streamlit_Saclay.executor": "Run",
|
||||
"Python.Telegram_sondes.executor": "Run",
|
||||
"Python.Test Tables MYSQL.executor": "Run",
|
||||
"Python.Test Tables Sondes.executor": "Run",
|
||||
"Python.Test table Meudon.executor": "Run",
|
||||
"Python.Test table Saclay.executor": "Run",
|
||||
"Python.Test.executor": "Run",
|
||||
"Python.Test_mail.executor": "Run",
|
||||
"Python.Tracker.executor": "Run",
|
||||
"Python.Vérification Triggers.executor": "Run",
|
||||
"Python.Vérification_temperatures_alertes_mail.executor": "Run",
|
||||
"Python.domo91.executor": "Run",
|
||||
"Python.logs_analyses.executor": "Run",
|
||||
"Python.test.executor": "Run",
|
||||
"RunOnceActivity.ShowReadmeOnStart": "true",
|
||||
"RunOnceActivity.git.unshallow": "true",
|
||||
"git-widget-placeholder": "Merging product",
|
||||
"ignore.virus.scanning.warn.message": "true",
|
||||
"last_opened_file_path": "C:/Users/miche/PycharmProjects/Gestion sondes",
|
||||
"settings.editor.selected.configurable": "com.jetbrains.python.configuration.PyActiveSdkModuleConfigurable",
|
||||
"settings.editor.splitter.proportion": "0.28861153"
|
||||
<component name="PropertiesComponent">{
|
||||
"keyToString": {
|
||||
"Python.AlerteMonitoring.executor": "Run",
|
||||
"Python.Alerte_journalière.executor": "Run",
|
||||
"Python.AlertesSondesSaclay.executor": "Run",
|
||||
"Python.Alertes_Saclay.executor": "Run",
|
||||
"Python.Alertes_Telegram.executor": "Run",
|
||||
"Python.Alertes_saclay.executor": "Run",
|
||||
"Python.Alertes_telegram.executor": "Run",
|
||||
"Python.Base.executor": "Run",
|
||||
"Python.Base2.executor": "Run",
|
||||
"Python.Chat-Id.executor": "Run",
|
||||
"Python.Chaufferie.executor": "Run",
|
||||
"Python.Code_général.executor": "Run",
|
||||
"Python.Connexion_mysql.executor": "Run",
|
||||
"Python.Cuisine_meudon.executor": "Run",
|
||||
"Python.Cuisine_saclay.executor": "Run",
|
||||
"Python.Général.executor": "Run",
|
||||
"Python.Insertion_tables_Msql.executor": "Run",
|
||||
"Python.Lecture_tableau_frigos.executor": "Run",
|
||||
"Python.Monitor.executor": "Run",
|
||||
"Python.Saclay.executor": "Run",
|
||||
"Python.Saclay_buffer.executor": "Run",
|
||||
"Python.Sondes tracker.executor": "Run",
|
||||
"Python.Streamlit.executor": "Run",
|
||||
"Python.Streamlit_Saaclay.executor": "Run",
|
||||
"Python.Streamlit_Saclay.executor": "Run",
|
||||
"Python.Telegram_sondes.executor": "Run",
|
||||
"Python.Test Tables MYSQL.executor": "Run",
|
||||
"Python.Test Tables Sondes.executor": "Run",
|
||||
"Python.Test table Meudon.executor": "Run",
|
||||
"Python.Test table Saclay.executor": "Run",
|
||||
"Python.Test.executor": "Run",
|
||||
"Python.Test_mail.executor": "Run",
|
||||
"Python.Tracker.executor": "Run",
|
||||
"Python.Vérification Triggers.executor": "Run",
|
||||
"Python.Vérification_temperatures_alertes_mail.executor": "Run",
|
||||
"Python.domo91.executor": "Run",
|
||||
"Python.logs_analyses.executor": "Run",
|
||||
"Python.test.executor": "Run",
|
||||
"RunOnceActivity.ShowReadmeOnStart": "true",
|
||||
"RunOnceActivity.git.unshallow": "true",
|
||||
"git-widget-placeholder": "develop",
|
||||
"ignore.virus.scanning.warn.message": "true",
|
||||
"last_opened_file_path": "C:/Users/miche/PycharmProjects/Gestion sondes",
|
||||
"settings.editor.selected.configurable": "vcs.Git",
|
||||
"settings.editor.splitter.proportion": "0.28861153"
|
||||
}
|
||||
}]]></component>
|
||||
}</component>
|
||||
<component name="RecentsManager">
|
||||
<key name="CopyFile.RECENT_KEYS">
|
||||
<recent name="C:\Users\miche\PycharmProjects\Gestion sondes" />
|
||||
@@ -134,6 +131,10 @@
|
||||
<recent_temporary>
|
||||
<list>
|
||||
<item itemvalue="Python.domo91" />
|
||||
<item itemvalue="Python.domo91" />
|
||||
<item itemvalue="Python.domo91" />
|
||||
<item itemvalue="Python.domo91" />
|
||||
<item itemvalue="Python.domo91" />
|
||||
</list>
|
||||
</recent_temporary>
|
||||
</component>
|
||||
@@ -260,9 +261,55 @@
|
||||
<option name="project" value="LOCAL" />
|
||||
<updated>1744891048964</updated>
|
||||
</task>
|
||||
<option name="localTasksCounter" value="14" />
|
||||
<task id="LOCAL-00014" summary=""Ajout entrées au fichier Gitignore"">
|
||||
<option name="closed" value="true" />
|
||||
<created>1744951733528</created>
|
||||
<option name="number" value="00014" />
|
||||
<option name="presentableId" value="LOCAL-00014" />
|
||||
<option name="project" value="LOCAL" />
|
||||
<updated>1744951733528</updated>
|
||||
</task>
|
||||
<option name="localTasksCounter" value="15" />
|
||||
<servers />
|
||||
</component>
|
||||
<component name="Vcs.Log.Tabs.Properties">
|
||||
<option name="RECENT_FILTERS">
|
||||
<map>
|
||||
<entry key="Branch">
|
||||
<value>
|
||||
<list>
|
||||
<RecentGroup>
|
||||
<option name="FILTER_VALUES">
|
||||
<option value="develop" />
|
||||
</option>
|
||||
</RecentGroup>
|
||||
</list>
|
||||
</value>
|
||||
</entry>
|
||||
</map>
|
||||
</option>
|
||||
<option name="TAB_STATES">
|
||||
<map>
|
||||
<entry key="MAIN">
|
||||
<value>
|
||||
<State>
|
||||
<option name="FILTERS">
|
||||
<map>
|
||||
<entry key="branch">
|
||||
<value>
|
||||
<list>
|
||||
<option value="develop" />
|
||||
</list>
|
||||
</value>
|
||||
</entry>
|
||||
</map>
|
||||
</option>
|
||||
</State>
|
||||
</value>
|
||||
</entry>
|
||||
</map>
|
||||
</option>
|
||||
</component>
|
||||
<component name="VcsManagerConfiguration">
|
||||
<MESSAGE value="Ajout README Complet" />
|
||||
<MESSAGE value=".gitignore" />
|
||||
@@ -270,6 +317,7 @@
|
||||
<MESSAGE value="Base de données SG" />
|
||||
<MESSAGE value=""Injection données dans Tables Meudon et Roissy"" />
|
||||
<MESSAGE value=""Ajout bt impression rapports et dossier PDF crée"" />
|
||||
<option name="LAST_COMMIT_MESSAGE" value=""Ajout bt impression rapports et dossier PDF crée"" />
|
||||
<MESSAGE value=""Ajout entrées au fichier Gitignore"" />
|
||||
<option name="LAST_COMMIT_MESSAGE" value=""Ajout entrées au fichier Gitignore"" />
|
||||
</component>
|
||||
</project>
|
||||
36
Chat-Id.py
Normal file
36
Chat-Id.py
Normal file
@@ -0,0 +1,36 @@
|
||||
import requests
|
||||
import json
|
||||
|
||||
# Remplace par ton token de bot Telegram
|
||||
token = "8128378340:AAF2sO3gaH1XpMNya_pEslzerqokoCiFRGs"
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/getUpdates"
|
||||
|
||||
try:
|
||||
response = requests.get(url)
|
||||
data = response.json()
|
||||
|
||||
print("🔍 Récupération des chats Telegram récents...\n")
|
||||
|
||||
if "result" in data:
|
||||
chats = set()
|
||||
|
||||
for update in data["result"]:
|
||||
message = update.get("message") or update.get("edited_message")
|
||||
if not message:
|
||||
continue
|
||||
|
||||
chat = message["chat"]
|
||||
chat_id = chat["id"]
|
||||
chat_title = chat.get("title") or chat.get("username") or chat.get("first_name") or "Inconnu"
|
||||
|
||||
if chat_id not in chats:
|
||||
chats.add(chat_id)
|
||||
print(f"➡️ Chat : {chat_title} | ID : {chat_id}")
|
||||
|
||||
if not chats:
|
||||
print("⚠️ Aucun chat trouvé. Envoie un message depuis un groupe ou une discussion avec le bot.")
|
||||
else:
|
||||
print("❌ Erreur : aucune donnée 'result' trouvée dans la réponse.")
|
||||
except Exception as e:
|
||||
print(f"Erreur lors de la récupération des chats : {e}")
|
||||
30
Chaufferie.py
Normal file
30
Chaufferie.py
Normal file
@@ -0,0 +1,30 @@
|
||||
import paho.mqtt.client as mqtt
|
||||
import mysql.connector
|
||||
|
||||
# Configuration de la connexion MySQL
|
||||
mydb = mysql.connector.connect(
|
||||
host="54.36.188.119",
|
||||
user="michel",
|
||||
password="#SO2&1nf%mZ@jfh",
|
||||
database="Sondes"
|
||||
)
|
||||
|
||||
# Fonction de callback quand un message est reçu
|
||||
def on_message(_client, _userdata, msg):
|
||||
print(f"Message reçu sur {msg.topic}: {msg.payload.decode()}")
|
||||
cursor = mydb.cursor()
|
||||
frigo_name = msg.topic.split('/')[-1] # Prend la dernière partie après le "/"
|
||||
sql = "INSERT INTO Chaufferie (Sonde, Temperature) VALUES (%s, %s)"
|
||||
val = (frigo_name, msg.payload.decode())
|
||||
cursor.execute(sql, val)
|
||||
mydb.commit()
|
||||
|
||||
# Configuration du client MQTT
|
||||
client = mqtt.Client()
|
||||
client.username_pw_set("Bwps", "scJ5ACj2keRfI^")
|
||||
client.on_message = on_message
|
||||
|
||||
client.connect("54.36.188.119", 1883, 60)
|
||||
client.subscribe("Module_01/#") # S'abonner à tous les topics commençant par Saclay
|
||||
|
||||
client.loop_forever() # Rester connecté en continu pour écouter les messages
|
||||
36
Fichiers restaurés/Chat-Id.py
Normal file
36
Fichiers restaurés/Chat-Id.py
Normal file
@@ -0,0 +1,36 @@
|
||||
import requests
|
||||
import json
|
||||
|
||||
# Remplace par ton token de bot Telegram
|
||||
token = "8128378340:AAF2sO3gaH1XpMNya_pEslzerqokoCiFRGs"
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/getUpdates"
|
||||
|
||||
try:
|
||||
response = requests.get(url)
|
||||
data = response.json()
|
||||
|
||||
print("🔍 Récupération des chats Telegram récents...\n")
|
||||
|
||||
if "result" in data:
|
||||
chats = set()
|
||||
|
||||
for update in data["result"]:
|
||||
message = update.get("message") or update.get("edited_message")
|
||||
if not message:
|
||||
continue
|
||||
|
||||
chat = message["chat"]
|
||||
chat_id = chat["id"]
|
||||
chat_title = chat.get("title") or chat.get("username") or chat.get("first_name") or "Inconnu"
|
||||
|
||||
if chat_id not in chats:
|
||||
chats.add(chat_id)
|
||||
print(f"➡️ Chat : {chat_title} | ID : {chat_id}")
|
||||
|
||||
if not chats:
|
||||
print("⚠️ Aucun chat trouvé. Envoie un message depuis un groupe ou une discussion avec le bot.")
|
||||
else:
|
||||
print("❌ Erreur : aucune donnée 'result' trouvée dans la réponse.")
|
||||
except Exception as e:
|
||||
print(f"Erreur lors de la récupération des chats : {e}")
|
||||
30
Fichiers restaurés/Chaufferie.py
Normal file
30
Fichiers restaurés/Chaufferie.py
Normal file
@@ -0,0 +1,30 @@
|
||||
import paho.mqtt.client as mqtt
|
||||
import mysql.connector
|
||||
|
||||
# Configuration de la connexion MySQL
|
||||
mydb = mysql.connector.connect(
|
||||
host="54.36.188.119",
|
||||
user="michel",
|
||||
password="#SO2&1nf%mZ@jfh",
|
||||
database="Sondes"
|
||||
)
|
||||
|
||||
# Fonction de callback quand un message est reçu
|
||||
def on_message(_client, _userdata, msg):
|
||||
print(f"Message reçu sur {msg.topic}: {msg.payload.decode()}")
|
||||
cursor = mydb.cursor()
|
||||
frigo_name = msg.topic.split('/')[-1] # Prend la dernière partie après le "/"
|
||||
sql = "INSERT INTO Chaufferie (Sonde, Temperature) VALUES (%s, %s)"
|
||||
val = (frigo_name, msg.payload.decode())
|
||||
cursor.execute(sql, val)
|
||||
mydb.commit()
|
||||
|
||||
# Configuration du client MQTT
|
||||
client = mqtt.Client()
|
||||
client.username_pw_set("Bwps", "scJ5ACj2keRfI^")
|
||||
client.on_message = on_message
|
||||
|
||||
client.connect("54.36.188.119", 1883, 60)
|
||||
client.subscribe("Module_01/#") # S'abonner à tous les topics commençant par Saclay
|
||||
|
||||
client.loop_forever() # Rester connecté en continu pour écouter les messages
|
||||
18
Fichiers restaurés/Purge_Alertes_saclay.py
Normal file
18
Fichiers restaurés/Purge_Alertes_saclay.py
Normal file
@@ -0,0 +1,18 @@
|
||||
# Purge de la table Sondes.Alertes_Saclay.
|
||||
import mysql.connector
|
||||
|
||||
config = {
|
||||
"host": "54.36.188.119",
|
||||
"user": "michel",
|
||||
"password": "#SO2&1nf%mZ@jfh",
|
||||
"database": "Sondes"
|
||||
}
|
||||
|
||||
conn = mysql.connector.connect(**config)
|
||||
cursor = conn.cursor()
|
||||
cursor.execute("DELETE FROM Alertes_Saclay WHERE Debut_defaut < NOW() - INTERVAL 7 DAY")
|
||||
conn.commit()
|
||||
cursor.close()
|
||||
conn.close()
|
||||
|
||||
print("✅ Alertes de plus de 7 jours supprimées.")
|
||||
52
Fichiers restaurés/README.md
Normal file
52
Fichiers restaurés/README.md
Normal file
@@ -0,0 +1,52 @@
|
||||
# 🌡️ Gestion des sondes domotiques
|
||||
|
||||
[](https://python.org)
|
||||
[](https://mj91.fr:448/michel/Gestion_sondes)
|
||||
[](https://mj91.fr:448)
|
||||
|
||||
Application de **surveillance des températures** avec alertes, visualisation Streamlit, et déploiement automatisé via Gitea + Supervisor.
|
||||
|
||||
---
|
||||
|
||||
## 🧩 Fonctionnalités principales
|
||||
|
||||
- 🔍 Lecture de capteurs **DS18B20** et **DHT22**
|
||||
- 📨 Transmission via **MQTT**
|
||||
- 📊 Interface **Streamlit** (app.domo91.fr)
|
||||
- 🔔 Alertes **email / Telegram** si dépassement > 30 minutes
|
||||
- 🧠 Déploiement auto avec **`deploy.sh`**
|
||||
- 🧾 Stockage SQL sur **MySQL (VPS)**
|
||||
|
||||
---
|
||||
|
||||
## 📊 Exemple de visualisation
|
||||
|
||||
Voici un aperçu d’un graphique dans l’interface Streamlit :
|
||||
|
||||
|
||||
|
||||
---
|
||||
|
||||
## 🗂️ Structure du projet
|
||||
|
||||
| Fichier | Description |
|
||||
|-----------------------------|---------------------------------------------------------------------|
|
||||
| `Monitor.py` | Analyse de température et alertes |
|
||||
| `Streamlit.py` | Interface graphique web |
|
||||
| `Cuisine_saclay.py` | Script capteur pour le site de Saclay |
|
||||
| `Cuisine_meudon.py` | Script capteur pour Meudon |
|
||||
| `check_supervisor.py` | Vérifie l’état des scripts supervisés |
|
||||
| `deploy.sh` | Déploiement auto depuis Gitea (branche `product`) |
|
||||
| `requirements.txt` | Dépendances Python |
|
||||
|
||||
---
|
||||
|
||||
## 🧪 Installation locale
|
||||
|
||||
```bash
|
||||
git clone https://mj91.fr:448/michel/Gestion_sondes.git
|
||||
cd Gestion_sondes
|
||||
python -m venv .venv
|
||||
source .venv/bin/activate # Linux/macOS
|
||||
.venv\Scripts\activate # Windows
|
||||
pip install -r requirements.txt
|
||||
107
Fichiers restaurés/Societe_Generale.py
Normal file
107
Fichiers restaurés/Societe_Generale.py
Normal file
@@ -0,0 +1,107 @@
|
||||
# Insertion de données da l'app SG.
|
||||
import streamlit as st
|
||||
import mysql.connector
|
||||
from dotenv import load_dotenv
|
||||
import os
|
||||
from datetime import datetime
|
||||
|
||||
load_dotenv()
|
||||
|
||||
st.set_page_config(page_title="Insertion Mysql", layout="centered")
|
||||
st.title("🗓️ Insertion dans une base MySQL")
|
||||
|
||||
# Charger les identifiants
|
||||
DB_HOST = os.getenv("DB_HOST")
|
||||
DB_USER = os.getenv("DB_USER")
|
||||
DB_PASSWORD = os.getenv("DB_PASSWORD")
|
||||
|
||||
# Connexion sans DB initiale pour lister les bases
|
||||
@st.cache_data
|
||||
def get_databases():
|
||||
conn = mysql.connector.connect(
|
||||
host=DB_HOST,
|
||||
user=DB_USER,
|
||||
password=DB_PASSWORD
|
||||
)
|
||||
cursor = conn.cursor()
|
||||
cursor.execute("SHOW DATABASES")
|
||||
bases = [db[0] for db in cursor.fetchall()]
|
||||
conn.close()
|
||||
return bases
|
||||
|
||||
# Connexion avec DB sélectionnée
|
||||
def connect_to_db(db_name):
|
||||
return mysql.connector.connect(
|
||||
host=DB_HOST,
|
||||
user=DB_USER,
|
||||
password=DB_PASSWORD,
|
||||
database=db_name
|
||||
)
|
||||
|
||||
# --- Interface principale ---
|
||||
|
||||
base = st.selectbox("Choisir une base de données", get_databases())
|
||||
if base:
|
||||
conn = connect_to_db(base)
|
||||
cursor = conn.cursor()
|
||||
|
||||
cursor.execute("SHOW TABLES")
|
||||
tables = [table[0] for table in cursor.fetchall()]
|
||||
table = st.selectbox("Choisir une table", tables)
|
||||
|
||||
if table:
|
||||
cursor.execute(f"DESCRIBE {table}")
|
||||
colonnes = cursor.fetchall()
|
||||
|
||||
# Détection clé primaire
|
||||
cursor.execute(f"SHOW INDEX FROM {table} WHERE Key_name = 'PRIMARY'")
|
||||
pk = cursor.fetchone()
|
||||
primary_key = pk[4] if pk else None
|
||||
|
||||
champ_date_candidates = [col[0] for col in colonnes if "date" in col[1].lower()]
|
||||
champ_date = st.selectbox("Champ de date", champ_date_candidates)
|
||||
|
||||
nb_mois = st.number_input("Nombre d'insertions mensuelles", 1, 36, 6)
|
||||
date_depart = st.date_input("Date de départ des insertions", value=datetime.today().date())
|
||||
st.subheader("Champs à insérer (hors clé primaire et champ de date)")
|
||||
champs_choisis = []
|
||||
champs_editables = [col for col in colonnes if col[0] != primary_key and col[0] != champ_date]
|
||||
for col in champs_editables:
|
||||
if st.checkbox(f"{col[0]} ({col[1]})", value=True):
|
||||
champs_choisis.append(col[0])
|
||||
|
||||
with st.form("formulaire_insertion"):
|
||||
st.markdown("**Valeurs fixes pour les champs cochés**")
|
||||
valeurs_fixes = {}
|
||||
for nom in champs_choisis:
|
||||
val = st.text_input(nom)
|
||||
valeurs_fixes[nom] = val if val != "" else None
|
||||
|
||||
submit = st.form_submit_button("Insérer")
|
||||
|
||||
try:
|
||||
cursor = conn.cursor()
|
||||
insert_count = 0
|
||||
|
||||
for i in range(nb_mois):
|
||||
year = date_depart.year + (date_depart.month + i - 1) // 12
|
||||
month = (date_depart.month + i - 1) % 12 + 1
|
||||
day = min(date_depart.day, 28)
|
||||
date_cible = datetime(year, month, day).date()
|
||||
|
||||
champs = [champ_date] + list(valeurs_fixes.keys())
|
||||
valeurs = [date_cible] + list(valeurs_fixes.values())
|
||||
sql = f"INSERT INTO {table} ({', '.join(champs)}) VALUES ({', '.join(['%s'] * len(valeurs))})"
|
||||
|
||||
cursor.execute(sql, valeurs)
|
||||
insert_count += 1
|
||||
|
||||
conn.commit()
|
||||
st.success(f"{insert_count} lignes insérées avec succès dans `{table}`.")
|
||||
|
||||
except Exception as e:
|
||||
st.error(f"❌ Erreur lors de l’insertion : {e}")
|
||||
|
||||
conn.commit()
|
||||
st.success(f"{insert_count} lignes insérées avec succès dans `{table}`.")
|
||||
st.success(f"{insert_count} lignes insérées avec succès.")
|
||||
324
Fichiers restaurés/Telegram_sondes.py
Normal file
324
Fichiers restaurés/Telegram_sondes.py
Normal file
@@ -0,0 +1,324 @@
|
||||
# Gestion des chambres froides & alertes Telegram
|
||||
import requests
|
||||
import mysql.connector
|
||||
from datetime import datetime, timedelta
|
||||
import time
|
||||
import sys
|
||||
import os
|
||||
import schedule
|
||||
|
||||
def connect_db():
|
||||
return mysql.connector.connect(
|
||||
host="54.36.188.119",
|
||||
user="michel",
|
||||
password="#SO2&1nf%mZ@jfh",
|
||||
database="Sondes"
|
||||
)
|
||||
|
||||
def envoi_etat_quotidien(cursor, site):
|
||||
token = "8128378340:AAF2sO3gaH1XpMNya_pEslzerqokoCiFRGs"
|
||||
chat_id = get_chat_id(cursor, site)
|
||||
etat_sondes(cursor, site, chat_id, token)
|
||||
print(f"[INFO] État des sondes envoyé pour le site {site}.")
|
||||
|
||||
def get_active_sondes(cursor, site):
|
||||
query = "SELECT Sonde, Temp_Max FROM Chambres_froides WHERE Lieu = %s AND Etat = 'On';"
|
||||
cursor.execute(query, (site,))
|
||||
result = cursor.fetchall()
|
||||
return {row[0]: float(row[1]) for row in result}
|
||||
|
||||
|
||||
def check_temperature_limits(cursor, table_historique, sonde, limite, duree=30):
|
||||
temps_limite = datetime.now() - timedelta(minutes=duree)
|
||||
query = f"""
|
||||
SELECT Temperature
|
||||
FROM {table_historique}
|
||||
WHERE Sonde = %s AND Date >= %s
|
||||
ORDER BY Date DESC LIMIT 6;
|
||||
"""
|
||||
cursor.execute(query, (sonde, temps_limite))
|
||||
result = cursor.fetchall()
|
||||
if len(result) == 6 and all(float(temp[0]) > limite for temp in result):
|
||||
return True, float(result[0][0])
|
||||
return False, None
|
||||
|
||||
def simulate_alert(db, cursor, site, sonde, chat_id, token):
|
||||
table_alertes = f"Alertes_{site}"
|
||||
print(f"[TEST] tentative d'insertion de sonde : {sonde} dans table {table_alertes}")
|
||||
|
||||
try:
|
||||
query = f"""
|
||||
INSERT INTO {table_alertes} (Sonde, Debut_defaut, Status)
|
||||
VALUES (%s, NOW(), 'test')
|
||||
ON DUPLICATE KEY UPDATE Debut_defaut = NOW(), Status = 'test';
|
||||
"""
|
||||
cursor.execute(query, (sonde,))
|
||||
db.commit()
|
||||
print(f"[TEST] insertion ou mise à jour réussie pour {sonde}.")
|
||||
except Exception as e:
|
||||
print(f"[ERREUR] lors de l'insertion test : {e}")
|
||||
|
||||
message = f"⚠️ TEST ALERTE : Simulation d'une alerte pour la sonde {sonde}."
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
try:
|
||||
requests.get(url, params={'chat_id': chat_id, 'text': message})
|
||||
except Exception as e:
|
||||
print(f"[ERREUR] lors de l'envoi Telegram : {e}")
|
||||
|
||||
def create_alert(db, cursor, table_alertes, sonde, temperature):
|
||||
query = f"""
|
||||
INSERT INTO {table_alertes} (Sonde, Debut_defaut, Status)
|
||||
VALUES (%s, NOW(), 'en cours');
|
||||
"""
|
||||
cursor.execute(query, (sonde,))
|
||||
send_telegram_message(sonde, temperature)
|
||||
print(f"Alerte créée pour la sonde {sonde}")
|
||||
db.commit()
|
||||
|
||||
def resolve_alert(cursor, table_alertes, sonde):
|
||||
query = f"""
|
||||
UPDATE {table_alertes}
|
||||
SET Status = 'résolu'
|
||||
WHERE Sonde = %s AND Status = 'en cours';
|
||||
"""
|
||||
cursor.execute(query, (sonde,))
|
||||
print(f"Alerte résolue pour la sonde {sonde}")
|
||||
|
||||
def acquitter_alerte(cursor, site, sonde, chat_id, token):
|
||||
table_alertes = f"Alertes_{site}"
|
||||
query = f"""
|
||||
UPDATE {table_alertes}
|
||||
SET Status = 'acquittée'
|
||||
WHERE Sonde = %s AND Status IN ('en cours', 'test');
|
||||
"""
|
||||
cursor.execute(query, (sonde,))
|
||||
lignes_modifiees = cursor.rowcount
|
||||
|
||||
if lignes_modifiees > 0:
|
||||
message = f"✅ Alerte acquittée pour la sonde {sonde} par commande Telegram."
|
||||
else:
|
||||
message = f"ℹ️ Aucune alerte active à acquitter pour la sonde {sonde}."
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
try:
|
||||
requests.get(url, params={'chat_id': chat_id, 'text': message})
|
||||
except Exception as e:
|
||||
print(f"[ERREUR] envoi message Telegram : {e}")
|
||||
|
||||
def send_telegram_message(sonde, temperature):
|
||||
token = "5714323406:AAGSj9jrfBHbfxubz3ooabPEizI8aBOLnvE"
|
||||
chat_id = "-1002442631825"
|
||||
message = f"⚠️ Alerte température : La sonde {sonde} dépasse la limite avec une température de {temperature}°C."
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
params = {'chat_id': chat_id, 'text': message}
|
||||
try:
|
||||
response = requests.get(url, params=params)
|
||||
if response.status_code == 200:
|
||||
print(f"Message envoyé via Telegram pour la sonde {sonde}.")
|
||||
else:
|
||||
print(f"Erreur lors de l'envoi du message Telegram : {response.status_code}")
|
||||
except Exception as e:
|
||||
print(f"Erreur lors de l'envoi du message Telegram : {e}")
|
||||
|
||||
|
||||
def get_chat_id(cursor, site):
|
||||
cursor.execute("SELECT Chat_ID FROM Sites WHERE Nom = %s;", (site,))
|
||||
result = cursor.fetchone()
|
||||
if result:
|
||||
return result[0]
|
||||
else:
|
||||
print(f"Aucun Chat_ID trouvé pour le site {site}")
|
||||
return None
|
||||
|
||||
def passer_en_maintenance(cursor, site, sonde, chat_id, token):
|
||||
try:
|
||||
query = """
|
||||
UPDATE Chambres_froides
|
||||
SET Etat = 'Off'
|
||||
WHERE Lieu = %s AND Sonde = %s;
|
||||
"""
|
||||
cursor.execute(query, (site, sonde))
|
||||
lignes_modifiees = cursor.rowcount
|
||||
|
||||
if lignes_modifiees > 0:
|
||||
message = f"🛠️ La sonde {sonde} a été passée en mode maintenance (OFF)."
|
||||
else:
|
||||
message = f"⚠️ Sonde {sonde} introuvable pour le site {site}."
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
requests.get(url, params={'chat_id': chat_id, 'text': message})
|
||||
|
||||
except Exception as e:
|
||||
print(f"[ERREUR] lors du passage en maintenance : {e}")
|
||||
|
||||
def reactiver_sonde(cursor, site, sonde, chat_id, token):
|
||||
try:
|
||||
query = """
|
||||
UPDATE Chambres_froides
|
||||
SET Etat = 'On'
|
||||
WHERE Lieu = %s AND Sonde = %s;
|
||||
"""
|
||||
cursor.execute(query, (site, sonde))
|
||||
lignes_modifiees = cursor.rowcount
|
||||
|
||||
if lignes_modifiees > 0:
|
||||
message = f"✅ La sonde {sonde} a été réactivée (ON)."
|
||||
else:
|
||||
message = f"⚠️ Sonde {sonde} introuvable pour le site {site}."
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
requests.get(url, params={'chat_id': chat_id, 'text': message})
|
||||
|
||||
except Exception as e:
|
||||
print(f"[ERREUR] lors de la réactivation : {e}")
|
||||
|
||||
def etat_sondes(cursor, site, chat_id, token):
|
||||
query = "SELECT Sonde, Etat FROM Chambres_froides WHERE Lieu = %s ORDER BY Sonde;"
|
||||
cursor.execute(query, (site,))
|
||||
result = cursor.fetchall()
|
||||
|
||||
message = f"📊 État des sondes - {site} :\n"
|
||||
for sonde, etat in result:
|
||||
symbole = "🟢" if etat.upper() == "ON" else "🔴"
|
||||
message += f"{symbole} {sonde} ({etat.upper()})\n"
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
requests.get(url, params={'chat_id': chat_id, 'text': message})
|
||||
|
||||
def monitor_temperatures_simple(site, db, cursor):
|
||||
table_historique = site
|
||||
table_alertes = f"Alertes_{site}"
|
||||
sondes = get_active_sondes(cursor, site)
|
||||
print(f"[MONITORING] Sondes actives pour {site} : {sondes}")
|
||||
|
||||
for sonde, limite in sondes.items():
|
||||
alert_needed, temperature = check_temperature_limits(cursor, table_historique, sonde, limite)
|
||||
if alert_needed:
|
||||
create_alert(db, cursor, table_alertes, sonde, temperature)
|
||||
else:
|
||||
resolve_alert(cursor, table_alertes, sonde)
|
||||
|
||||
db.commit()
|
||||
print("[MONITORING] Vérification des sondes terminée.")
|
||||
|
||||
def monitor_temperatures(site):
|
||||
db = connect_db()
|
||||
cursor = db.cursor()
|
||||
|
||||
table_historique = site # Ex: Saclay
|
||||
table_alertes = f"Alertes_{site}" # Ex: Alertes_Saclay
|
||||
|
||||
sondes = get_active_sondes(cursor, site)
|
||||
print(f"Sondes actives pour le site {site} :", sondes)
|
||||
|
||||
for sonde, limite in sondes.items():
|
||||
alert_needed, temperature = check_temperature_limits(cursor, table_historique, sonde, limite)
|
||||
if alert_needed:
|
||||
create_alert(db, cursor, table_alertes, sonde, temperature)
|
||||
else:
|
||||
resolve_alert(cursor, table_alertes, sonde)
|
||||
|
||||
db.commit()
|
||||
listen_for_commands(db, cursor, site)
|
||||
cursor.close()
|
||||
db.close()
|
||||
|
||||
def listen_for_commands(db, cursor, site):
|
||||
token = "5714323406:AAGSj9jrfBHbfxubz3ooabPEizI8aBOLnvE"
|
||||
chat_id = get_chat_id(cursor, site)
|
||||
offset_file = os.path.join(os.path.dirname(__file__), f"last_update_id_{site}.txt")
|
||||
|
||||
try:
|
||||
with open(offset_file, 'r') as f:
|
||||
last_update_id = int(f.read().strip())
|
||||
except FileNotFoundError:
|
||||
last_update_id = None
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/getUpdates"
|
||||
if last_update_id is not None:
|
||||
url += f"?offset={last_update_id + 1}"
|
||||
|
||||
try:
|
||||
response = requests.get(url)
|
||||
data = response.json()
|
||||
|
||||
if "result" in data:
|
||||
for update in data["result"]:
|
||||
update_id = update["update_id"]
|
||||
|
||||
if "message" in update:
|
||||
message = update["message"]["text"]
|
||||
print(f"[CMD] Message reçu : {message}")
|
||||
|
||||
if message.lower().startswith("/etat"):
|
||||
etat_sondes(cursor, site, chat_id, token)
|
||||
|
||||
elif message.lower().startswith("/acquitter"):
|
||||
parts = message.strip().split(" ", 1)
|
||||
if len(parts) == 2 and parts[1].strip():
|
||||
sonde = parts[1].strip()
|
||||
acquitter_alerte(cursor, site, sonde, chat_id, token)
|
||||
db.commit()
|
||||
else:
|
||||
erreur_msg = "❌ Utilisation incorrecte. Format attendu : /acquitter <nom_sonde>"
|
||||
requests.get(f"https://api.telegram.org/bot{token}/sendMessage",
|
||||
params={'chat_id': chat_id, 'text': erreur_msg})
|
||||
elif message.lower().startswith("/maintenance"):
|
||||
parts = message.strip().split(" ", 1)
|
||||
if len(parts) == 2 and parts[1].strip():
|
||||
sonde = parts[1].strip()
|
||||
passer_en_maintenance(cursor, site, sonde, chat_id, token)
|
||||
db.commit()
|
||||
else:
|
||||
erreur_msg = "❌ Utilisation incorrecte. Format attendu : /maintenance <nom_sonde>"
|
||||
requests.get(f"https://api.telegram.org/bot{token}/sendMessage",
|
||||
params={'chat_id': chat_id, 'text': erreur_msg})
|
||||
elif message.lower().startswith("/reactiver"):
|
||||
parts = message.strip().split(" ", 1)
|
||||
if len(parts) == 2 and parts[1].strip():
|
||||
sonde = parts[1].strip()
|
||||
reactiver_sonde(cursor, site, sonde, chat_id, token)
|
||||
db.commit()
|
||||
else:
|
||||
erreur_msg = "❌ Utilisation incorrecte. Format attendu : /reactiver <nom_sonde>"
|
||||
requests.get(f"https://api.telegram.org/bot{token}/sendMessage",
|
||||
params={'chat_id': chat_id, 'text': erreur_msg})
|
||||
elif message.lower().startswith("/test"):
|
||||
parts = message.strip().split(" ", 1)
|
||||
if len(parts) == 2 and parts[1].strip():
|
||||
sonde = parts[1].strip()
|
||||
simulate_alert(db, cursor, site, sonde, chat_id, token)
|
||||
else:
|
||||
erreur_msg = "❌ Utilisation incorrecte. Format attendu : /test <nom_sonde>"
|
||||
requests.get(f"https://api.telegram.org/bot{token}/sendMessage",
|
||||
params={'chat_id': chat_id, 'text': erreur_msg})
|
||||
|
||||
with open(offset_file, 'w') as f:
|
||||
f.write(str(update_id))
|
||||
|
||||
except Exception as e:
|
||||
print(f"Erreur lors de la lecture des commandes Telegram : {e}")
|
||||
|
||||
|
||||
def main():
|
||||
site = sys.argv[1] if len(sys.argv) > 1 else "Saclay"
|
||||
db = connect_db()
|
||||
cursor = db.cursor()
|
||||
|
||||
# ✅ Planification : tous les jours à 07:00 → état des sondes
|
||||
schedule.every().day.at("07:00").do(envoi_etat_quotidien, cursor=cursor, site=site)
|
||||
|
||||
# ✅ Planification : toutes les 2m30 → surveillance
|
||||
schedule.every(2).minutes.do(monitor_temperatures_simple, site=site, db=db, cursor=cursor)
|
||||
|
||||
try:
|
||||
while True:
|
||||
schedule.run_pending()
|
||||
listen_for_commands(db, cursor, site)
|
||||
time.sleep(2) # petite pause pour ne pas surcharger Telegram
|
||||
finally:
|
||||
cursor.close()
|
||||
db.close()
|
||||
|
||||
if __name__ == "__main__":
|
||||
main()
|
||||
24
Fichiers restaurés/Test_mail.py
Normal file
24
Fichiers restaurés/Test_mail.py
Normal file
@@ -0,0 +1,24 @@
|
||||
# Programme de test de la BAL alertes_saclay@domo91.fr.
|
||||
import smtplib
|
||||
from email.mime.text import MIMEText
|
||||
|
||||
def envoyer_mail(sujet, message, destinataires):
|
||||
msg = MIMEText(message)
|
||||
msg['Subject'] = sujet
|
||||
msg['From'] = 'alertes_saclay@domo91.fr'
|
||||
msg['To'] = ', '.join(destinataires)
|
||||
|
||||
try:
|
||||
with smtplib.SMTP_SSL('smtp.mail.ovh.net', 465) as server:
|
||||
server.login('alertes_saclay@domo91.fr', 'Kdpke674y23Feq^H')
|
||||
server.sendmail(msg['From'], destinataires, msg.as_string())
|
||||
print(f"📧 Mail envoyé à {destinataires}")
|
||||
except Exception as e:
|
||||
print(f"Erreur envoi mail : {e}")
|
||||
|
||||
# --- Test d'envoi ---
|
||||
envoyer_mail(
|
||||
sujet="🧪 Test d'envoi d'alerte",
|
||||
message="Ceci est un test de l'envoi d'e-mail via alertes_saclay@domo91.fr.",
|
||||
destinataires=["services@domo91.fr"]
|
||||
)
|
||||
106
Fichiers restaurés/Tracker.py
Normal file
106
Fichiers restaurés/Tracker.py
Normal file
@@ -0,0 +1,106 @@
|
||||
# Programme de récupération des adresses de sondes DS18B20 et envoie dans table Sondes.Tracker.
|
||||
import paho.mqtt.client as mqtt
|
||||
import mysql.connector
|
||||
import re # Import de la bibliothèque des expressions régulières
|
||||
|
||||
# Configuration de la base de données MySQL
|
||||
db_config = {
|
||||
'user': 'superviseur', # Remplacez par votre utilisateur MySQL
|
||||
'password': 'Bto7Lm_z]m!BFH!*', # Remplacez par votre mot de passe MySQL
|
||||
'host': '54.36.188.119', # Adresse de votre serveur MySQL (localhost si en local)
|
||||
'database': 'Sondes' # Nom de la base de données MySQL
|
||||
}
|
||||
|
||||
|
||||
def convertir_rom_id_en_hexa(rom_id):
|
||||
# On découpe la chaîne rom_id en paires de deux caractères
|
||||
hex_parts = [f"0x{rom_id[i:i + 2]}" for i in range(0, len(rom_id), 2)]
|
||||
return ",".join(hex_parts)
|
||||
|
||||
|
||||
# Connexion à la base de données MySQL
|
||||
def connect_db():
|
||||
return mysql.connector.connect(**db_config)
|
||||
|
||||
|
||||
# Fonction pour vérifier si la sonde est déjà présente dans la base
|
||||
def sonde_deja_presente(rom_id):
|
||||
conn = connect_db()
|
||||
cursor = conn.cursor()
|
||||
try:
|
||||
# Vérifier si la sonde existe déjà dans la base
|
||||
cursor.execute("SELECT COUNT(*) FROM Tracker WHERE rom_id = %s", (rom_id,))
|
||||
result = cursor.fetchone()
|
||||
return result[0] > 0 # Si le nombre est supérieur à 0, la sonde est déjà présente
|
||||
|
||||
except mysql.connector.Error as err:
|
||||
print(f"Erreur MySQL lors de la vérification de la sonde : {err}")
|
||||
return False
|
||||
|
||||
finally:
|
||||
cursor.close()
|
||||
conn.close()
|
||||
|
||||
|
||||
# Fonction pour insérer les sondes dans la base de données
|
||||
def inserer_sonde(rom_id):
|
||||
if sonde_deja_presente(rom_id):
|
||||
print(f"Sonde {rom_id} déjà présente dans la base de données. Aucune insertion effectuée.")
|
||||
return
|
||||
|
||||
conn = connect_db()
|
||||
cursor = conn.cursor()
|
||||
try:
|
||||
# Conversion en hexadécimal
|
||||
rom_id_hexa = convertir_rom_id_en_hexa(rom_id)
|
||||
|
||||
# Insertion de rom_id et de sa version hexa dans la base
|
||||
cursor.execute("INSERT INTO Tracker (rom_id, hexa) VALUES (%s, %s)", (rom_id, rom_id_hexa))
|
||||
conn.commit()
|
||||
print(f"Sonde {rom_id} insérée dans la base de données avec son format hexa {rom_id_hexa}.")
|
||||
|
||||
except mysql.connector.Error as err:
|
||||
print(f"Erreur MySQL : {err}")
|
||||
|
||||
finally:
|
||||
cursor.close()
|
||||
conn.close()
|
||||
|
||||
|
||||
# Fonction de callback pour gérer les messages MQTT
|
||||
def on_message(_client, _userdata, message):
|
||||
payload = message.payload.decode()
|
||||
print(f"Message reçu : {payload}")
|
||||
|
||||
# Utilisation de re pour extraire les ROM IDs (Sonde [rom_id])
|
||||
rom_ids = re.findall(r"[0-9a-fA-F]{16}", payload) # Capturer les IDs de 16 caractères
|
||||
if rom_ids:
|
||||
for rom_id in rom_ids:
|
||||
inserer_sonde(rom_id)
|
||||
else:
|
||||
print("Aucun ROM ID trouvé dans le message.")
|
||||
|
||||
|
||||
# Configuration du client MQTT
|
||||
mqtt_broker = "46.105.92.116"
|
||||
mqtt_port = 1883 # Vérifiez si votre broker utilise un autre port
|
||||
mqtt_user = "Bwps"
|
||||
mqtt_password = "scJ5ACj2keRfI^"
|
||||
mqtt_topic = "Tracker/sondes"
|
||||
|
||||
client = mqtt.Client()
|
||||
|
||||
# Authentification MQTT
|
||||
client.username_pw_set(mqtt_user, mqtt_password)
|
||||
|
||||
# Configuration du callback pour les messages MQTT
|
||||
client.on_message = on_message
|
||||
|
||||
# Connexion au broker MQTT
|
||||
client.connect(mqtt_broker, mqtt_port, 60)
|
||||
|
||||
# Souscription au topic Tracker/sondes
|
||||
client.subscribe(mqtt_topic)
|
||||
|
||||
# Démarrer la boucle MQTT
|
||||
client.loop_forever()
|
||||
39
Fichiers restaurés/logs_analyse.py
Normal file
39
Fichiers restaurés/logs_analyse.py
Normal file
@@ -0,0 +1,39 @@
|
||||
import streamlit as st
|
||||
import pandas as pd
|
||||
import matplotlib.pyplot as plt
|
||||
|
||||
# --- Chargement des données ---
|
||||
try:
|
||||
df = pd.read_csv("/home/debian/travail/logs_monitor.csv", sep=";", parse_dates=["Date"])
|
||||
except FileNotFoundError:
|
||||
st.error("📂 Le fichier de log n'a pas été trouvé.")
|
||||
st.stop()
|
||||
|
||||
st.title("🧾 Analyse des scans Monitor.py")
|
||||
|
||||
# --- Filtres ---
|
||||
df["Date_str"] = df["Date"].dt.date
|
||||
dates_dispo = sorted(df["Date_str"].unique(), reverse=True)
|
||||
date_selection = st.selectbox("📅 Sélectionnez une date :", dates_dispo)
|
||||
|
||||
lieux = sorted(df["Lieu"].unique())
|
||||
lieu_selection = st.selectbox("📍 Site :", lieux)
|
||||
|
||||
df_filtré = df[(df["Date_str"] == date_selection) & (df["Lieu"] == lieu_selection)]
|
||||
|
||||
sondes = sorted(df_filtré["Sonde"].unique())
|
||||
sonde_selection = st.selectbox("🧪 Sonde :", sondes)
|
||||
|
||||
df_sonde = df_filtré[df_filtré["Sonde"] == sonde_selection]
|
||||
|
||||
# --- Graphique température ---
|
||||
fig, ax = plt.subplots(figsize=(10, 4))
|
||||
ax.plot(df_sonde["Date"], df_sonde["Température"], marker='o')
|
||||
ax.set_title(f"Évolution de la température - {sonde_selection}")
|
||||
ax.set_xlabel("Heure")
|
||||
ax.set_ylabel("Température (°C)")
|
||||
st.pyplot(fig)
|
||||
|
||||
# --- Tableau complet du jour/sonde sélectionnés ---
|
||||
st.markdown("### 📋 Détail des scans")
|
||||
st.dataframe(df_sonde[["Date", "Sonde", "Température", "Seuil", "État"]], use_container_width=True)
|
||||
47
Fichiers restaurés/supervisor_watchdog.py
Normal file
47
Fichiers restaurés/supervisor_watchdog.py
Normal file
@@ -0,0 +1,47 @@
|
||||
# Controle des services supervisor envoi en cas de disfonction et tous les jours à sept heures
|
||||
# a faire tourner avec crontb -e en sudo
|
||||
# */30 * * * * /home/debian/travail/myenv/bin/python3 /home/debian/travail/Scripts/supervisor_watchdog.py
|
||||
import subprocess
|
||||
import smtplib
|
||||
from email.mime.text import MIMEText
|
||||
from datetime import datetime
|
||||
|
||||
heure_actuelle = datetime.now().strftime("%H:%M")
|
||||
etat_services = []
|
||||
anomalies = []
|
||||
|
||||
try:
|
||||
output = subprocess.check_output("/usr/bin/supervisorctl status", shell=True, text=True)
|
||||
for line in output.splitlines():
|
||||
parts = line.split()
|
||||
if len(parts) >= 2:
|
||||
nom, statut = parts[0], parts[1]
|
||||
etat_services.append(f"{nom} ➤ {statut}")
|
||||
if statut != "RUNNING":
|
||||
anomalies.append(f"{nom} ➤ {statut}")
|
||||
except Exception as e:
|
||||
etat_services.append("❌ Impossible d'exécuter supervisorctl")
|
||||
anomalies.append(f"Erreur : {e}")
|
||||
|
||||
# Déclenchement mail si anomalie ou à 07:00
|
||||
envoyer_mail = bool(anomalies) or heure_actuelle == "07:00"
|
||||
|
||||
if envoyer_mail:
|
||||
sujet = "⚠️ Alerte Supervisor" if anomalies else "✅ Rapport quotidien Supervisor"
|
||||
intro = "🛑 Les services suivants ne sont pas en RUNNING :" if anomalies else "✅ Tous les services supervisés sont en RUNNING."
|
||||
contenu = f"{intro}\n\n" + "\n".join(etat_services)
|
||||
|
||||
msg = MIMEText(contenu)
|
||||
msg["Subject"] = sujet
|
||||
msg["From"] = "alertes_saclay@domo91.fr"
|
||||
msg["To"] = "services@domo91.fr"
|
||||
|
||||
try:
|
||||
with smtplib.SMTP_SSL("smtp.mail.ovh.net", 465) as server:
|
||||
server.login("alertes_saclay@domo91.fr", "Kdpke674y23Feq^H")
|
||||
server.sendmail(msg["From"], [msg["To"]], msg.as_string())
|
||||
print("📧 Mail envoyé.")
|
||||
except Exception as e:
|
||||
print(f"Erreur envoi mail : {e}")
|
||||
else:
|
||||
print("🕖 Aucun mail envoyé (tout est OK et ce n’est pas l’heure du rapport).")
|
||||
18
Purge_Alertes_saclay.py
Normal file
18
Purge_Alertes_saclay.py
Normal file
@@ -0,0 +1,18 @@
|
||||
# Purge de la table Sondes.Alertes_Saclay.
|
||||
import mysql.connector
|
||||
|
||||
config = {
|
||||
"host": "54.36.188.119",
|
||||
"user": "michel",
|
||||
"password": "#SO2&1nf%mZ@jfh",
|
||||
"database": "Sondes"
|
||||
}
|
||||
|
||||
conn = mysql.connector.connect(**config)
|
||||
cursor = conn.cursor()
|
||||
cursor.execute("DELETE FROM Alertes_Saclay WHERE Debut_defaut < NOW() - INTERVAL 7 DAY")
|
||||
conn.commit()
|
||||
cursor.close()
|
||||
conn.close()
|
||||
|
||||
print("✅ Alertes de plus de 7 jours supprimées.")
|
||||
52
README.md
Normal file
52
README.md
Normal file
@@ -0,0 +1,52 @@
|
||||
# 🌡️ Gestion des sondes domotiques
|
||||
|
||||
[](https://python.org)
|
||||
[](https://mj91.fr:448/michel/Gestion_sondes)
|
||||
[](https://mj91.fr:448)
|
||||
|
||||
Application de **surveillance des températures** avec alertes, visualisation Streamlit, et déploiement automatisé via Gitea + Supervisor.
|
||||
|
||||
---
|
||||
|
||||
## 🧩 Fonctionnalités principales
|
||||
|
||||
- 🔍 Lecture de capteurs **DS18B20** et **DHT22**
|
||||
- 📨 Transmission via **MQTT**
|
||||
- 📊 Interface **Streamlit** (app.domo91.fr)
|
||||
- 🔔 Alertes **email / Telegram** si dépassement > 30 minutes
|
||||
- 🧠 Déploiement auto avec **`deploy.sh`**
|
||||
- 🧾 Stockage SQL sur **MySQL (VPS)**
|
||||
|
||||
---
|
||||
|
||||
## 📊 Exemple de visualisation
|
||||
|
||||
Voici un aperçu d’un graphique dans l’interface Streamlit :
|
||||
|
||||
|
||||
|
||||
---
|
||||
|
||||
## 🗂️ Structure du projet
|
||||
|
||||
| Fichier | Description |
|
||||
|-----------------------------|---------------------------------------------------------------------|
|
||||
| `Monitor.py` | Analyse de température et alertes |
|
||||
| `Streamlit.py` | Interface graphique web |
|
||||
| `Cuisine_saclay.py` | Script capteur pour le site de Saclay |
|
||||
| `Cuisine_meudon.py` | Script capteur pour Meudon |
|
||||
| `check_supervisor.py` | Vérifie l’état des scripts supervisés |
|
||||
| `deploy.sh` | Déploiement auto depuis Gitea (branche `product`) |
|
||||
| `requirements.txt` | Dépendances Python |
|
||||
|
||||
---
|
||||
|
||||
## 🧪 Installation locale
|
||||
|
||||
```bash
|
||||
git clone https://mj91.fr:448/michel/Gestion_sondes.git
|
||||
cd Gestion_sondes
|
||||
python -m venv .venv
|
||||
source .venv/bin/activate # Linux/macOS
|
||||
.venv\Scripts\activate # Windows
|
||||
pip install -r requirements.txt
|
||||
107
Societe_Generale.py
Normal file
107
Societe_Generale.py
Normal file
@@ -0,0 +1,107 @@
|
||||
# Insertion de données da l'app SG.
|
||||
import streamlit as st
|
||||
import mysql.connector
|
||||
from dotenv import load_dotenv
|
||||
import os
|
||||
from datetime import datetime
|
||||
|
||||
load_dotenv()
|
||||
|
||||
st.set_page_config(page_title="Insertion Mysql", layout="centered")
|
||||
st.title("🗓️ Insertion dans une base MySQL")
|
||||
|
||||
# Charger les identifiants
|
||||
DB_HOST = os.getenv("DB_HOST")
|
||||
DB_USER = os.getenv("DB_USER")
|
||||
DB_PASSWORD = os.getenv("DB_PASSWORD")
|
||||
|
||||
# Connexion sans DB initiale pour lister les bases
|
||||
@st.cache_data
|
||||
def get_databases():
|
||||
conn = mysql.connector.connect(
|
||||
host=DB_HOST,
|
||||
user=DB_USER,
|
||||
password=DB_PASSWORD
|
||||
)
|
||||
cursor = conn.cursor()
|
||||
cursor.execute("SHOW DATABASES")
|
||||
bases = [db[0] for db in cursor.fetchall()]
|
||||
conn.close()
|
||||
return bases
|
||||
|
||||
# Connexion avec DB sélectionnée
|
||||
def connect_to_db(db_name):
|
||||
return mysql.connector.connect(
|
||||
host=DB_HOST,
|
||||
user=DB_USER,
|
||||
password=DB_PASSWORD,
|
||||
database=db_name
|
||||
)
|
||||
|
||||
# --- Interface principale ---
|
||||
|
||||
base = st.selectbox("Choisir une base de données", get_databases())
|
||||
if base:
|
||||
conn = connect_to_db(base)
|
||||
cursor = conn.cursor()
|
||||
|
||||
cursor.execute("SHOW TABLES")
|
||||
tables = [table[0] for table in cursor.fetchall()]
|
||||
table = st.selectbox("Choisir une table", tables)
|
||||
|
||||
if table:
|
||||
cursor.execute(f"DESCRIBE {table}")
|
||||
colonnes = cursor.fetchall()
|
||||
|
||||
# Détection clé primaire
|
||||
cursor.execute(f"SHOW INDEX FROM {table} WHERE Key_name = 'PRIMARY'")
|
||||
pk = cursor.fetchone()
|
||||
primary_key = pk[4] if pk else None
|
||||
|
||||
champ_date_candidates = [col[0] for col in colonnes if "date" in col[1].lower()]
|
||||
champ_date = st.selectbox("Champ de date", champ_date_candidates)
|
||||
|
||||
nb_mois = st.number_input("Nombre d'insertions mensuelles", 1, 36, 6)
|
||||
date_depart = st.date_input("Date de départ des insertions", value=datetime.today().date())
|
||||
st.subheader("Champs à insérer (hors clé primaire et champ de date)")
|
||||
champs_choisis = []
|
||||
champs_editables = [col for col in colonnes if col[0] != primary_key and col[0] != champ_date]
|
||||
for col in champs_editables:
|
||||
if st.checkbox(f"{col[0]} ({col[1]})", value=True):
|
||||
champs_choisis.append(col[0])
|
||||
|
||||
with st.form("formulaire_insertion"):
|
||||
st.markdown("**Valeurs fixes pour les champs cochés**")
|
||||
valeurs_fixes = {}
|
||||
for nom in champs_choisis:
|
||||
val = st.text_input(nom)
|
||||
valeurs_fixes[nom] = val if val != "" else None
|
||||
|
||||
submit = st.form_submit_button("Insérer")
|
||||
|
||||
try:
|
||||
cursor = conn.cursor()
|
||||
insert_count = 0
|
||||
|
||||
for i in range(nb_mois):
|
||||
year = date_depart.year + (date_depart.month + i - 1) // 12
|
||||
month = (date_depart.month + i - 1) % 12 + 1
|
||||
day = min(date_depart.day, 28)
|
||||
date_cible = datetime(year, month, day).date()
|
||||
|
||||
champs = [champ_date] + list(valeurs_fixes.keys())
|
||||
valeurs = [date_cible] + list(valeurs_fixes.values())
|
||||
sql = f"INSERT INTO {table} ({', '.join(champs)}) VALUES ({', '.join(['%s'] * len(valeurs))})"
|
||||
|
||||
cursor.execute(sql, valeurs)
|
||||
insert_count += 1
|
||||
|
||||
conn.commit()
|
||||
st.success(f"{insert_count} lignes insérées avec succès dans `{table}`.")
|
||||
|
||||
except Exception as e:
|
||||
st.error(f"❌ Erreur lors de l’insertion : {e}")
|
||||
|
||||
conn.commit()
|
||||
st.success(f"{insert_count} lignes insérées avec succès dans `{table}`.")
|
||||
st.success(f"{insert_count} lignes insérées avec succès.")
|
||||
324
Telegram_sondes.py
Normal file
324
Telegram_sondes.py
Normal file
@@ -0,0 +1,324 @@
|
||||
# Gestion des chambres froides & alertes Telegram
|
||||
import requests
|
||||
import mysql.connector
|
||||
from datetime import datetime, timedelta
|
||||
import time
|
||||
import sys
|
||||
import os
|
||||
import schedule
|
||||
|
||||
def connect_db():
|
||||
return mysql.connector.connect(
|
||||
host="54.36.188.119",
|
||||
user="michel",
|
||||
password="#SO2&1nf%mZ@jfh",
|
||||
database="Sondes"
|
||||
)
|
||||
|
||||
def envoi_etat_quotidien(cursor, site):
|
||||
token = "8128378340:AAF2sO3gaH1XpMNya_pEslzerqokoCiFRGs"
|
||||
chat_id = get_chat_id(cursor, site)
|
||||
etat_sondes(cursor, site, chat_id, token)
|
||||
print(f"[INFO] État des sondes envoyé pour le site {site}.")
|
||||
|
||||
def get_active_sondes(cursor, site):
|
||||
query = "SELECT Sonde, Temp_Max FROM Chambres_froides WHERE Lieu = %s AND Etat = 'On';"
|
||||
cursor.execute(query, (site,))
|
||||
result = cursor.fetchall()
|
||||
return {row[0]: float(row[1]) for row in result}
|
||||
|
||||
|
||||
def check_temperature_limits(cursor, table_historique, sonde, limite, duree=30):
|
||||
temps_limite = datetime.now() - timedelta(minutes=duree)
|
||||
query = f"""
|
||||
SELECT Temperature
|
||||
FROM {table_historique}
|
||||
WHERE Sonde = %s AND Date >= %s
|
||||
ORDER BY Date DESC LIMIT 6;
|
||||
"""
|
||||
cursor.execute(query, (sonde, temps_limite))
|
||||
result = cursor.fetchall()
|
||||
if len(result) == 6 and all(float(temp[0]) > limite for temp in result):
|
||||
return True, float(result[0][0])
|
||||
return False, None
|
||||
|
||||
def simulate_alert(db, cursor, site, sonde, chat_id, token):
|
||||
table_alertes = f"Alertes_{site}"
|
||||
print(f"[TEST] tentative d'insertion de sonde : {sonde} dans table {table_alertes}")
|
||||
|
||||
try:
|
||||
query = f"""
|
||||
INSERT INTO {table_alertes} (Sonde, Debut_defaut, Status)
|
||||
VALUES (%s, NOW(), 'test')
|
||||
ON DUPLICATE KEY UPDATE Debut_defaut = NOW(), Status = 'test';
|
||||
"""
|
||||
cursor.execute(query, (sonde,))
|
||||
db.commit()
|
||||
print(f"[TEST] insertion ou mise à jour réussie pour {sonde}.")
|
||||
except Exception as e:
|
||||
print(f"[ERREUR] lors de l'insertion test : {e}")
|
||||
|
||||
message = f"⚠️ TEST ALERTE : Simulation d'une alerte pour la sonde {sonde}."
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
try:
|
||||
requests.get(url, params={'chat_id': chat_id, 'text': message})
|
||||
except Exception as e:
|
||||
print(f"[ERREUR] lors de l'envoi Telegram : {e}")
|
||||
|
||||
def create_alert(db, cursor, table_alertes, sonde, temperature):
|
||||
query = f"""
|
||||
INSERT INTO {table_alertes} (Sonde, Debut_defaut, Status)
|
||||
VALUES (%s, NOW(), 'en cours');
|
||||
"""
|
||||
cursor.execute(query, (sonde,))
|
||||
send_telegram_message(sonde, temperature)
|
||||
print(f"Alerte créée pour la sonde {sonde}")
|
||||
db.commit()
|
||||
|
||||
def resolve_alert(cursor, table_alertes, sonde):
|
||||
query = f"""
|
||||
UPDATE {table_alertes}
|
||||
SET Status = 'résolu'
|
||||
WHERE Sonde = %s AND Status = 'en cours';
|
||||
"""
|
||||
cursor.execute(query, (sonde,))
|
||||
print(f"Alerte résolue pour la sonde {sonde}")
|
||||
|
||||
def acquitter_alerte(cursor, site, sonde, chat_id, token):
|
||||
table_alertes = f"Alertes_{site}"
|
||||
query = f"""
|
||||
UPDATE {table_alertes}
|
||||
SET Status = 'acquittée'
|
||||
WHERE Sonde = %s AND Status IN ('en cours', 'test');
|
||||
"""
|
||||
cursor.execute(query, (sonde,))
|
||||
lignes_modifiees = cursor.rowcount
|
||||
|
||||
if lignes_modifiees > 0:
|
||||
message = f"✅ Alerte acquittée pour la sonde {sonde} par commande Telegram."
|
||||
else:
|
||||
message = f"ℹ️ Aucune alerte active à acquitter pour la sonde {sonde}."
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
try:
|
||||
requests.get(url, params={'chat_id': chat_id, 'text': message})
|
||||
except Exception as e:
|
||||
print(f"[ERREUR] envoi message Telegram : {e}")
|
||||
|
||||
def send_telegram_message(sonde, temperature):
|
||||
token = "5714323406:AAGSj9jrfBHbfxubz3ooabPEizI8aBOLnvE"
|
||||
chat_id = "-1002442631825"
|
||||
message = f"⚠️ Alerte température : La sonde {sonde} dépasse la limite avec une température de {temperature}°C."
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
params = {'chat_id': chat_id, 'text': message}
|
||||
try:
|
||||
response = requests.get(url, params=params)
|
||||
if response.status_code == 200:
|
||||
print(f"Message envoyé via Telegram pour la sonde {sonde}.")
|
||||
else:
|
||||
print(f"Erreur lors de l'envoi du message Telegram : {response.status_code}")
|
||||
except Exception as e:
|
||||
print(f"Erreur lors de l'envoi du message Telegram : {e}")
|
||||
|
||||
|
||||
def get_chat_id(cursor, site):
|
||||
cursor.execute("SELECT Chat_ID FROM Sites WHERE Nom = %s;", (site,))
|
||||
result = cursor.fetchone()
|
||||
if result:
|
||||
return result[0]
|
||||
else:
|
||||
print(f"Aucun Chat_ID trouvé pour le site {site}")
|
||||
return None
|
||||
|
||||
def passer_en_maintenance(cursor, site, sonde, chat_id, token):
|
||||
try:
|
||||
query = """
|
||||
UPDATE Chambres_froides
|
||||
SET Etat = 'Off'
|
||||
WHERE Lieu = %s AND Sonde = %s;
|
||||
"""
|
||||
cursor.execute(query, (site, sonde))
|
||||
lignes_modifiees = cursor.rowcount
|
||||
|
||||
if lignes_modifiees > 0:
|
||||
message = f"🛠️ La sonde {sonde} a été passée en mode maintenance (OFF)."
|
||||
else:
|
||||
message = f"⚠️ Sonde {sonde} introuvable pour le site {site}."
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
requests.get(url, params={'chat_id': chat_id, 'text': message})
|
||||
|
||||
except Exception as e:
|
||||
print(f"[ERREUR] lors du passage en maintenance : {e}")
|
||||
|
||||
def reactiver_sonde(cursor, site, sonde, chat_id, token):
|
||||
try:
|
||||
query = """
|
||||
UPDATE Chambres_froides
|
||||
SET Etat = 'On'
|
||||
WHERE Lieu = %s AND Sonde = %s;
|
||||
"""
|
||||
cursor.execute(query, (site, sonde))
|
||||
lignes_modifiees = cursor.rowcount
|
||||
|
||||
if lignes_modifiees > 0:
|
||||
message = f"✅ La sonde {sonde} a été réactivée (ON)."
|
||||
else:
|
||||
message = f"⚠️ Sonde {sonde} introuvable pour le site {site}."
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
requests.get(url, params={'chat_id': chat_id, 'text': message})
|
||||
|
||||
except Exception as e:
|
||||
print(f"[ERREUR] lors de la réactivation : {e}")
|
||||
|
||||
def etat_sondes(cursor, site, chat_id, token):
|
||||
query = "SELECT Sonde, Etat FROM Chambres_froides WHERE Lieu = %s ORDER BY Sonde;"
|
||||
cursor.execute(query, (site,))
|
||||
result = cursor.fetchall()
|
||||
|
||||
message = f"📊 État des sondes - {site} :\n"
|
||||
for sonde, etat in result:
|
||||
symbole = "🟢" if etat.upper() == "ON" else "🔴"
|
||||
message += f"{symbole} {sonde} ({etat.upper()})\n"
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/sendMessage"
|
||||
requests.get(url, params={'chat_id': chat_id, 'text': message})
|
||||
|
||||
def monitor_temperatures_simple(site, db, cursor):
|
||||
table_historique = site
|
||||
table_alertes = f"Alertes_{site}"
|
||||
sondes = get_active_sondes(cursor, site)
|
||||
print(f"[MONITORING] Sondes actives pour {site} : {sondes}")
|
||||
|
||||
for sonde, limite in sondes.items():
|
||||
alert_needed, temperature = check_temperature_limits(cursor, table_historique, sonde, limite)
|
||||
if alert_needed:
|
||||
create_alert(db, cursor, table_alertes, sonde, temperature)
|
||||
else:
|
||||
resolve_alert(cursor, table_alertes, sonde)
|
||||
|
||||
db.commit()
|
||||
print("[MONITORING] Vérification des sondes terminée.")
|
||||
|
||||
def monitor_temperatures(site):
|
||||
db = connect_db()
|
||||
cursor = db.cursor()
|
||||
|
||||
table_historique = site # Ex: Saclay
|
||||
table_alertes = f"Alertes_{site}" # Ex: Alertes_Saclay
|
||||
|
||||
sondes = get_active_sondes(cursor, site)
|
||||
print(f"Sondes actives pour le site {site} :", sondes)
|
||||
|
||||
for sonde, limite in sondes.items():
|
||||
alert_needed, temperature = check_temperature_limits(cursor, table_historique, sonde, limite)
|
||||
if alert_needed:
|
||||
create_alert(db, cursor, table_alertes, sonde, temperature)
|
||||
else:
|
||||
resolve_alert(cursor, table_alertes, sonde)
|
||||
|
||||
db.commit()
|
||||
listen_for_commands(db, cursor, site)
|
||||
cursor.close()
|
||||
db.close()
|
||||
|
||||
def listen_for_commands(db, cursor, site):
|
||||
token = "5714323406:AAGSj9jrfBHbfxubz3ooabPEizI8aBOLnvE"
|
||||
chat_id = get_chat_id(cursor, site)
|
||||
offset_file = os.path.join(os.path.dirname(__file__), f"last_update_id_{site}.txt")
|
||||
|
||||
try:
|
||||
with open(offset_file, 'r') as f:
|
||||
last_update_id = int(f.read().strip())
|
||||
except FileNotFoundError:
|
||||
last_update_id = None
|
||||
|
||||
url = f"https://api.telegram.org/bot{token}/getUpdates"
|
||||
if last_update_id is not None:
|
||||
url += f"?offset={last_update_id + 1}"
|
||||
|
||||
try:
|
||||
response = requests.get(url)
|
||||
data = response.json()
|
||||
|
||||
if "result" in data:
|
||||
for update in data["result"]:
|
||||
update_id = update["update_id"]
|
||||
|
||||
if "message" in update:
|
||||
message = update["message"]["text"]
|
||||
print(f"[CMD] Message reçu : {message}")
|
||||
|
||||
if message.lower().startswith("/etat"):
|
||||
etat_sondes(cursor, site, chat_id, token)
|
||||
|
||||
elif message.lower().startswith("/acquitter"):
|
||||
parts = message.strip().split(" ", 1)
|
||||
if len(parts) == 2 and parts[1].strip():
|
||||
sonde = parts[1].strip()
|
||||
acquitter_alerte(cursor, site, sonde, chat_id, token)
|
||||
db.commit()
|
||||
else:
|
||||
erreur_msg = "❌ Utilisation incorrecte. Format attendu : /acquitter <nom_sonde>"
|
||||
requests.get(f"https://api.telegram.org/bot{token}/sendMessage",
|
||||
params={'chat_id': chat_id, 'text': erreur_msg})
|
||||
elif message.lower().startswith("/maintenance"):
|
||||
parts = message.strip().split(" ", 1)
|
||||
if len(parts) == 2 and parts[1].strip():
|
||||
sonde = parts[1].strip()
|
||||
passer_en_maintenance(cursor, site, sonde, chat_id, token)
|
||||
db.commit()
|
||||
else:
|
||||
erreur_msg = "❌ Utilisation incorrecte. Format attendu : /maintenance <nom_sonde>"
|
||||
requests.get(f"https://api.telegram.org/bot{token}/sendMessage",
|
||||
params={'chat_id': chat_id, 'text': erreur_msg})
|
||||
elif message.lower().startswith("/reactiver"):
|
||||
parts = message.strip().split(" ", 1)
|
||||
if len(parts) == 2 and parts[1].strip():
|
||||
sonde = parts[1].strip()
|
||||
reactiver_sonde(cursor, site, sonde, chat_id, token)
|
||||
db.commit()
|
||||
else:
|
||||
erreur_msg = "❌ Utilisation incorrecte. Format attendu : /reactiver <nom_sonde>"
|
||||
requests.get(f"https://api.telegram.org/bot{token}/sendMessage",
|
||||
params={'chat_id': chat_id, 'text': erreur_msg})
|
||||
elif message.lower().startswith("/test"):
|
||||
parts = message.strip().split(" ", 1)
|
||||
if len(parts) == 2 and parts[1].strip():
|
||||
sonde = parts[1].strip()
|
||||
simulate_alert(db, cursor, site, sonde, chat_id, token)
|
||||
else:
|
||||
erreur_msg = "❌ Utilisation incorrecte. Format attendu : /test <nom_sonde>"
|
||||
requests.get(f"https://api.telegram.org/bot{token}/sendMessage",
|
||||
params={'chat_id': chat_id, 'text': erreur_msg})
|
||||
|
||||
with open(offset_file, 'w') as f:
|
||||
f.write(str(update_id))
|
||||
|
||||
except Exception as e:
|
||||
print(f"Erreur lors de la lecture des commandes Telegram : {e}")
|
||||
|
||||
|
||||
def main():
|
||||
site = sys.argv[1] if len(sys.argv) > 1 else "Saclay"
|
||||
db = connect_db()
|
||||
cursor = db.cursor()
|
||||
|
||||
# ✅ Planification : tous les jours à 07:00 → état des sondes
|
||||
schedule.every().day.at("07:00").do(envoi_etat_quotidien, cursor=cursor, site=site)
|
||||
|
||||
# ✅ Planification : toutes les 2m30 → surveillance
|
||||
schedule.every(2).minutes.do(monitor_temperatures_simple, site=site, db=db, cursor=cursor)
|
||||
|
||||
try:
|
||||
while True:
|
||||
schedule.run_pending()
|
||||
listen_for_commands(db, cursor, site)
|
||||
time.sleep(2) # petite pause pour ne pas surcharger Telegram
|
||||
finally:
|
||||
cursor.close()
|
||||
db.close()
|
||||
|
||||
if __name__ == "__main__":
|
||||
main()
|
||||
24
Test_mail.py
Normal file
24
Test_mail.py
Normal file
@@ -0,0 +1,24 @@
|
||||
# Programme de test de la BAL alertes_saclay@domo91.fr.
|
||||
import smtplib
|
||||
from email.mime.text import MIMEText
|
||||
|
||||
def envoyer_mail(sujet, message, destinataires):
|
||||
msg = MIMEText(message)
|
||||
msg['Subject'] = sujet
|
||||
msg['From'] = 'alertes_saclay@domo91.fr'
|
||||
msg['To'] = ', '.join(destinataires)
|
||||
|
||||
try:
|
||||
with smtplib.SMTP_SSL('smtp.mail.ovh.net', 465) as server:
|
||||
server.login('alertes_saclay@domo91.fr', 'Kdpke674y23Feq^H')
|
||||
server.sendmail(msg['From'], destinataires, msg.as_string())
|
||||
print(f"📧 Mail envoyé à {destinataires}")
|
||||
except Exception as e:
|
||||
print(f"Erreur envoi mail : {e}")
|
||||
|
||||
# --- Test d'envoi ---
|
||||
envoyer_mail(
|
||||
sujet="🧪 Test d'envoi d'alerte",
|
||||
message="Ceci est un test de l'envoi d'e-mail via alertes_saclay@domo91.fr.",
|
||||
destinataires=["services@domo91.fr"]
|
||||
)
|
||||
106
Tracker.py
Normal file
106
Tracker.py
Normal file
@@ -0,0 +1,106 @@
|
||||
# Programme de récupération des adresses de sondes DS18B20 et envoie dans table Sondes.Tracker.
|
||||
import paho.mqtt.client as mqtt
|
||||
import mysql.connector
|
||||
import re # Import de la bibliothèque des expressions régulières
|
||||
|
||||
# Configuration de la base de données MySQL
|
||||
db_config = {
|
||||
'user': 'superviseur', # Remplacez par votre utilisateur MySQL
|
||||
'password': 'Bto7Lm_z]m!BFH!*', # Remplacez par votre mot de passe MySQL
|
||||
'host': '54.36.188.119', # Adresse de votre serveur MySQL (localhost si en local)
|
||||
'database': 'Sondes' # Nom de la base de données MySQL
|
||||
}
|
||||
|
||||
|
||||
def convertir_rom_id_en_hexa(rom_id):
|
||||
# On découpe la chaîne rom_id en paires de deux caractères
|
||||
hex_parts = [f"0x{rom_id[i:i + 2]}" for i in range(0, len(rom_id), 2)]
|
||||
return ",".join(hex_parts)
|
||||
|
||||
|
||||
# Connexion à la base de données MySQL
|
||||
def connect_db():
|
||||
return mysql.connector.connect(**db_config)
|
||||
|
||||
|
||||
# Fonction pour vérifier si la sonde est déjà présente dans la base
|
||||
def sonde_deja_presente(rom_id):
|
||||
conn = connect_db()
|
||||
cursor = conn.cursor()
|
||||
try:
|
||||
# Vérifier si la sonde existe déjà dans la base
|
||||
cursor.execute("SELECT COUNT(*) FROM Tracker WHERE rom_id = %s", (rom_id,))
|
||||
result = cursor.fetchone()
|
||||
return result[0] > 0 # Si le nombre est supérieur à 0, la sonde est déjà présente
|
||||
|
||||
except mysql.connector.Error as err:
|
||||
print(f"Erreur MySQL lors de la vérification de la sonde : {err}")
|
||||
return False
|
||||
|
||||
finally:
|
||||
cursor.close()
|
||||
conn.close()
|
||||
|
||||
|
||||
# Fonction pour insérer les sondes dans la base de données
|
||||
def inserer_sonde(rom_id):
|
||||
if sonde_deja_presente(rom_id):
|
||||
print(f"Sonde {rom_id} déjà présente dans la base de données. Aucune insertion effectuée.")
|
||||
return
|
||||
|
||||
conn = connect_db()
|
||||
cursor = conn.cursor()
|
||||
try:
|
||||
# Conversion en hexadécimal
|
||||
rom_id_hexa = convertir_rom_id_en_hexa(rom_id)
|
||||
|
||||
# Insertion de rom_id et de sa version hexa dans la base
|
||||
cursor.execute("INSERT INTO Tracker (rom_id, hexa) VALUES (%s, %s)", (rom_id, rom_id_hexa))
|
||||
conn.commit()
|
||||
print(f"Sonde {rom_id} insérée dans la base de données avec son format hexa {rom_id_hexa}.")
|
||||
|
||||
except mysql.connector.Error as err:
|
||||
print(f"Erreur MySQL : {err}")
|
||||
|
||||
finally:
|
||||
cursor.close()
|
||||
conn.close()
|
||||
|
||||
|
||||
# Fonction de callback pour gérer les messages MQTT
|
||||
def on_message(_client, _userdata, message):
|
||||
payload = message.payload.decode()
|
||||
print(f"Message reçu : {payload}")
|
||||
|
||||
# Utilisation de re pour extraire les ROM IDs (Sonde [rom_id])
|
||||
rom_ids = re.findall(r"[0-9a-fA-F]{16}", payload) # Capturer les IDs de 16 caractères
|
||||
if rom_ids:
|
||||
for rom_id in rom_ids:
|
||||
inserer_sonde(rom_id)
|
||||
else:
|
||||
print("Aucun ROM ID trouvé dans le message.")
|
||||
|
||||
|
||||
# Configuration du client MQTT
|
||||
mqtt_broker = "46.105.92.116"
|
||||
mqtt_port = 1883 # Vérifiez si votre broker utilise un autre port
|
||||
mqtt_user = "Bwps"
|
||||
mqtt_password = "scJ5ACj2keRfI^"
|
||||
mqtt_topic = "Tracker/sondes"
|
||||
|
||||
client = mqtt.Client()
|
||||
|
||||
# Authentification MQTT
|
||||
client.username_pw_set(mqtt_user, mqtt_password)
|
||||
|
||||
# Configuration du callback pour les messages MQTT
|
||||
client.on_message = on_message
|
||||
|
||||
# Connexion au broker MQTT
|
||||
client.connect(mqtt_broker, mqtt_port, 60)
|
||||
|
||||
# Souscription au topic Tracker/sondes
|
||||
client.subscribe(mqtt_topic)
|
||||
|
||||
# Démarrer la boucle MQTT
|
||||
client.loop_forever()
|
||||
39
logs_analyse.py
Normal file
39
logs_analyse.py
Normal file
@@ -0,0 +1,39 @@
|
||||
import streamlit as st
|
||||
import pandas as pd
|
||||
import matplotlib.pyplot as plt
|
||||
|
||||
# --- Chargement des données ---
|
||||
try:
|
||||
df = pd.read_csv("/home/debian/travail/logs_monitor.csv", sep=";", parse_dates=["Date"])
|
||||
except FileNotFoundError:
|
||||
st.error("📂 Le fichier de log n'a pas été trouvé.")
|
||||
st.stop()
|
||||
|
||||
st.title("🧾 Analyse des scans Monitor.py")
|
||||
|
||||
# --- Filtres ---
|
||||
df["Date_str"] = df["Date"].dt.date
|
||||
dates_dispo = sorted(df["Date_str"].unique(), reverse=True)
|
||||
date_selection = st.selectbox("📅 Sélectionnez une date :", dates_dispo)
|
||||
|
||||
lieux = sorted(df["Lieu"].unique())
|
||||
lieu_selection = st.selectbox("📍 Site :", lieux)
|
||||
|
||||
df_filtré = df[(df["Date_str"] == date_selection) & (df["Lieu"] == lieu_selection)]
|
||||
|
||||
sondes = sorted(df_filtré["Sonde"].unique())
|
||||
sonde_selection = st.selectbox("🧪 Sonde :", sondes)
|
||||
|
||||
df_sonde = df_filtré[df_filtré["Sonde"] == sonde_selection]
|
||||
|
||||
# --- Graphique température ---
|
||||
fig, ax = plt.subplots(figsize=(10, 4))
|
||||
ax.plot(df_sonde["Date"], df_sonde["Température"], marker='o')
|
||||
ax.set_title(f"Évolution de la température - {sonde_selection}")
|
||||
ax.set_xlabel("Heure")
|
||||
ax.set_ylabel("Température (°C)")
|
||||
st.pyplot(fig)
|
||||
|
||||
# --- Tableau complet du jour/sonde sélectionnés ---
|
||||
st.markdown("### 📋 Détail des scans")
|
||||
st.dataframe(df_sonde[["Date", "Sonde", "Température", "Seuil", "État"]], use_container_width=True)
|
||||
47
supervisor_watchdog.py
Normal file
47
supervisor_watchdog.py
Normal file
@@ -0,0 +1,47 @@
|
||||
# Controle des services supervisor envoi en cas de disfonction et tous les jours à sept heures
|
||||
# a faire tourner avec crontb -e en sudo
|
||||
# */30 * * * * /home/debian/travail/myenv/bin/python3 /home/debian/travail/Scripts/supervisor_watchdog.py
|
||||
import subprocess
|
||||
import smtplib
|
||||
from email.mime.text import MIMEText
|
||||
from datetime import datetime
|
||||
|
||||
heure_actuelle = datetime.now().strftime("%H:%M")
|
||||
etat_services = []
|
||||
anomalies = []
|
||||
|
||||
try:
|
||||
output = subprocess.check_output("/usr/bin/supervisorctl status", shell=True, text=True)
|
||||
for line in output.splitlines():
|
||||
parts = line.split()
|
||||
if len(parts) >= 2:
|
||||
nom, statut = parts[0], parts[1]
|
||||
etat_services.append(f"{nom} ➤ {statut}")
|
||||
if statut != "RUNNING":
|
||||
anomalies.append(f"{nom} ➤ {statut}")
|
||||
except Exception as e:
|
||||
etat_services.append("❌ Impossible d'exécuter supervisorctl")
|
||||
anomalies.append(f"Erreur : {e}")
|
||||
|
||||
# Déclenchement mail si anomalie ou à 07:00
|
||||
envoyer_mail = bool(anomalies) or heure_actuelle == "07:00"
|
||||
|
||||
if envoyer_mail:
|
||||
sujet = "⚠️ Alerte Supervisor" if anomalies else "✅ Rapport quotidien Supervisor"
|
||||
intro = "🛑 Les services suivants ne sont pas en RUNNING :" if anomalies else "✅ Tous les services supervisés sont en RUNNING."
|
||||
contenu = f"{intro}\n\n" + "\n".join(etat_services)
|
||||
|
||||
msg = MIMEText(contenu)
|
||||
msg["Subject"] = sujet
|
||||
msg["From"] = "alertes_saclay@domo91.fr"
|
||||
msg["To"] = "services@domo91.fr"
|
||||
|
||||
try:
|
||||
with smtplib.SMTP_SSL("smtp.mail.ovh.net", 465) as server:
|
||||
server.login("alertes_saclay@domo91.fr", "Kdpke674y23Feq^H")
|
||||
server.sendmail(msg["From"], [msg["To"]], msg.as_string())
|
||||
print("📧 Mail envoyé.")
|
||||
except Exception as e:
|
||||
print(f"Erreur envoi mail : {e}")
|
||||
else:
|
||||
print("🕖 Aucun mail envoyé (tout est OK et ce n’est pas l’heure du rapport).")
|
||||
Reference in New Issue
Block a user