我正在尝试连接IB Api以下载一些历史数据。我注意到我的客户机连接到API,但随后在很短的时间内(几秒钟)自动断开连接
以下是服务器中的日志:
socket connection for client{10} has closed.
Connection terminated.
以下是我启动应用程序的主要代码:
class TestApp(TestWrapper, TestClient):
def __init__(self):
TestWrapper.__init__(self)
TestClient.__init__(self, wrapper=self)
self.connect(config.ib_hostname, config.ib_port, config.ib_session_id)
self.session_id = int(config.ib_session_id)
self.thread = Thread(target = self.run)
self.thread.start()
setattr(self, "_thread", self.thread)
self.init_error()
def reset_connection(self):
pass
def check_contract(self, name, exchange_name, security_type, currency):
self.reset_connection()
ibcontract = IBcontract()
ibcontract.secType = security_type
ibcontract.symbol = name
ibcontract.exchange = exchange_name
ibcontract.currency = currency
return self.resolve_ib_contract(ibcontract)
def resolve_contract(self, security):
self.reset_connection()
ibcontract = IBcontract()
ibcontract.secType = security.security_type()
ibcontract.symbol=security.name()
ibcontract.exchange=security.exchange()
ibcontract.currency = security.currency()
return self.resolve_ib_contract(ibcontract)
def get_historical_data(self, security, duration, bar_size, what_to_show):
self.reset_connection()
resolved_ibcontract=self.resolve_contract(security)
data = test_app.get_IB_historical_data(resolved_ibcontract.contract, duration, bar_size, what_to_show)
return data
def create_app():
test_app = TestApp()
return test_app
对可能出现的问题有什么建议吗?如果需要,我可以从调试中显示更多错误消息
如果您仅通过更改客户端ID就可以连接而不出现问题,则通常表示以前的连接未正确关闭,TWS认为其仍处于打开状态。要断开API客户端,应显式调用EClient.disconnect函数,在示例中被重写为:
虽然没有必要在每次任务完成后断开/重新连接,而且您可以让连接长时间保持打开状态
如果在连接后立即调用API函数(如reqHistoricalData),有时可能会遇到问题。在启动连接后最好有一个小的暂停,以等待回调,例如
nextValidID
,以确保连接在继续之前完成http://interactivebrokers.github.io/tws-api/connection.html#connect
我不确定函数
init_error()
在您的示例中的用途,因为它总是在创建TestApp对象时被调用(无论是否存在错误)安装最新版本的TWS API(V9.76)解决了这个问题
https://interactivebrokers.github.io/#
相关问题 更多 >
编程相关推荐