使用ib_insync获取多标的最新价时ib传参与返回nan问题

1. ib对象传入自定义函数的修正 #

你写的df.apply中的lambda存在语法错误，逗号把ib和函数调用分隔开，导致ib没有被正确传入自定义函数，正确写法如下：

# 正确的apply写法，把ib作为第一个参数传入自定义函数
hk['last'] = hk.apply(lambda x: last_live_price(
    ib=ib,
    symbol_in=x['symbol'],
    exchange_in=x['exchange'],
    currency_in=x['currency']
), axis=1)

你单独调用函数的写法本身是正确的不需要修改。如果要简化写法适配你允许用全局变量的场景，也可以直接去掉函数定义中的ib参数，函数内部直接读取全局的ib对象即可。

2. 函数返回nan的修复 #

返回nan核心有两个问题：

• 不能用标准库的time.sleep，会阻塞ib_insync的异步事件循环，导致行情数据无法正常接收，需要替换为ib_insync自带的ib.sleep()
• 建议先校验合约有效性，避免合约配置错误导致拿不到数据，同时可以加兜底逻辑，拿不到最新成交价时用买卖价的中间值兜底
  修正后的函数代码：

def last_live_price(ib, symbol_in, exchange_in, currency_in):
    # 先校验合约有效性，提前识别合约配置错误
    contract = Stock(symbol=symbol_in, exchange=exchange_in, currency=currency_in)
    ib.qualifyContracts(contract)
    # 请求快照行情
    last_live = ib.reqMktData(contract, genericTickList='', snapshot=True, regulatorySnapshot=False, mktDataOptions=None)
    # 用ib.sleep替代time.sleep，不阻塞事件循环保证行情正常接收
    ib.sleep(5)
    # 优先取最新成交价，取不到则用买卖价中间值兜底
    last = last_live.last
    if not last or pd.isna(last):
        if last_live.bid and last_live.ask:
            last = (last_live.bid + last_live.ask) / 2
    # 取消行情订阅避免占用TWS的行情额度
    ib.cancelMktData(contract)
    return last

额外注意：

• 确认你的TWS/IB Gateway已经开启API权限，端口号和连接环境匹配（实盘TWS默认7496，模拟盘默认7497，IB Gateway实盘4001、模拟盘4002）
• 确认使用的clientId没有被其他进程占用
• 确认你的IB账户有对应交易市场的行情权限，无权限也会返回nan

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