如何在Interactive Brokers导出账户组合信息

Question

我想用一个数据框来存储我的投资组合信息，并每分钟更新一次。但是下面代码的结果是空的，我是否遗漏了什么？

from ibapi.client import EClient
from ibapi.wrapper import EWrapper
from ibapi.contract import Contract
from ibapi.ticktype import TickTypeEnum
import pandas as pd
import time


class IBapi(EWrapper, EClient):


    def __init__(self):
        EClient.__init__(self, self)
        self.all_positions = pd.DataFrame([], columns=['ConID', 'Symbol', 'Quantity', 'Average Cost', 'MarketPrice', 'marketValue', 'unrealizedONL', 'realizedPNL'])

    def updatePortfolio(self, contract: Contract, position: float, marketPrice: float, marketValue: float,averageCost: float, unrealizedPNL: float, realizedPNL:float, accountName:str):
        super().updatePortfolio(contract, position, marketPrice, marketValue, averageCost, unrealizedPNL, realizedPNL, accountName)
        index = str(contract.conId)
        self.all_positions.loc[index] = contract.conId, contract.symbol, position, averageCost, marketPrice, marketValue, unrealizedPNL, realizedPNL


def main():

    app = IBapi()
    app.connect('127.0.0.1', 7497, 0)
    app.reqAccountUpdates(True, "XXXXXXXX")
    current_positions = app.reqAccountUpdates(True, "XXXXXXX")

    app.run()
    print(current_positions.to_string())
    app.disconnect()

if __name__ == "__main__":
    main()

Answer 1

reqAcccountUpdates是一个异步函数调用，它发送一条传出消息，但不等待响应。（由于消息启动了对数据流的订阅，因此返回的不是单个响应，而是一系列响应）。

所以当前位置在：

current_positions = app.reqAccountUpdates(True, "XXXXXXX")

永远都不会有。相反，响应存储在应用程序中。所有_位置由被覆盖的updatePortfolio（）函数覆盖。

此外，run（）循环是一个无限循环，因此后面的行将无法执行。最常见的是，这种类型的架构将由python期货/asyncio模块（如在ib_insync库中）处理，或者为运行循环添加一个额外的线程。