Ibpy с API Interactive Brokers не работает

Question

Я чувствую, что что-то в корне не так. Я иду от примера кода к примеру кода, пробуя каждый, и у меня никогда не было никакого успеха.

Ниже приведен набор сценариев, которые я запускаю, и ответ. Большинство этих сценариев взяты из примера, найденного здесь в Stackru, с которым человек, похоже, добился успеха (после некоторой помощи). Увы, у меня нет успеха, и я просто чувствую, что с тем, что я делаю, должно быть что-то не так.

Прежде чем я начну со скриптов, которые, кажется, не работают, приведу мои конфиги для GUI Interactive brokers, TWS.

API - Настройки

проверил: включить ActiveX и Socket Clients. снят: включить клиенты DDE. не проверено: API только для чтения. проверил: скачать открытые ордера на соединение. проверил: при отправке портфолио включайте валютные позиции. проверил: отправлять обновления статуса для EEP. Порт сокета = 7496. флажок: использовать отрицательные числа для привязки автоматических заказов. снят: создание файла журнала сообщений API. снят: включение рыночных данных в файл журнала API. не отмечено: разрешать запросы учетной записи API переключать видимую пользователем подписку. Уровень ведения журнала = Ошибка. ИД клиента основного API = 100. Время ожидания для отправки массовых данных в API составляет 30 секунд. Компонент Exch Separator = Blank (здесь нет записей). проверил: разрешить соединения только с локального хоста.

API - Проверенные меры предосторожности: Обход мер предосторожности для заказов API. все остальное все не проверено в этой вкладке.

Пример 1

#test_conn.py

from ib.opt import ibConnection
con = ibConnection(port=7496,clientId=100)
print(con.connect())

Запуск сценария и ответ

C:\Users\alex>python test_conn.py
Server Version: 76
TWS Time at connection:20160314 16:13:59 ICT
True
True

Я думаю, что я могу подключиться к TWS тогда?

Пример 2

#test_portfolio.py

from ib.opt import ibConnection, message

def acct_update(msg):
    print(msg)

con = ibConnection(port=7496,clientId=100)
con.register(acct_update,
             message.updateAccountValue,
             message.updateAccountTime,
             message.updatePortfolio)
con.connect()
con.reqAccountUpdates(True,'DU358588')

#don't forget to disconnect somehow when done
con.disconnect()

Запуск сценария и ответ

C:\Users\alex>python test_portfolio.py
Server Version: 76
TWS Time at connection:20160314 16:25:59 ICT

C:\Users\alex>

Так что ничего не возвращается?

Пример 3

#test_mkt_data.py

from ib.opt import ibConnection, message
from ib.ext.Contract import Contract
from time import sleep

def my_callback_handler(msg):
    inside_mkt_bid = ''
    inside_mkt_ask = ''

    if msg.field == 1:
        inside_mkt_bid = msg.price
        print 'bid', inside_mkt_bid
    elif msg.field == 2:
        inside_mkt_ask = msg.price
        print 'ask', inside_mkt_ask

tws = ibConnection()
tws.register(my_callback_handler, message.tickSize, message.tickPrice)
tws.connect()

c = Contract()
c.m_symbol = "GOOG"
c.m_secType = "STK"
c.m_exchange = "SMART"
c.m_currency = "USD"

tws.reqMktData(1,c,"",False)
sleep(25)

print 'All done'

tws.disconnect()

Запуск сценария и ответ

C:\Users\alex>python test_mkt_data.py
Server Version: 76
TWS Time at connection:20160314 16:31:54 ICT
All done
Exception in thread EReader (likely raised during interpreter shutdown):
C:\Users\alex>

Опять ничего не возвращается?

Пример 4

#test_historical.py

from time import sleep, strftime
from time import sleep
from ib.ext.Contract import Contract
from ib.opt import ibConnection, message

def my_account_handler(msg):
    print(msg)

def my_tick_handler(msg):
    print(msg)

def my_hist_data_handler(msg):
    print(msg)


if __name__ == '__main__':

    con = ibConnection(port=7496,clientId=100)
    con.register(my_account_handler, 'UpdateAccountValue')
    con.register(my_tick_handler, message.tickSize, message.tickPrice)
    con.register(my_hist_data_handler, message.historicalData)
    con.connect()

    print(con.isConnected())

    def inner():

        qqqq = Contract()
        qqqq.m_secType = "STK" 
        qqqq.m_symbol = "GOOG"
        qqqq.m_currency = "USD"
        qqqq.m_exchange = "SMART"
        endtime = strftime('%Y%m%d %H:%M:%S')
    print(endtime)
        print(con.reqHistoricalData(1,qqqq,endtime,"5 D","1     hour","MIDPOINT",0,1))



        sleep(10)

    inner()
    sleep(5)
    print('disconnected', con.disconnect())
    print(con.isConnected())

