dimValue key has now topic address, topic name and topic port

HSLdevcom · Aug 22, 2022 · b52c7d3 · b52c7d3
1 parent aca2a30
commit b52c7d3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/mqtt_data_collector.py b/mqtt_data_collector.py
@@ -123,7 +123,8 @@ def main():
         if time.time() > time_end:
             topic_data_map = {}
             for topic in topic_list:
-                topic_data_map[topic.topic_name] = topic.msg_count
+                topic_data_map_key = f"{topic.topic_address}:{topic.topic_name}:{topic.topic_port}"
+                topic_data_map[topic_data_map_key] = topic.msg_count
                 topic.msg_count = 0
 
             if IS_DEBUG: