问题描述
我有一个仪表板,其中包含我希望从订阅的 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 (将#修改为@)