Запуск сценария и ответ

C:\Users\alex>python test_historical.py
Server Version: 76
TWS Time at connection:20160314 16:38:03 ICT
True
20160314 16:38:04
None
('disconnected', True)
False

C:\Users\alex>

Нет исторических данных? Уберите "print" из "print(con.req..." по-прежнему без разницы).

Пример 5

# ib_api_demo.py

from ib.ext.Contract import Contract
from ib.ext.Order import Order
from ib.opt import Connection, message

def error_handler(msg):
    """Handles the capturing of error messages"""
    print "Server Error: %s" % msg

def reply_handler(msg):
    """Handles of server replies"""
    print "Server Response: %s, %s" % (msg.typeName, msg)

def create_contract(symbol, sec_type, exch, prim_exch, curr):
    """Create a Contract object defining what will
    be purchased, at which exchange and in which currency.

    symbol - The ticker symbol for the contract
    sec_type - The security type for the contract ('STK' is 'stock')
    exch - The exchange to carry out the contract on
    prim_exch - The primary exchange to carry out the contract on
    curr - The currency in which to purchase the contract"""
    contract = Contract()
    contract.m_symbol = symbol
    contract.m_secType = sec_type
    contract.m_exchange = exch
    contract.m_primaryExch = prim_exch
    contract.m_currency = curr
    return contract

def create_order(order_type, quantity, action):
    """Create an Order object (Market/Limit) to go long/short.

    order_type - 'MKT', 'LMT' for Market or Limit orders
    quantity - Integral number of assets to order
    action - 'BUY' or 'SELL'"""
    order = Order()
    order.m_orderType = order_type
    order.m_totalQuantity = quantity
    order.m_action = action
    return order

if __name__ == "__main__":
    # Connect to the Trader Workstation (TWS) running on the
    # usual port of 7496, with a clientId of 100
    # (The clientId is chosen by us and we will need 
    # separate IDs for both the execution connection and
    # market data connection)
    tws_conn = Connection.create(port=7496, clientId=100)
    tws_conn.connect()

    # Assign the error handling function defined above
    # to the TWS connection
    tws_conn.register(error_handler, 'Error')

    # Assign all of the server reply messages to the
    # reply_handler function defined above
    tws_conn.registerAll(reply_handler)

    # Create an order ID which is 'global' for this session. This
    # will need incrementing once new orders are submitted.
    order_id = 1

    # Create a contract in a stock via SMART order routing
    goog_contract = create_contract('BHP', 'STK', 'SMART', 'SMART', 'AUD')

    # Go long 100 shares of Google
    goog_order = create_order('MKT', 100, 'BUY')

    # Use the connection to the send the order to IB
    tws_conn.placeOrder(order_id, goog_contract, goog_order)

    # Disconnect from TWS
    tws_conn.disconnect()

бег и ответ

C:\Users\alex>python ib_api_demo.py
Server Version: 76
TWS Time at connection:20160314 16:43:55 ICT
Server Error: <error id=-1, errorCode=2104, errorMsg=Market data farm connection is OK:afarm>

Server Response: error, <error id=-1, errorCode=2104, errorMsg=Market data farm connection is OK:afarm>
C:\Users\alex>

Так что, кажется, ничего не работает, и я чувствую, что есть что-то фундаментальное, что я пропустил? TWS вошел в систему и работает, когда я запускаю скрипты на python, и настройки TWS API (см. Выше) кажутся правильными в отношении того, что все остальные говорят онлайн.

Любая помощь высоко ценится.

Answer 1

Я попробовал коды, которые вы предоставили.

Пример 2. Добавление sleep(1) перед con.disconnect()

Пример 3. tws = ibConnection() следует изменить на tws = ibConnection (порт =7496,clientId=100)

Пример 4, "1 час"-> слишком много пробелов, оставьте только один пробел и удалите лишние.

Пример 5. Будьте осторожны со следующим действующим идентификатором заказа. Он должен быть больше, чем идентификатор заказа в системе Ib. Вы можете использовать следующий код, чтобы получить следующий действующий идентификатор заказа из системы.:

def save_order_id(msg):

    print('Next Valid ID is ' + str(msg.orderId))

con = ibConnection(port=7496,clientId=100)

con.register(save_order_id, 'NextValidId')

con.connect()

sleep(1)

con.disconnect()

Вы хороши, чтобы пойти с вышеуказанными изменениями.

Answer 2

У меня была аналогичная проблема. Самой большой проблемой для меня была версия Python. Python 3.5.7 работал у меня. Однако мне все равно пришлось исправить некоторые проблемы совместимости версий Python.