使用ib_insync请求多只股票行情数据时回调函数异常求助

核心问题点 #

1. 重复绑定回调函数：你把ib.pendingTickersEvent += wait_for_market_data放在循环内部，每次循环都会给事件多绑定一次回调，导致后续行情推送时回调被多次触发。
2. 闭包变量引用错误：回调里的market_data是循环中的局部变量，循环结束后它会指向最后一个标的（AAPL）的Ticker对象，所以无论哪个标的的行情推送，打印的都是AAPL的数据。
3. 重复订阅行情：while True循环一直在重复调用reqMktData订阅同一批股票，这完全没必要——IB的行情订阅是持续性的，订阅一次就会持续推送最新数据，重复订阅只会造成资源浪费。

修正后的代码 #

from ib_insync import *

watch_dict = {"TSLA": "NYSE",
              "MSFT": "NYSE",
              "AAPL": "NYSE"}

def wait_for_market_data(tickers):
    # 遍历推送过来的所有ticker，打印对应标的的行情
    for ticker in tickers:
        print(f"标的: {ticker.contract.symbol}")
        print(f"最新价: {ticker.last}")
        print(f"买一价: {ticker.bid}")
        print(f"卖一价: {ticker.ask}")
        print()

# 创建连接
ib = IB()
ib.connect('127.0.0.1', 7497, clientId=1)

# 只绑定一次回调，避免重复触发
ib.pendingTickersEvent += wait_for_market_data

# 批量订阅行情，只订阅一次即可
subscribed_tickers = []
for symbol, exchange in watch_dict.items():
    stock = Stock(symbol, exchange, 'USD')
    ticker = ib.reqMktData(stock, '', False, False)
    subscribed_tickers.append(ticker)
    print(f"已订阅 {symbol}")

# 启动事件循环，持续接收行情
ib.run()

关键修改说明 #

• 回调函数直接使用事件推送的tickers参数：pendingTickersEvent触发时会把所有有更新的Ticker对象传进来，遍历这些对象就能获取每个标的的最新行情，彻底解决变量引用问题。
• 回调绑定移到循环外：确保回调只被注册一次，避免重复触发。
• 移除while True循环：行情订阅只需执行一次，IB会持续推送最新数据，不需要重复请求。
• 存储订阅的Ticker对象：方便后续如果需要取消订阅或直接访问标的行情时使用。

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