localhorst/TTN-VEGAPULS-Air-exporter
1
0
Fork 0
Code Issues 3 Pull Requests Packages Projects Releases Wiki Activity

silence http log

Browse Source
This commit is contained in:
Hendrik Schutter 2025-05-06 22:02:35 +02:00
parent ca94d77052
commit 566c687c2e
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ttn-vegapulsair-exporter.py
View File

@ -59,10 +59,12 @@ def reconnect_mqtt():
) )
except Exception as e: except Exception as e:
print(f"MQTT reconnect failed: {e}") print(f"MQTT reconnect failed: {e}")
time.sleep(10) # Retry every 10 seconds time.sleep(60) # Retry every 10 seconds
class RequestHandler(BaseHTTPRequestHandler): class RequestHandler(BaseHTTPRequestHandler):
def log_message(self, format, *args):
pass
def get_metrics(self): def get_metrics(self):
global request_count global request_count
@ -193,16 +195,18 @@ def on_connect(client, userdata, flags, reason_code, properties):
print("\nNot connected to MQTT: reason_code = " + str(reason_code)) print("\nNot connected to MQTT: reason_code = " + str(reason_code))
mqtt_connected = False mqtt_connected = False
def on_disconnect(client, userdata, flags, reason_code): def on_disconnect(client, userdata, flags, reason_code, tmp):
global mqtt_connected global mqtt_connected
print(f"Disconnected from MQTT: reason_code = {reason_code}") print(f"Disconnected from MQTT: reason_code = {reason_code}")
mqtt_connected = False mqtt_connected = False
def on_message(mqttc, obj, msg): def on_message(mqttc, obj, msg):
print("on_message")
global scrape_healthy global scrape_healthy
try: try:
parsedJSON = json.loads(msg.payload) parsedJSON = json.loads(msg.payload)
print(parsedJSON)
uplink_message = parsedJSON["uplink_message"] uplink_message = parsedJSON["uplink_message"]
update_metrics(uplink_message["decoded_payload"], uplink_message["rx_metadata"]) update_metrics(uplink_message["decoded_payload"], uplink_message["rx_metadata"])
except Exception as e: except Exception as e: