使用Python IBKR API获取期权链Delta对应行权价遇数据接收问题

刚接触Python和IBKR API，尝试获取Delta接近0.20的期权行权价，后续还要获取该行权价的中间价，但运行代码后无数据返回，进程以退出码0结束。原代码如下：

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


class TestApp(EWrapper, EClient):
    def __init__(self):
        EClient.__init__(self, self)
        self.nextOrderId = 0
        self.permId2ord = {}
        self.strike = 160

    def error(self, reqId, errorCode, errorString):
        print(f"Error: {reqId} {errorCode} {errorString}")

    def nextValidId(self, orderId: int):
        self.req_data(orderId)

    def req_data(self, orderId):
        optcontract = Contract()
        optcontract.symbol = "AAPL"
        optcontract.secType = "OPT"
        optcontract.exchange = "SMART"
        optcontract.currency = "USD"
        optcontract.lastTradeDateOrContractMonth = "20240419"
        optcontract.strike = self.strike
        optcontract.right = "P"

        self.reqMarketDataType(4)
        self.reqMktData(orderId, optcontract, '106', False, False, [])

    def tickOptionComputation(self, reqId: int, tickType: int, impliedVol,
                              delta, optPrice, pvDividend,
                              gamma, vega, theta, undPrice):
        print(f"Delta: {delta} for option with reqId {reqId}")
        if delta > 0.22:
            self.strike -= 5
            self.req_data(reqId + 1)
        elif delta < 0.18:
            self.strike += 5
            self.req_data(reqId + 1)
        else:
            print(f"Found an option with Delta in the desired range. Strike: {self.strike} Delta: {delta}")
            self.cancelMktData(reqId)


def main():
    app = TestApp()
    app.connect('127.0.0.1', 7497, 0)
    app.nextOrderId = 0
    # Call an initial request for OrderId increments
    app.reqIds(-1)
    # Initialize the run loop
    api_thread = threading.Thread(target=lambda: app.run(), daemon=True)
    api_thread.start()

    time.sleep(10)
    app.disconnect()


if __name__ == "__main__":
    main()

问题根源分析 #

• 到期日已过期：原代码指定的20240419已过，IBKR不会返回过期期权的市场数据
• Delta判断逻辑错误：看跌期权（right="P"）的Delta为负数，原代码直接判断delta>0.22或delta<0.18，永远无法命中条件
• 初始行权价不合理：AAPL当前股价远高于160，该行权价的看跌期权Delta绝对值接近1，偏离目标范围
• 缺少中间价获取逻辑：未处理tickPrice回调，无法捕获bid/ask价计算中间价
• 固定sleep不可靠：time.sleep(10)可能在数据返回前就断开连接

修复后的代码 #

import threading
from ibapi.client import EClient
from ibapi.wrapper import EWrapper
from ibapi.contract import Contract
from ibapi.common import TickTypeEnum
from threading import Event


class TestApp(EWrapper, EClient):
    def __init__(self):
        EClient.__init__(self, self)
        self.nextOrderId = 0
        self.target_delta = 0.20
        self.delta_tolerance = 0.02
        self.strike = 190  # 初始行权价设为AAPL当前股价附近
        self.found_target = Event()
        self.bid_price = None
        self.ask_price = None

    def error(self, reqId, errorCode, errorString):
        print(f"Error: {reqId} {errorCode} {errorString}")

    def nextValidId(self, orderId: int):
        self.nextOrderId = orderId
        self.req_data(orderId)

    def req_data(self, orderId):
        optcontract = Contract()
        optcontract.symbol = "AAPL"
        optcontract.secType = "OPT"
        optcontract.exchange = "SMART"
        optcontract.currency = "USD"
        optcontract.lastTradeDateOrContractMonth = "20241018"  # 未到期的期权到期日
        optcontract.strike = self.strike
        optcontract.right = "P"
        optcontract.primaryExchange = "NASDAQ"  # 补充主交易所，避免合约歧义

        self.reqMarketDataType(4)  # 请求实时数据
        self.reqMktData(orderId, optcontract, '106', False, False, [])

    def tickOptionComputation(self, reqId: int, tickType: int, impliedVol,
                              delta, optPrice, pvDividend,
                              gamma, vega, theta, undPrice):
        abs_delta = abs(delta)
        print(f"当前行权价: {self.strike} | Delta绝对值: {abs_delta:.4f}")
        
        if abs_delta > self.target_delta + self.delta_tolerance:
            # Delta绝对值过大，上调看跌期权行权价（股价越高，看跌期权Delta绝对值越小）
            self.strike += 5
            self.cancelMktData(reqId)
            self.req_data(reqId + 1)
        elif abs_delta < self.target_delta - self.delta_tolerance:
            # Delta绝对值过小，下调看跌期权行权价
            self.strike -= 5
            self.cancelMktData(reqId)
            self.req_data(reqId + 1)
        else:
            print(f"找到目标期权 | 行权价: {self.strike} | Delta绝对值: {abs_delta:.4f}")
            # 等待捕获bid/ask价
            self.found_target.wait(timeout=2)
            if self.bid_price and self.ask_price:
                mid_price = (self.bid_price + self.ask_price) / 2
                print(f"该行权价中间价: {mid_price:.2f}")
            self.cancelMktData(reqId)
            self.found_target.set()

    def tickPrice(self, reqId: int, tickType: int, price: float, attrib):
        # 记录bid和ask价格
        if tickType == TickTypeEnum.BID:
            self.bid_price = price
        elif tickType == TickTypeEnum.ASK:
            self.ask_price = price


def main():
    app = TestApp()
    app.connect('127.0.0.1', 7497, 0)
    
    # 启动API运行线程
    api_thread = threading.Thread(target=app.run, daemon=True)
    api_thread.start()

    # 等待找到目标期权或超时（30秒）
    app.found_target.wait(timeout=30)
    app.disconnect()


if __name__ == "__main__":
    main()

关键修复点说明 #

• 修正到期日：使用未到期的期权合约日期，确保IBKR返回有效数据
• Delta逻辑修正：判断Delta的绝对值，符合看跌期权的Delta特性
• 合理初始行权价：设为标的当前股价附近，减少行权价调整次数
• 中间价获取：通过tickPrice回调捕获bid和ask价，计算中间价
• 可靠等待机制：用Event同步等待目标期权找到，替代固定sleep，避免提前断开

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