diff --git a/ambient_info.py b/ambient_info.py index fa1034d..96bb4df 100644 --- a/ambient_info.py +++ b/ambient_info.py @@ -1,5 +1,6 @@ import config import logging +import mqtt import paho.mqtt.client as paho import socket import report @@ -47,20 +48,16 @@ class meaner(dict): return time.time() - self.start_time +mqtt_inst = mqtt.mqtt_client(config.APP_NAME, config.MQTT_SERVER, username=config.MQTT_USER, password=config.MQTT_PASS) dht_meaner = meaner() bmp_meaner = meaner() + def send_data_to_mqtt(data): - client = paho.Client("temp_sens") - client.username_pw_set(config.MQTT_USER, config.MQTT_PASS) - try: - client.connect(config.MQTT_SERVER, 1883) - for key in data: - topic = config.MQTT_TOPIC + "/" + key - logger.info("Sending Ambient Information to mqtt %s=%s", topic, str(data[key])) - client.publish(topic, data[key]) - except (socket.timeout, OSError) as e: - logger.warning("Erro while sending ambient information") + for key in data: + topic = config.MQTT_TOPIC + "/" + key + logger.info("Sending Ambient Information to mqtt %s=%s", topic, str(data[key])) + mqtt_inst.send(topic, data[key]) def dht_callback(**data): diff --git a/requirements.txt b/requirements.txt index 67e0f81..a535607 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1,3 +1,2 @@ -paho-mqtt adafruit-circuitpython-dht smbus