eric/smart-city-digital-twin-martinique
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Simulator: use localhost for MQTT brokers (fix DNS resolution)

Browse Source
This commit is contained in:
Eric FELIXINE
2026-05-04 20:53:10 -04:00
parent 78b423e43d
commit 816f5fcddc
1 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
simulator.py
View File

@@ -4,11 +4,13 @@ Smart City IoT Simulator — Martinique (14.6°N, 61.2°W)
======================================================= =======================================================
Publie vers MULTIPLES brokers MQTT + context brokers NGSI-LD. Publie vers MULTIPLES brokers MQTT + context brokers NGSI-LD.
Brokers MQTT: # Brokers MQTT (utiliser localhost avec ports exposés)
- EMQX: emqx_emqx_1:1883 (sans auth) EMQX_HOST = os.environ.get("EMQX_HOST", "localhost")
- Mosquitto: mosquitto-traefik:1883 (bunker/bunker) EMQX_PORT = int(os.environ.get("EMQX_PORT", "11883"))
- BunkerM: bunkerm_bunkerm_1:1900 (TLS, bunker/bunker) MOSQUITTO_HOST = os.environ.get("MOSQUITTO_HOST", "localhost")
- OpenRemote: openremote-manager-1:1883 (admin/Digitribe972) MOSQUITTO_PORT = int(os.environ.get("MOSQUITTO_PORT", "1883"))
BUNKERM_HOST = os.environ.get("BUNKERM_HOST", "mqtt.digitribe.fr")
BUNKERM_PORT = int(os.environ.get("BUNKERM_PORT", "1900"))
Context Brokers REST: Context Brokers REST:
- Orion-LD: fiware-gis-quickstart-orion-1:1026 (NGSI-LD) - Orion-LD: fiware-gis-quickstart-orion-1:1026 (NGSI-LD)
@@ -394,11 +396,10 @@ class MultiMQTT:
print(f"[MQTT] ⚠️ {name} déconnecté") print(f"[MQTT] ⚠️ {name} déconnecté")
def _setup(self): def _setup(self):
# Garder que EMQX et Mosquitto (MQTT fonctionnels) # Utiliser les variables d'environnement pour les brokers
# BunkerM via HTTP API (port 2000) au lieu de MQTT/TLS
brokers = [ brokers = [
("EMQX", "emqx_emqx_1", 1883, False, "", ""), ("EMQX", EMQX_HOST, EMQX_PORT, False, "", ""),
("Mosquitto", "mosquitto-traefik", 1883, False, "bunker", "bunker"), ("Mosquitto", MOSQUITTO_HOST, MOSQUITTO_PORT, False, "bunker", "bunker"),
] ]
print("[MQTT] 🔌 Connexion aux brokers...") print("[MQTT] 🔌 Connexion aux brokers...")
for name, host, port, tls, user, pwd in brokers: for name, host, port, tls, user, pwd in brokers: