diff --git a/mqtt2prometheus.py b/mqtt2prometheus.py --- a/mqtt2prometheus.py +++ b/mqtt2prometheus.py @@ -103,37 +103,55 @@ def handle_availability(client, userdata def handle_temperature(client, userdata, msg): t = msg.topic.split("/") location = "-".join(t[2:]) - temperature.labels(location).set(float(msg.payload)) + try: + temperature.labels(location).set(float(msg.payload)) + except: + pass def handle_humidity(client, userdata, msg): t = msg.topic.split("/") location = "-".join(t[2:]) - humidity.labels(location).set(float(msg.payload)) + try: + humidity.labels(location).set(float(msg.payload)) + except: + pass def handle_barometer(client, userdata, msg): t = msg.topic.split("/") location = "-".join(t[2:]) - barometer.labels(location).set(float(msg.payload)) + try: + barometer.labels(location).set(float(msg.payload)) + except: + pass def handle_power_consumption(client, userdata, msg): t = msg.topic.split("/") location = "-".join(t[2:]) - power_consumption.labels(location).set(float(msg.payload)) + try: + power_consumption.labels(location).set(float(msg.payload)) + except: + pass def handle_co2_emission(client, userdata, msg): t = msg.topic.split("/") location = "-".join(t[2:]) - co2_emission.labels(location).set(float(msg.payload)) + try: + co2_emission.labels(location).set(float(msg.payload)) + except: + pass def handle_energy_consumption(client, userdata, msg): t = msg.topic.split("/") location = "-".join(t[2:]) - energy_consumption.labels(location).set(float(msg.payload)) + try: + energy_consumption.labels(location).set(float(msg.payload)) + except: + pass def main():