币安 websocket例子

以下是使用币安 WebSocket API 获取最新交易更新的 Python 例子代码：

import websocket
import json

def on_message(ws, message):
    print(json.loads(message))

def on_error(ws, error):
    print(error)

def on_close(ws):
    print("### closed ###")

def on_open(ws):
    print("### opened ###")
    subscribe_message = {
        "method": "SUBSCRIBE",
        "params": [
            "btcusdt@aggTrade",
            "ethusdt@aggTrade"
        ],
        "id": 1
    }
    ws.send(json.dumps(subscribe_message))

if __name__ == "__main__":
    websocket.enableTrace(True)
    ws = websocket.WebSocketApp("wss://stream.binance.com:9443/ws",
                                on_message=on_message,
                                on_error=on_error,
                                on_close=on_close)
    ws.on_open = on_open
    ws.run_forever()

在上述代码中，我们使用了 `websocket` 模块和 `json` 模块，然后定义了四个回调函数，分别是 `on_message`、`on_error`、`on_close` 和 `on_open`。

`on_message` 函数用于接收和处理服务器发送的消息，这里我们只是简单地将其打印出来。

`on_error` 函数用于处理错误信息，我们只是简单地将其打印出来。

`on_close` 函数会在 WebSocket 连接关闭时被调用，我们也只是简单地将其打印出来。

`on_open` 函数则会在 WebSocket 连接建立时被调用，我们在这里发送了订阅消息，以便获取最新的交易更新。在这个例子中，我们订阅了 `btcusdt@aggTrade` 和 `ethusdt@aggTrade` 这两个交易对的最新交易更新。

最后，我们使用 `websocket.WebSocketApp` 创建了一个 WebSocket 对象，并调用 `run_forever` 方法来保持连接。