82 lines
2.5 KiB
Python
82 lines
2.5 KiB
Python
# _*_ coding: utf-8 _*_
|
|
# @Time :2022/5/29 09:15
|
|
# @Email :508737091@qq.com
|
|
# @Author :qiangyanwen
|
|
# @File :sys_monitor_api.py
|
|
import time
|
|
|
|
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.response import success_200
|
|
from fastapi.responses import HTMLResponse
|
|
from utils.websocket_manager import manager
|
|
|
|
router = APIRouter(prefix="/api", tags=["系统模块"])
|
|
|
|
|
|
@router.get("/sys/disk", summary="获取磁盘信息", name="获取磁盘信息")
|
|
async def get_disk():
|
|
return success_200(data=await get_disk_info(), message="查询磁盘信息成功")
|
|
|
|
|
|
@router.get("/sys/info", summary="获取系统信息", name="获取系统信息")
|
|
async def get_sys():
|
|
return success_200(data=await get_sys_info(), message="查询系统信息成功")
|
|
|
|
|
|
@router.get("/sys/cpu", summary="获取cpu信息", name="获取cpu信息")
|
|
async def get_cpu():
|
|
return success_200(data=await get_cpu_info(), message="查询cpu信息成功")
|
|
|
|
|
|
@router.get("/sys/memory", summary="获取内存信息", name="获取内存信息")
|
|
async def get_mem():
|
|
return success_200(data=await ge_mem_info(), message="查询内存信息成功")
|
|
|
|
|
|
html = """
|
|
<!DOCTYPE html>
|
|
<html>
|
|
<head>
|
|
<title>Chat</title>
|
|
</head>
|
|
<body>
|
|
<h1>WebSocket Chat</h1>
|
|
<form action="" onsubmit="sendMessage(event)">
|
|
<input type="text" id="messageText" autocomplete="off"/>
|
|
<button>Send</button>
|
|
</form>
|
|
<ul id='messages'>
|
|
</ul>
|
|
<script>
|
|
var ws = new WebSocket("ws://localhost:8000/items/ws");
|
|
ws.onmessage = function(event) {
|
|
var messages = document.getElementById('messages')
|
|
var message = document.createElement('li')
|
|
var content = document.createTextNode(event.data)
|
|
message.appendChild(content)
|
|
messages.appendChild(message)
|
|
};
|
|
function sendMessage(event) {
|
|
var input = document.getElementById("messageText")
|
|
ws.send(input.value)
|
|
input.value = ''
|
|
event.preventDefault()
|
|
}
|
|
</script>
|
|
</body>
|
|
</html>
|
|
"""
|
|
@router.get("/")
|
|
async def get():
|
|
return HTMLResponse(html)
|
|
|
|
@router.websocket("/items/ws")
|
|
async def websocket_endpoint(
|
|
websocket: WebSocket
|
|
):
|
|
await websocket.accept()
|
|
while True:
|
|
data = await websocket.receive_text()
|
|
await websocket.send_text(f"消息是: {data}")
|