IBPY 中的 reqHistoricalData 不返回任何内容 [python]

我正在尝试通过 Ibpy 从盈透证券（IB）获取历史数据。 我已经尝试了几个脚本来完成此任务，这些脚本是从其他人那里改编而来的，他们表明它应该可以工作。然而，它们都不适合我！ 我是Python新手，所以我承认我对这些方法的工作原理没有完全的了解——但是，我应该尝试最明显的修复。下面我列出了我尝试过的两个脚本。 我正在使用 python 2x。

在 TWS 中我有以下设置：

选中：启用 ActiveX 和套接字客户端。 未选中：启用 DDE 客户端。 未选中：只读 API。 选中：下载连接上的未结订单。 选中：发送投资组合时包括外汇头寸。 选中：发送 EEP 的状态更新。 套接字端口 = 7496。 勾选：使用负数绑定自动订单。 未选中：创建 API 消息日志文件。 未选中：在 API 日志文件中包含市场数据。 日志记录级别 = 错误。 主 API 客户端 ID = 222。 向 API 发送批量数据的超时时间为 30 秒。 组分交换分离器 = 空白。 选中：仅允许来自本地主机的连接。

API - 检查预防措施：绕过 API 订单的订单预防措施。此选项卡中的所有其他内容均未选中。

当我运行 python 脚本时，我已经登录并运行了 TWS，并且与其他人在网上所说的相比，上面的 TWS API 设置似乎是正确的。我有一个订阅美国股票数据的真实 IB 账户。还应该提到的是，我也尝试运行另一个通过 IBPY 下订单的脚本 - 这有效，因此问题似乎仅（至少目前）存在于获取历史数据方面。

脚本1：

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


new_symbolinput = ['AAPL']
newDataList = []  
dataDownload = []  

def historical_data_handler(msg):  
    global newDataList  
    print (msg.reqId, msg.date, msg.close)
    if ('finished' in str(msg.date)) == False:  
        new_symbol = new_symbolinput[msg.reqId]  
        dataStr = '%s, %s, %s' % (new_symbol, strftime("%Y-%m-%d", localtime(int(msg.date))), msg.close)  
        newDataList = newDataList + [dataStr]
    else:  
        new_symbol = new_symbolinput[msg.reqId]  
        filename = 'minutetrades' + new_symbol + '.csv'  
        csvfile = open('IBdata/' + filename,'w')
        for item in newDataList:  
            csvfile.write('{} \n'.format(item))
        csvfile.close()  
        newDataList = []  
        global dataDownload  
        dataDownload.append(new_symbol)  


con = ibConnection(port=7496, clientId=222)  
con.register(historical_data_handler, message.historicalData)  
con.connect()  

symbol_id = 0  
for i in new_symbolinput:  
    print (i)  
    qqq = Contract()  
    qqq.m_symbol = i  
    qqq.m_secType = 'STK'  
    qqq.m_exchange = 'SMART'  
    qqq.m_currency = 'USD'
    con.reqHistoricalData(symbol_id, qqq, '20161101', '1 W', '1 D', 'MIDPOINT', 1, 2)  

    symbol_id = symbol_id + 1  
    sleep(10)  

print (dataDownload) 
filename = 'downloaded_symbols.csv'  
csvfile = open('IBdata/' + filename,'w')  
for item in dataDownload:  
    csvfile.write('%s \n' % item)  
csvfile.close()

这应该返回 csv 文件中的数据。 csv 文件已创建，但它是空的。

回复：

Server Version: 76
TWS Time at connection:20170315 14:18:06 CET
AAPL
[]

所以它显然不会返回任何东西。

脚本2：

from time import sleep, strftime
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=222)
    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 = "AAPL"
        qqqq.m_currency = "USD"
        qqqq.m_exchange = "SMART"
        endtime = strftime('%Y%m%d %H:%M:%S')
        print(endtime)
        print(con.reqHistoricalData(1,qqqq,endtime,"1 W","1 D","MIDPOINT",1,2))



    sleep(10)

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

这里的回应：

Server Version: 76
TWS Time at connection:20170315 14:29:53 CET
True
20170315 14:30:05
None
('disconnected', True)
False

再次没有返回任何内容。我不知道为什么，因为它似乎对其他人有用。我可能错过了一些基本的东西，因为我对 Python 还很陌生？

很感谢任何形式的帮助。

始终实现错误处理程序，API 会告诉您出了什么问题。在本例中，它表示使用“1 天”作为条形大小。

没必要睡觉。使用nextValidId了解连接何时准备就绪。使用不同的结束方法来知道何时完成。historicalDataEndIBpy 中似乎还没有实现，所以只需寻找“finished”

不要关闭 API 日志记录，它会显示错误以及发送至 TWS 和从 TWS 发送的所有不同消息。您可以关闭日志文件中的市场数据，因为它相当多。在 jts 目录中查找文件“api.222.Wed.log”。

from time import sleep, strftime
from ib.ext.Contract import Contract
from ib.opt import ibConnection, message
import pandas as pd
import numpy as np

def nextValidId_handler(msg):
    print(msg)
    inner()

hist = []

def my_hist_data_handler(msg):
    print(msg)
    if "finished" in msg.date:
        print('disconnecting', con.disconnect())
        df = df = pd.DataFrame(index=np.arange(0, len(hist)), columns=('date', 'close', 'volume'))
        for index, msg in enumerate(hist):
            df.loc[index,'date':'volume'] = msg.date, msg.close, msg.volume
        print(df )
    else:
        hist.append(msg)    

def error_handler(msg):
    print(msg)

if __name__ == '__main__':

    con = ibConnection(port=7497,clientId=222)
    con.register(error_handler, message.Error)
    con.register(nextValidId_handler, message.nextValidId)
    con.register(my_hist_data_handler, message.historicalData)
    con.connect()

    print(con.isConnected())

    def inner():

        qqqq = Contract()
        qqqq.m_secType = "STK" 
        qqqq.m_symbol = "AAPL"
        qqqq.m_currency = "USD"
        qqqq.m_exchange = "SMART"
        endtime = strftime('%Y%m%d %H:%M:%S')
        print(endtime)
        con.reqHistoricalData(1,qqqq,endtime,"1 W","1 day","MIDPOINT",1,2)

    print(con.isConnected())