如何在调用更新后端状态的函数时从python (fastapi)发送服务器端事件

pip install python-socketio

from fastapi import FastAPI
from fastapi import WebSocket
from fastapi.responses import HTMLResponse
from fastapi.staticfiles import StaticFiles
import socketio

app = FastAPI()

sio = socketio.AsyncServer(async_mode='asgi')
socket_app = socketio.ASGIApp(sio, static_files={"/": "path/to/static/files"})

app.mount("/socket.io", socket_app)
app.mount("/", StaticFiles(directory="path/to/static/files"), name="static")

@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
    await websocket.accept()
    while True:
        data = await websocket.receive_text()
        # 在这里调用更新后端状态的函数，并处理相应的逻辑
        # ...

        # 发送服务器端事件给所有连接的客户端
        await sio.emit('event_name', data)

var socket = io.connect('http://your_server_address/ws');

socket.on('event_name', function(data) {
    // 处理接收到的服务器端事件
    // ...
});