test bandwidth

labs/labs-internal/emqx/app/src/base.py

@@ -7,7 +7,7 @@
 from paho.mqtt import client as mqttc
 from paho.mqtt import __version__ as mqtt_version
 
-__VER__ = '0.0.1'
+__VER__ = '0.1.2'
 
 
 

labs/labs-internal/emqx/app/src/reader.py

@@ -32,10 +32,25 @@ def on_message(self, client, userdata, msg, *args, **kwargs):
 
   def display_stats(self, ):
     """Periodically display message stats."""
+    start = time.time()
     while True:
+      good, bad = 0, 0
+      counter = 0
+      if len(self.messages) == 0:
+        time.sleep(1)
+        start = time.time()
+        continue
       for sender, sum_ in self.messages.items():
-        self.P("----------------------------------------")
-        self.P(f"{sender} -> sum -> {sum_} (id: {self.counters[sender]})")
+        if sum_ == self.counters[sender]:
+          good +=1
+        else:
+          bad += 1
+        counter += self.counters[sender]
+      msg = "Stats: {} senders, {} stable, {} unstable, {:.0f} msgs/sec".format(
+        len(self.messages), 
+        good, bad, 
+        counter/(time.time()-start))
+      self.P(msg)
       time.sleep(10)  # Adjust as necessary
     return