websocket 接收实时数据 python代码

以下是一个 Python WebSocket 接收实时数据的示例代码：

import websocket
import json

def on_message(ws, message):
    # 处理接收到的数据
    data = json.loads(message)
    print(data)

def on_error(ws, error):
    # 处理错误
    print(error)

def on_close(ws):
    # 处理关闭事件
    print("WebSocket closed")

def on_open(ws):
    # 连接成功后发送请求
    ws.send(json.dumps({"type": "subscribe", "symbol": "btcusdt@trade"}))

if __name__ == "__main__":
    # 创建 WebSocket 连接
    ws = websocket.WebSocketApp("wss://stream.binance.com:9443/ws")

    # 注册事件回调函数
    ws.on_message = on_message
    ws.on_error = on_error
    ws.on_close = on_close
    ws.on_open = on_open

    # 启动 WebSocket
    ws.run_forever()

这段代码演示了如何使用 Python 中的 websocket 模块接收币安交易所的实时交易数据。当连接成功后，代码会发送一个订阅请求，然后不断接收新的数据并进行处理。