发送emqq

emq_terminal.json

@@ -11,6 +11,13 @@
                 "random_type": 1,
                 "port": "a",
                 "port_address": 0
+            },
+            {
+                "measurement": "door",
+                "type": 0,
+                "random_type": 1,
+                "port": "c",
+                "port_address": 1
             }
         ]
     },
@@ -26,6 +33,13 @@
                 "random_type": 1,
                 "port": "a",
                 "port_address": 0
+            },
+            {
+                "measurement": "door",
+                "type": 0,
+                "random_type": 1,
+                "port": "c",
+                "port_address": 1
             }
         ]
     },
@@ -41,6 +55,13 @@
                 "random_type": 1,
                 "port": "a",
                 "port_address": 0
+            },
+            {
+                "measurement": "door",
+                "type": 0,
+                "random_type": 1,
+                "port": "c",
+                "port_address": 1
             }
         ]
     }

fake_terminal.py

@@ -73,9 +73,13 @@ def getTelemetry(param):
     l = len(param)
     tjsons = []
     for i in range(l):
+        v = random.randint(0, 1000)
+        # 门开关只有0 1
+        if param[i].get("measurement") == "door":
+            v = random.randint(0, 1)
         dataT = telemetryTemplate.format(port=param[i].get("port"), protAddress=param[i].get("port_address"),
                                          time=str(t),
-                                         measurement=param[i].get("measurement"), value=str(random.randint(0, 1000)))
+                                         measurement=param[i].get("measurement"), value=str(v))
         tJson = json.loads(dataT)
         tjsons.append(tJson)
     return json.dumps(tjsons)