AntoineVe/snmp2mqtt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Mise à jour avec la nouvelle API (V2) de Paho MQTT

Browse Source
This commit is contained in:
Antoine Van Elstraete
2025-08-24 16:37:25 +02:00
parent 75f8c6a637
commit 2309ef1deb
3 changed files with 18 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
README.md
View File

@@ -31,10 +31,12 @@ Passerelle SNMP vers MQTT pour l'intégration Home Assistant. Ce script Python s
### Dépendances principales ### Dépendances principales
- **pysnmp >= 7.0.0** : Bibliothèque SNMP avec nouvelle API asynchrone - **pysnmp >= 7.0.0** : Bibliothèque SNMP avec nouvelle API asynchrone
- **paho-mqtt >= 1.6.0** : Client MQTT pour la communication avec le broker - **paho-mqtt >= 2.0.0** : Client MQTT pour la communication avec le broker
- **PyYAML >= 6.0.0** : Parsing des fichiers de configuration YAML - **PyYAML >= 6.0.0** : Parsing des fichiers de configuration YAML
⚠️ **Note importante** : Ce projet utilise pysnmp version 7.x qui introduit des changements d'API incompatibles avec les versions 6.x et antérieures. L'ancienne classe `Slim` a été supprimée au profit de `get_cmd()` avec des objets `SnmpEngine`, `UdpTransportTarget`, etc. ⚠️ **Notes importantes sur les versions** :
- **pysnmp 7.x** : Changements d'API incompatibles avec les versions 6.x et antérieures. L'ancienne classe `Slim` a été supprimée au profit de `get_cmd()` avec des objets `SnmpEngine`, `UdpTransportTarget`, etc.
- **paho-mqtt 2.x** : Nouvelle API de callbacks (VERSION2) qui remplace l'ancienne API deprecated (VERSION1). Les signatures des callbacks ont changé.
### Configuration de l'environnement ### Configuration de l'environnement
@@ -374,6 +376,11 @@ devices:
- **"Please call .create() to construct UdpTransportTarget object"** : Erreur corrigée dans cette version, utilisez `pip install -r requirements.txt` - **"Please call .create() to construct UdpTransportTarget object"** : Erreur corrigée dans cette version, utilisez `pip install -r requirements.txt`
- **Erreurs d'importation SNMP** : Assurez-vous d'avoir pysnmp 7.x avec `pip show pysnmp` - **Erreurs d'importation SNMP** : Assurez-vous d'avoir pysnmp 7.x avec `pip show pysnmp`
6. **Erreurs liées à Paho MQTT**
- **"DeprecationWarning: Callback API version 1 is deprecated"** : Vous utilisez une version paho-mqtt < 2.0. Mettez à jour vers >= 2.0.0
- **Erreurs de callback MQTT** : La nouvelle API VERSION2 change la signature des callbacks (ex: `on_connect` reçoit maintenant 5 paramètres)
- **Vérification version** : `pip show paho-mqtt` pour confirmer la version installée
### Commandes de test utiles ### Commandes de test utiles
```bash ```bash

3
requirements.txt
View File

@@ -6,7 +6,8 @@
pysnmp>=7.0.0 pysnmp>=7.0.0
# MQTT client library for connecting to MQTT brokers # MQTT client library for connecting to MQTT brokers
paho-mqtt>=1.6.0 # Note: paho-mqtt 2.x uses a new callback API (VERSION2) instead of the deprecated VERSION1
paho-mqtt>=2.0.0
# YAML configuration file parsing # YAML configuration file parsing
PyYAML>=6.0.0 PyYAML>=6.0.0

12
snmp2mqtt.py
View File

@@ -179,12 +179,14 @@ def load_config(config_path):
def connect_mqtt(mqtt_config): def connect_mqtt(mqtt_config):
def on_connect(client, userdata, flags, rc): def on_connect(client, userdata, connect_flags, reason_code, properties):
if rc == 0: if reason_code == 0:
print("Connected to MQTT Broker!") logging.info("Connected to MQTT Broker!")
else: else:
print("Failed to connect, return code {rc}") logging.error(f"Failed to connect to MQTT Broker, reason code: {reason_code}")
client = mqtt_client.Client()
# Use the new callback API version 2
client = mqtt_client.Client(callback_api_version=mqtt_client.CallbackAPIVersion.VERSION2)
client.username_pw_set(mqtt_config["user"], mqtt_config["password"]) client.username_pw_set(mqtt_config["user"], mqtt_config["password"])
client.on_connect = on_connect client.on_connect = on_connect
client.connect(mqtt_config['broker'], mqtt_config['port']) client.connect(mqtt_config['broker'], mqtt_config['port'])