Python-Flask:前端客户端可以从连接到某个公司服务的 websocket 接收数据流吗?

问题描述

我有一个仪表板,其中包含我希望从订阅的 websocket 实时更新的数据 渠道。我目前正在使用 Flask 并通过请求和响应周期获取更新的数据。

我正在研究 Flask-SocketIO,但似乎无法弄清楚如何连接 websocket 从 Alpaca(数据源)获取数据并将该数据发送到我的仪表板网络客户端。

数据是否来自 1) Alapca => Flask => webclient?或 2) Alpaca => webclient => Flask => webclient?

我更喜欢案例 (1),因为我想做一些处理,也因为我刚刚开始在这个项目中第一次使用 javascript(但任何工作决定了选择)。

您会使用哪些包或库来完成此任务?你会怎么做? (我在 Windows 电脑上)

我目前有一个文件一个端口上运行烧瓶应用程序,另一个文件连接到 在另一个端口上流式传输数据的数据源。你如何将两者联系起来? Flask-SocketIO 和 Alpaca 可以在同一个端口上侦听/流数据吗?我环顾四周,找不到任何有帮助的例子。可以吗?

这似乎不符合犹太教规,但可以做以下类似的事情吗?

# Alpaca websocket connection: data inflow
@conn.on(r'^T.*$')
async def on_data(conn,channel,data):
    data_dict = data._raw
    print('data:',data_dict)

    # FastAPI websocket creation: pass-through/ data outflow
    @app.websocket("/ws")
    async def websocket_endpoint(websocket: WebSocket):
        await websocket.accept()

        while True:
            payload = data_dict 
            await websocket.send_json(payload)


conn.run(['T.AAPL']])

可以使用 Flask-SocketIO 来完成这样的事情吗?

参考资料: Connecting to Alpaca websocket Creating websocket using FastAPI

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)