无法在 FastAPI websocket 中从客户端获取数据 | Python

Question

我在 fastapi 日志中收到此错误：

INFO:     ('172.28.0.1', 35088) - "WebSocket /ws" [accepted]
INFO:     connection open
ERROR:    Exception in ASGI application
...
    await self.app(scope, receive, send)
    File "/usr/local/lib/python3.9/site-packages/starlette/exceptions.py", line 58, in __call__
    await self.app(scope, receive, send)
    File "/usr/local/lib/python3.9/site-packages/starlette/routing.py", line 580, in __call__
    await route.handle(scope, receive, send)
    File "/usr/local/lib/python3.9/site-packages/starlette/routing.py", line 297, in handle
    await self.app(scope, receive, send)
    File "/usr/local/lib/python3.9/site-packages/starlette/routing.py", line 68, in app
    await func(session)
    File "/usr/local/lib/python3.9/site-packages/fastapi/routing.py", line 273, in app
    await dependant.call(**values)
    File "/code/./app/main.py", line 127, in websocket_endpoint
    data = await websocket.receive_text()
     File "/usr/local/lib/python3.9/site-packages/starlette/websockets.py", line 85, in receive_text
     self._raise_on_disconnect(message)
    File "/usr/local/lib/python3.9/site-packages/starlette/websockets.py", line 80, in _raise_on_disconnect
    raise WebSocketDisconnect(message["code"])
    starlette.websockets.WebSocketDisconnect: 1000
    INFO:     connection closed

我找不到问题。为什么我的 fastapi 路由无法从客户端获取数据，但服务器向客户端发送的消息有效。

客户端代码：

import asyncio
from time import sleep
import websockets

async def get_work():
    async with websockets.connect("ws://localhost:3000/ws", open_timeout=None) as websocket:
        await websocket.send('Hello from CLient')
        answer = await websocket.recv()
        print(answer)
         
while True:
    asyncio.run(get_work())
    sleep(5)

服务器代码：

@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
    await websocket.accept()
    while True:
        try:
            data = await websocket.receive_text()
            print(data)
        except RuntimeError:
            break
        await websocket.send_text("Hello from Server") 

非常感谢您的帮助！