binance websocket 例子python

以下是一个使用Python的Binance WebSocket API进行实时市场订阅的示例代码：

import websocket
import json

# 定义 WebSocket 连接地址
url = "wss://stream.binance.com:9443/ws"

# 定义要订阅的交易对
symbol = "btcusdt"

# 定义订阅的事件类型
event_type = "kline_1m"

# 定义回调函数，用于处理接收到的消息
def on_message(ws, message):
    data = json.loads(message)
    print("Received message:", data)

# 创建 WebSocket 连接
ws = websocket.WebSocketApp(f"{url}/{symbol}@{event_type}", on_message=on_message)

# 启动 WebSocket 连接
ws.run_forever()

在上述代码中，我们首先导入了`websocket`和`json`库。然后，定义了一个WebSocket的连接地址`url`，这里使用的是Binance的WebSocket API地址。

接下来，我们定义了要订阅的交易对`symbol`和事件类型`event_type`。在示例中，我们订阅了BTC/USDT交易对的1分钟K线数据。

然后，定义了一个回调函数`on_message`，用于处理接收到的消息。这个函数会在每次接收到消息时被调用，并将消息解析为JSON格式后打印出来。

最后，通过调用`websocket.WebSocketApp`创建一个WebSocket连接对象`ws`，并将订阅的交易对和事件类型作为参数传入其中。

最后，通过调用`ws.run_forever()`启动WebSocket连接，并使其一直运行，等待接收消息。

请注意，根据你的需求，你可以修改`symbol`和`event_type`来订阅不同的交易对和事件类型。此外，你还可以根据具体的Binance WebSocket API文档，处理不同类型的消息数据。