Python Websockets Client连接建立成功但终端不打印消息问题排查

核心问题梳理 #

• 交易对参数错误：币安公开WebSocket流不支持btcusd交易对，现货场景需替换为币安官方支持的全小写交易对，例如btcusdt，若使用合约交易对需对应调整接口路径规则。
• 回调函数参数不匹配：你使用的websocket-client新版库中，on_close回调要求传入3个参数（ws实例、关闭状态码、关闭描述），仅定义1个参数会触发参数不匹配异常，导致事件循环异常终止，既看不到报错也收不到消息。
• 缺少错误监听逻辑：未定义on_error回调，运行过程中抛出的所有异常都不会被打印，无法定位具体故障。
• 网络访问限制：币安WebSocket服务在中国大陆地区无法直接访问，需确保你的运行环境配置了合规的网络代理，否则即使连接握手成功也无法收到下行数据流。

修复后可运行代码 #

import websocket
import json

# 替换为币安官方支持的交易对，这里以btcusdt现货为例
cc = 'btcusdt'
interval = '1m'
socket = f'wss://stream.binance.com:9443/ws/{cc}@kline_{interval}'

print('代码初始化执行完成')

def on_open(ws):
    print("连接已建立")

def on_message(ws, message):
    # 可以直接打印原始消息，也可以解析后打印结构化数据
    print("收到消息：", json.loads(message))

def on_error(ws, error):
    print("发生错误：", error)

# 适配新版websocket库的参数要求
def on_close(ws, close_status_code, close_msg):
    print(f"连接已关闭，状态码：{close_status_code}，关闭信息：{close_msg}")

if __name__ == "__main__":
    ws = websocket.WebSocketApp(
        socket,
        on_open=on_open,
        on_message=on_message,
        on_error=on_error,
        on_close=on_close
    )
    # 如果需要配置代理可以在这里添加参数，例如http_proxy_host、http_proxy_port
    ws.run_forever()

验证步骤 #

1. 确认交易对在币安平台存在，可登录币安交易页核对对应交易对的名称拼写，全部转为小写后再填入代码。
2. 确保运行环境的网络可以正常访问币安服务，必要时在run_forever方法中添加代理配置参数。
3. 运行代码后如果连接正常，每次K线数据更新时都会在终端打印对应的结构化K线数据。

内容的提问来源于stack exchange，提问作者Precious Chika