add logging

wmo-im · Sep 30, 2024 · 7a08b43 · 7a08b43
1 parent 9da33ef
commit 7a08b43
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/wis2box-mqtt-metrics-collector/mqtt_metrics_collector.py b/wis2box-mqtt-metrics-collector/mqtt_metrics_collector.py
@@ -174,6 +174,7 @@ def sub_mqtt_metrics(client, userdata, msg):
 
 
 def process_buffered_messages():
+    logger.info("Processing buffered messages")
     global message_buffer
 
     with buffer_lock:
@@ -214,6 +215,7 @@ def process_buffered_messages():
 
 # Call this function periodically, e.g., in a separate thread
 def periodic_buffer_processing():
+    logger.info("Starting periodic buffer processing")
     while True:
         process_buffered_messages()
         time.sleep(5)  # Adjust sleep time as needed