Binance ThreadedWebsocketManager无法显示价格流 运行后无输出

运行Binance实时行情流式获取代码时，进程无报错正常驻留，但控制台始终空白无输出，原代码如下：

import os
from binance.client import Client
import time
from binance import ThreadedWebsocketManager
from binance import ThreadedDepthCacheManager

api_key = os.environ.get('api_key')
api_secret = os.environ.get('api_secret')
client = Client(api_key, api_secret)

def main():

    symbol = 'BTCUSDT'
    twm = ThreadedWebsocketManager(api_key=api_key, api_secret=api_secret)
    
    #Start is required to initialise its internal loop
    twm.start()

    def handle_socket_message(msg):
        print(f"message type: {msg['e']}")
        print(msg)

    twm.start_kline_socket(callback=handle_socket_message, symbol=symbol)
    
    twm.join()

if __name__ == "__main__":
   main()

四个高频触发点：

• Python默认stdout缓冲机制：非终端直连场景下（IDE运行、输出重定向等），print不会实时把内容刷到控制台，要攒够缓冲区大小才会输出，看起来就像没有任何打印。
• 旧版本python-binance兼容性问题：未显式指定K线周期时，部分版本默认参数异常，导致订阅请求实际没有发送成功。
• 网络连通性问题：Binance WebSocket行情服务对国内网络直连做了限制，连接失败时库内部没有抛出可见异常，进程会一直卡在等待消息的状态。
• 冗余参数干扰：K线行情属于公开接口，不需要API密钥即可订阅，传了错误/无效的密钥反而可能触发连接异常。

直接替换成调整后的代码即可：

from binance.client import Client
from binance import ThreadedWebsocketManager

def main():
    symbol = 'BTCUSDT'
    # 公开行情接口无需传API密钥
    twm = ThreadedWebsocketManager()
    twm.start()

    def handle_socket_message(msg):
        # 加flush=True强制刷新输出缓冲
        print(f"message type: {msg['e']}", flush=True)
        print(msg, flush=True)

    # 显式指定K线周期，按需替换成1m/5m/1h等周期即可
    twm.start_kline_socket(
        callback=handle_socket_message,
        symbol=symbol,
        interval=Client.KLINE_INTERVAL_1MINUTE
    )

    twm.join()

if __name__ == "__main__":
    main()

如果替换代码后还是无输出，按顺序检查：

• 先升级python-binance到最新版本，执行命令pip install -U python-binance，修复旧版本已知的连接bug。
• 确认本地网络可以正常访问Binance服务，直连失败的话需要给程序配置可用的代理。
• 如果是在PyCharm等IDE中运行，打开运行配置，勾选「Emulate terminal in output console」选项，避免IDE本身的输出缓冲拦截内容。

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