update

conf/example/bash/stop_dataupload_internal_one_hour.sh

@@ -1,2 +1,4 @@
 #!/bin/bash
 supervisorctl stop data_upload
+supervisorctl stop sensor_to_server
+supervisorctl stop sensor_to_local

sensor_to_server.py

@@ -232,6 +232,9 @@ def p():
             subprocess.Popen(
                 ["/usr/bin/bash /home/pi/lot_manager/conf/example/bash/stop_dataupload_internal_one_hour.sh"],
                 shell=True)
+            subprocess.Popen(
+                ["/usr/bin/bash /home/pi/lot_manager/conf/example/bash/stop_dataupload_internal_one_hour.sh"],
+                shell=True)
         except Exception as e:
             # print(e)
             pass

video_task.py

@@ -46,7 +46,7 @@ user_sched = {}
 
 async def close(username, device):
     # 倒计时600秒
-    await asyncio.sleep(600)
+    await asyncio.sleep(5)
     print(username + "结束推流")
     user_sched.pop(username)
     close_stream(username, device)