From 9cbaef07f4e90bb205c6636b7777fe53866b7dc8 Mon Sep 17 00:00:00 2001
From: xyj <10908227994@qq.com>
Date: Wed, 3 Jan 2024 14:05:55 +0800
Subject: [PATCH] update

---
 test.py | 20 ++++++--------------
 1 file changed, 6 insertions(+), 14 deletions(-)

diff --git a/test.py b/test.py
index cd645b5..7cab03b 100644
--- a/test.py
+++ b/test.py
@@ -77,25 +77,17 @@ async def startup(username, device):
 
 def push_stream(username, device):
     MQTT = MQTTClient(broker, port, device, username, username)
-    try:
-        MQTT.start()
-        MQTT.push()
-    except Exception as e:
-        # print(e)
-        pass
+    MQTT.start()
+    MQTT.push()
 
 
 def close_stream(username, device):
-    try:
-        MQTT = MQTTClient(broker, port, device, username, username)
-        MQTT.start()
-        MQTT.close()
-    except Exception as e:
-        # print(e)
-        pass
+    MQTT = MQTTClient(broker, port, device, username, username)
+    MQTT.start()
+    MQTT.close()
 
 
 if __name__ == '__main__':
     broker = 'mqtt.lihaink.cn'
     port = 1883
-    uvicorn.run(app, host="127.0.0.1", port=8001)
+    uvicorn.run(app, host="127.0.0.1", port=8000)