如何解决处理 Websocket 数据馈送 (Python)
我已经成功订阅了 Bitstamp websockets 提要,但我正在努力寻找一种方法来处理我收到的数据。这是我的代码:
import asyncio
import websockets
import json
async def bitstamp_connect():
uri = "wss://ws.bitstamp.net/"
subscription = {
"event": "bts:subscribe","data": {
"channel": "order_book_btcusd"
}
}
async with websockets.connect(uri) as websocket:
await websocket.send(json.dumps(subscription))
while True:
print(json.loads(await websocket.recv()))
websocket_data = asyncio.get_event_loop().run_until_complete(bitstamp_connect())
处理此数据流的最佳方法是什么?我希望能够定义一个不断更新的变量(例如 best_price)。就像我上面的代码一样,当我打印数据时,我可以看到它在控制台上流式传输,但是当我返回数据并将其传递给处理程序函数时,流结束。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。