diff --git a/service_helpers.py b/service_helpers.py index 4cd40ca..f627d93 100644 --- a/service_helpers.py +++ b/service_helpers.py @@ -4,7 +4,7 @@ import os import requests from paho.mqtt import client as mqtt -from constants import solaredge_api_key, solaredge_monitoring_api_url, mqtt_username, mqtt_password, mqtt_broker_ip +from constants import solaredge_api_key, solaredge_monitoring_api_url, mqtt_username, mqtt_password, mqtt_broker_ip, mqtt_broker_ip_linux import logging @@ -57,10 +57,11 @@ def get_energy_totals(time_unit, start_date, end_date): def connect_mqtt(): c = mqtt.Client() c.username_pw_set(mqtt_username, mqtt_password) + mqtt_ip = mqtt_broker_ip if os.name == 'nt' else mqtt_broker_ip_linux try: # Stel in: probeer elke 1 tot 120 seconden opnieuw te verbinden c.reconnect_delay_set(min_delay=1, max_delay=120) - c.connect(mqtt_broker_ip, 1883, 60) + c.connect(mqtt_ip, 1883, 60) c.loop_start() # Draait op de achtergrond en regelt de automatische reconnect return c except Exception as e: