将交互式代理API引入熊猫

Question

对Python和IB API还不熟悉，但仍停留在这个简单的问题上。此应用程序工作正常，并打印IB服务器回复。然而，我不知道如何将这些数据输入熊猫的数据框或任何其他变量。你如何“把数据拿出来”谢谢

在论坛、文档或youtube上，我找不到任何有用的例子。我想答案一定是将accountSummary返回给pd。系列，但不知道如何。

预期输出将是一个可以在应用程序之外操作的数据系列或变量。

from ibapi import wrapper
from ibapi.client import EClient
from ibapi.utils import iswrapper #just for decorator
from ibapi.common import *
import pandas as pd

class TestApp(wrapper.EWrapper, EClient):
    def __init__(self):
        wrapper.EWrapper.__init__(self)
        EClient.__init__(self, wrapper=self)

    @iswrapper
    def nextValidId(self, orderId:int):
        print("setting nextValidOrderId: %d", orderId)
        self.nextValidOrderId = orderId
        # here is where you start using api
        self.reqAccountSummary(9002, "All", "$LEDGER")

    @iswrapper
    def error(self, reqId:TickerId, errorCode:int, errorString:str):
        print("Error. Id: " , reqId, " Code: " , errorCode , " Msg: " , errorString)

    @iswrapper
    def accountSummary(self, reqId:int, account:str, tag:str, value:str, currency:str):
        print("Acct Summary. ReqId:" , reqId , "Acct:", account, 
            "Tag: ", tag, "Value:", value, "Currency:", currency)
    #IB API data returns here, how to pass it to a variable or pd.series

    @iswrapper
    def accountSummaryEnd(self, reqId:int):
        print("AccountSummaryEnd. Req Id: ", reqId)
        # now we can disconnect
        self.disconnect()

def main():
    app = TestApp()
    app.connect("127.0.0.1", 4001, clientId=123)
    test = app.accountSummary
    app.run()

if __name__ == "__main__":
    main()

Answer 1

我将数据存储到一个字典中，从字典中创建一个数据帧，并使用concat函数将新的数据帧附加到主数据帧中。下面是一个例子：

def accountSummary(self, reqId:int, account:str, tag:str, value:str, currency:str):
    acct_dict = {"account": account, "value": value, "currency": currency}
    acct_df = pd.DataFrame([acct_dict], columns=acct_dict.keys())
    main_df = pd.concat([main_df, acct_df], axis=0).reset_index()

要了解更多信息，您可能喜欢与交互式经纪人进行算法交易

Answer 2

Hi也有同样的问题，collections帮我解决了。这是我的CFDs数据代码。也许它会帮助别人。你将在应用程序中拥有你的数据。df。任何改进建议都是非常受欢迎的。

import collections
import datetime as dt
from threading import Timer
from ibapi.client import EClient
from ibapi.wrapper import EWrapper
from ibapi.contract import Contract
import pandas as pd

# get yesterday and put it to correct format yyyymmdd{space}{space}hh:mm:dd
yesterday = str(dt.datetime.today() - dt.timedelta(1))
yesterday = yesterday.replace('-','')

IP = '127.0.0.1'
PORT = 7497

class App(EClient, EWrapper):

    def __init__(self):
        super().__init__(self)
        self.data = collections.defaultdict(list)
    
    def error(self, reqId, errorCode, errorString):
        print(f'Error {reqId}, {errorCode}, {errorString}')
    
    def historicalData(self, reqId, bar):
        self.data['date'].append(bar.date)
        self.data['open'].append(bar.open)
        self.data['high'].append(bar.high)
        self.data['low'].append(bar.low)
        self.data['close'].append(bar.close)
        self.data['volume'].append(bar.volume)
        self.df = pd.DataFrame.from_dict(self.data)

    def stop(self):
        self.done = True
        self.disconnect()

# create App object
app = App()
print('App created...')
app.connect(IP, PORT, 0)
print('App connected...')

# create contract
contract = Contract()
contract.symbol = 'IBDE30'
contract.secType = 'CFD' 
contract.exchange = 'SMART' 
contract.currency = 'EUR' 
print('Contract created...')

# request historical data for contract
app.reqHistoricalData(reqId=1, 
                    contract=contract, 
                    endDateTime=yesterday,
                    durationStr='1 W',  
                    barSizeSetting='15 mins', 
                    whatToShow='ASK', 
                    useRTH=0, 
                    formatDate=1, 
                    keepUpToDate=False, 
                    chartOptions=[])

Timer(4, app.stop).start()
app.run()