Как экспортировать данные позиции IB во фрейм данных? - PullRequest
Новая
       34

Как экспортировать данные позиции IB во фрейм данных?

0 голосов
/ 18 апреля 2019

Я пытался экспортировать позицию IB / значение счета во фрейм данных для дальнейшей обработки в python.Но не смог понять, как этого добиться.Кто-нибудь может помочь? 

import pandas as pd
import numpy as np 
import time 

import ibapi
from ibapi.client import EClient
from ibapi.wrapper import EWrapper
import threading
import sys
import queue

from ibapi.contract import Contract

class MyWrapper(EWrapper):
#@property        
    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)
        if (len(contract.symbol)<5) & (contract.secType == 'STK'):
            new_symbol = contract.symbol.zfill(5)
        else:
            new_symbol = contract.symbol
        print (contract.secType, contract.exchange, new_symbol, "Position:", position, "MarketPrice:", marketPrice, "MarketValue:", marketValue, "AverageCost:", averageCost, "UnrealizedPNL:", unrealizedPNL, "RealizedPNL:", realizedPNL)

accountName = '' 
callback = MyWrapper() # wrapper = MyWrapper()
#Instntiate My Wrapper.callback
tws = EClient(callback) # app = EClient(wrapper)
  #Instantiate EClient and return data to call back
host = '127.0.0.1'
port = 4001
clientID = 8
tws.connect(host, port, clientID)                 

print("serverVersion:%s connectionTime:%s" %     (tws.serverVersion(), tws.twsConnectionTime()))
print(tws.isConnected())

    tws.reqAccountUpdates(1, accountName)
time.sleep(2)
tws.run()
accvalue = pd.DataFrame(callback.updatePortfolio, columns = ['Symbol','Position','MarketPrice','MarketValue',
                            'AverageCost', 'UnrealisedPnL', 'RealisedPnL'])
#accvalue = callback.updateAccountValue
print ('Account: \n' + accvalue)

1 Ответ

0 голосов
/ 07 мая 2019

Вы на правильном пути. Вам нужно настроить объекты класса очереди внутри оболочки, чтобы получить ответ от клиентской функции, которую вы вызываете. Затем вы можете делать с данными все, что захотите. Посмотрите на этот блог -> https://qoppac.blogspot.com/2017/03/interactive-brokers-native-python-api.html

Там есть код, который вы можете использовать повторно, чтобы помочь с реализацией.

...