我的Python代码用于从IB API下载历史数据无法正常工作。

Question

我的代码如下，但它没有返回任何结果（没有错误，只是返回了“done”）：

from ibapi.client import EClient
from ibapi.wrapper import EWrapper
from ibapi.contract import Contract
import threading

# 定义继承自EWrapper和EClient的IBapi类
class IBapi(EWrapper, EClient):
    def __init__(self):
        EClient.__init__(self, self)
    def tickPrice(self, reqId, tickType, price, attrib):
        if tickType == 2 and reqId == 1:
            print('当前卖价为：', price)
    def historicalData(self, reqId, bar):
        print(reqId, bar.date, bar.high, bar.low, bar.volume)

# 定义循环运行函数
def run_loop():
    app.run()

# 创建IBapi实例并连接至本地服务器
app = IBapi()
app.connect('127.0.0.1', 7497, 123)
api_thread = threading.Thread(target=run_loop, daemon=True)
api_thread.start()

# 创建一个期货合约对象
contract = Contract()
contract.symbol = "VIX"
contract.secType = "FUT"
contract.exchange = "CFE"
contract.currency = "USD"
contract.lastTradeDateOrContractMonth = "20240117"
contract.multiplier = "1000"
contract.includeExpired = True

# 请求历史数据
app.reqHistoricalData(1, contract, "", "1 M", "30 mins", "bid", 0, 1, False, [])

# 断开与服务器的连接
app.disconnect()

print("完成")

我记得之前我运行过非常类似的代码，当时是正常的。请问有人能告诉我现在的代码中哪里出错了吗？

非常感谢！

Cheeso · Answer

您的代码在收到历史数据之前就断开了连接，因此没有显示任何结果。下面的修改版代码会解决这个问题：

import threading
from ibapi.client import EClient
from ibapi.wrapper import EWrapper
from ibapi.contract import Contract

# 定义IBapi类，增加了一个事件标志data_received
class IBapi(EWrapper, EClient):
    def __init__(self):
        EClient.__init__(self, self)
        self.data_received = threading.Event()

    # 当接收到历史数据时，触发data_received事件
    def historicalData(self, reqId, bar):
        print(reqId, bar.date, bar.high, bar.low, bar.volume)
        self.data_received.set()

# 创建IBapi实例并连接至本地服务器
app = IBapi()
app.connect('127.0.0.1', 7497, 123)

# 启动API运行线程
api_thread = threading.Thread(target=app.run, daemon=True)
api_thread.start()

# 创建期货合约对象
contract = Contract()
contract.symbol = "VIX"
contract.secType = "FUT"
contract.exchange = "CFE"
contract.currency = "USD"
contract.lastTradeDateOrContractMonth = "20240117"
contract.multiplier = "1000"
contract.includeExpired = True

# 请求历史数据
app.reqHistoricalData(1, contract, "", "1 M", "30 mins", "bid", 0, 1, False, [])

# 等待历史数据接收完成（data_received事件被触发）
app.data_received.wait()

# 数据接收完成后断开连接
app.disconnect()

print("完成")

Jordan Running · Answer

我发现了解决方法，并做了两个调整：

在 api_thread.start() 之后，我添加了一些等待时间，即：

   api_thread.start()
   time.sleep(2)

然后我注意到，在TWS应用程序运行时，它被最小化了，因此没有给出任何结果。一旦将其最大化而不是最小化，代码就能如我所愿地给出结果。

感谢你的帮助。