qiangyanwen
/
monitoring
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add test

This commit is contained in:
qiangyanwen 2022-12-13 16:29:19 +08:00
parent 144cdf172c
commit 16ccf161ed
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
api/sys_monitor_api.py
View File

@ -9,7 +9,7 @@ import time
from fastapi import APIRouter, Body, Depends, Query, WebSocket, WebSocketDisconnect from fastapi import APIRouter, Body, Depends, Query, WebSocket, WebSocketDisconnect
from utils.mem import get_disk_info, get_sys_info, get_cpu_info, ge_mem_info from utils.mem import get_disk_info, get_sys_info, get_cpu_info, ge_mem_info
from utils.websocket_manager import manager from utils.websocket_manager import manager
from config.log import logger
router = APIRouter(prefix="/api", tags=["系统模块"]) router = APIRouter(prefix="/api", tags=["系统模块"])
@ -18,6 +18,8 @@ async def websocket_endpoint(
websocket: WebSocket websocket: WebSocket
): ):
await manager.connect(websocket) await manager.connect(websocket)
logger.info("ws开始连接....")
logger.info("websocket client ip==>{} port===>{}".format(websocket.client.host,websocket.client.port))
try: try:
while True: while True:
data = await websocket.receive() data = await websocket.receive()