xyj
/
lot_manager
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

This commit is contained in:
xyj 2024-01-02 14:59:36 +08:00
parent d9221df692
commit 5beb69024d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test.py
View File

@ -43,12 +43,12 @@ async def close(username, device):
# 倒计时600秒 # 倒计时600秒
await asyncio.sleep(600) await asyncio.sleep(600)
user_sched.pop(username) user_sched.pop(username)
print(username + "结束推流") # print(username + "结束推流")
close_stream(username, device) close_stream(username, device)
async def task_start(username, device): async def task_start(username, device):
print(username + "开始推流") # print(username + "开始推流")
push_stream(username, device) push_stream(username, device)
task = asyncio.create_task(close(username, device)) task = asyncio.create_task(close(username, device))
user_sched[username] = task user_sched[username] = task
@ -91,4 +91,4 @@ def close_stream(username, device):
if __name__ == '__main__': if __name__ == '__main__':
broker = 'mqtt.lihaink.cn' broker = 'mqtt.lihaink.cn'
port = 1883 port = 1883
uvicorn.run(app, host="127.0.0.1", port=8001) uvicorn.run(app, host="0.0.0.0", port=8001)