FastAPI 在子进程中从 websocket 发送

Posted

技术标签:

【中文标题】FastAPI 在子进程中从 websocket 发送【英文标题】:FastAPI sending from websocket in subprocess 【发布时间】:2021-05-21 13:28:35 【问题描述】:

从我正在运行的主循环中:

task = Process(
            target=sub_process 
            args=(socket,),
            daemon=True
        )

然后在sub_process 我开始一个新的异步事件循环并调用 await socket.send_json(...) 但它似乎没有发送任何东西。我没有收到任何错误,我只是可以在客户端上看到任何内容。。知道发生了什么或补救措施吗?

【问题讨论】:

【参考方案1】:

不知道为什么它不起作用,但我使用队列与主线程通信,然后从那里发送消息。

【讨论】:

以上是关于FastAPI 在子进程中从 websocket 发送的主要内容,如果未能解决你的问题,请参考以下文章

FastAPI中音频流的Websockets桥接器

FastAPI websocket 无法处理大量数据传入?

如何从 fastapi websocket 答案中获取“lastEventId”?

在 Python FastAPI 中使用 websocket 并行发送/接收

如何在没有 html/js 的情况下捕获 fastapi websocket 消息?

尝试使用 websockets 从 FastAPI 获取实时数据流时如何修复错误(不支持的升级请求。)?