Message count as messages per second

HSLdevcom · Aug 18, 2022 · e969fe3 · e969fe3
1 parent 7b1b680
commit e969fe3
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/mqtt_data_collector.py b/mqtt_data_collector.py
@@ -1,5 +1,6 @@
 import paho.mqtt.client as mqtt
 import time
+import math
 import json
 from datetime import datetime
 from threading import Thread
@@ -157,6 +158,9 @@ def get_series_array(topic_data_collection):
     for key in topic_data_collection:
         topic_msg_count = topic_data_collection[key]
 
+        # We want message count to be message per second
+        topic_msg_count = math.ceil(topic_msg_count/MONITOR_PERIOD_IN_SECONDS)
+
         # Azure doesn't seem to like # in a dimValue, replace it with *
         parsed_key = key.replace("#", "*")
         # Azure doesn't seem to like + in a dimValue, replace it with ^