从reqHistoricalData提取多合约失败：结果字典值重复问题求助

兄弟，我太懂这种踩坑的感觉了！用IB的reqHistoricalData存字典时多个股票数据重复，十有八九是对象引用没处理好或者异步请求没同步导致的，我之前踩过一模一样的坑，给你捋捋排查和解决思路：

1. 检查DataFrame的初始化位置（最常见原因） #

如果你在for循环外面定义了全局的DataFrame，那每次请求都会往同一个对象里写入数据，最后字典里所有键都会指向这个唯一的DataFrame对象——看起来就是所有股票的数据都一样（其实是最后一次请求覆盖了之前的，或者所有数据混在一起了）。

错误写法示例： #

import pandas as pd
from ibapi.client import EClient
from ibapi.wrapper import EWrapper

# 错误：全局定义DataFrame，所有请求共用同一个对象
global_df = pd.DataFrame(columns=["date", "open", "high", "low", "close"])
result_dict = {}

class MyWrapper(EWrapper):
    def historicalData(self, reqId, bar):
        # 每次都往全局的global_df里加数据
        global_df.loc[len(global_df)] = [bar.date, bar.open, bar.high, bar.low, bar.close]

# 假设初始化客户端等操作省略
client = EClient(MyWrapper())
client.connect(...)

for symbol in ["SPY", "AAPL"]:
    # 创建合约省略
    contract = create_contract(symbol)
    client.reqHistoricalData(reqId=1, contract=contract, ...)
    # 直接把全局df存到字典里
    result_dict[symbol] = global_df

修正写法： #

把DataFrame的初始化放到循环内部，每次循环都新建一个独立的DataFrame，同时让回调函数绑定当前的DataFrame（可以用闭包或者类属性来实现）：

result_dict = {}

class MyWrapper(EWrapper):
    def __init__(self):
        self.current_df = None  # 用实例属性存当前处理的df
    
    def historicalData(self, reqId, bar):
        if self.current_df is not None:
            self.current_df.loc[len(self.current_df)] = [bar.date, bar.open, bar.high, bar.low, bar.close]

wrapper = MyWrapper()
client = EClient(wrapper)
client.connect(...)

for symbol in ["SPY", "AAPL"]:
    # 每次循环新建一个空df
    wrapper.current_df = pd.DataFrame(columns=["date", "open", "high", "low", "close"])
    contract = create_contract(symbol)
    client.reqHistoricalData(reqId=1, contract=contract, ...)
    # 存的时候最好用copy，避免后续修改影响字典里的值
    result_dict[symbol] = wrapper.current_df.copy()

2. 处理API的异步特性 #

IB的API是异步的，如果你在循环里直接存DataFrame，可能数据还没完全返回就执行了赋值操作，最后字典里的都是空的或者只存了部分数据，而最后一次请求的DataFrame会被所有键引用（因为循环快于数据返回）。

解决办法是用事件同步，每次请求完成后再进入下一次循环：

import threading

result_dict = {}

class MyWrapper(EWrapper):
    def __init__(self):
        self.current_df = None
        self.data_ready = threading.Event()  # 用事件标记数据接收完成
    
    def historicalData(self, reqId, bar):
        self.current_df.loc[len(self.current_df)] = [bar.date, bar.open, bar.high, bar.low, bar.close]
    
    def historicalDataEnd(self, reqId, startDateStr, endDateStr):
        # 数据接收完成时触发事件
        self.data_ready.set()

wrapper = MyWrapper()
client = EClient(wrapper)
client.connect(...)

for symbol in ["SPY", "AAPL"]:
    wrapper.current_df = pd.DataFrame(columns=["date", "open", "high", "low", "close"])
    wrapper.data_ready.clear()  # 重置事件
    contract = create_contract(symbol)
    client.reqHistoricalData(reqId=1, contract=contract, ...)
    wrapper.data_ready.wait()  # 等待数据接收完成
    result_dict[symbol] = wrapper.current_df.copy()

快速排查技巧 #

你可以先打印字典里每个值的内存地址，确认是不是同一个对象：

print(id(result_dict["SPY"]))
print(id(result_dict["AAPL"]))

如果两个地址相同，那100%是对象引用的问题——你所有键都指向了同一个DataFrame。

另外，每次循环后打印当前的current_df，看看是不是已经正确加载了当前股票的数据，再存入字典。

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