交互式代理中断管道python连接失败
我使用的是虚拟机、Ubuntu 16.04、Python 2.7.12。我从这里学到了一个例子。我正在使用演示帐户和TWS。
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("127.0.0.1", 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 GOOG stock via SMART order routing
goog_contract = create_contract('GOOG', 'STK', 'SMART', 'SMART', 'USD')
# Go long 100 shares of Google
goog_order = create_order('MKT', 100, 'BUY')
# Use the connection to the send the order to IB
print(tws_conn.placeOrder(order_id, goog_contract, goog_order))
# Disconnect from TWS
tws_conn.disconnect()
我可以连接到TWS，因为从日志中我可以看到：
2019-06-02 10:57:03.974 [GS] INFO [JTS-EServerSocket-153] - [0:62:76:1:0:0:0:SYS] Server version is 76
2019-06-02 10:57:03.974 [GS] INFO [JTS-EServerSocket-153] - [0:62:76:1:0:0:0:SYS] Client version is 62
2019-06-02 10:57:03.974 [GS] INFO [JTS-EServerSocket-153] - [0:62:76:1:0:0:0:SYS] is 3rdParty false
2019-06-02 10:57:03.974 [GS] INFO [JTS-EServerSocketNotifier-154] - Starting async queue thread
2019-06-02 10:57:03.977 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:0:0:SYS] Starting new conversation with client{100} at 127.0.0.1
2019-06-02 10:57:03.977 [GS] INFO [AWT-EventQueue-0] - MDConnectionsModel: Updated [127.0.0.1:34076 CLIENT ACCEPTED 100]
但是我不能做一个订单，我从日志中得到错误：
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:9:1:INFO] Sending next valid order id.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:9:1:DET] [9;1;1]
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] Sending error.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] [4;2;-1;2104;Market data farm connection is OK:usfarm.nj]
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] Error sent.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] Sending error.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] [4;2;-1;2104;Market data farm connection is OK:cashfarm]
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] Error sent.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] Sending error.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] [4;2;-1;2104;Market data farm connection is OK:usfarm]
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] Error sent.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] Sending error.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] [4;2;-1;2106;HMDS data farm connection is OK:hkhmds]
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] Error sent.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] Sending error.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] [4;2;-1;2106;HMDS data farm connection is OK:ushmds]
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:4:2:DET] Error sent.
2019-06-02 10:57:03.978 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:0:0:INFO] Start processing incoming messages for client {100}.
2019-06-02 10:57:03.980 [GS] INFO [JTS-EServerSocket-153] - [100:62:76:1:0:0:0:INFO] Handling incoming PlaceOrder(3) message.
2019-06-02 10:57:03.982 [GS] INFO [JTS-EWriter2-155] - Broken pipe (Write failed)
2019-06-02 10:57:03.982 [GS] INFO [JTS-EWriter2-155] - [100:62:76:1:0:0:0:ERR] Unable write to socket client{100} -
2019-06-02 10:57:03.982 [GS] INFO [JTS-EWriter2-155] - Broken pipe (Write failed)
2019-06-02 10:57:03.982 [GS] INFO [JTS-EWriter2-155] - [100:62:76:1:0:0:0:INFO] Close call made for client{100} socket connection.
2019-06-02 10:57:04.000 [GS] INFO [JTS-EWriter2-155] - Cleaning up [serverId: 100]...
2019-06-02 10:57:04.000 [GS] INFO [JTS-EWriter2-155] - Cleaning up [serverId: 100]...
2019-06-02 10:57:04.000 [GS] INFO [JTS-EWriter2-155] - Cleaning up [serverId: 100]...
2019-06-02 10:57:04.000 [GS] INFO [JTS-EWriter2-155] - [100:62:76:1:0:0:0:DET] closePrim called. Stopping all mkt data and HMDS requests for client{100}.
破裂的管道，是什么意思？如何通过python API修复并使订单？非常感谢。
共有1个答案
你在你的程序结束时调用断开。我猜这就是它断开连接的原因；）
一些随机的想法。
>
你的程序没有问题，但你可以拨打connect，不要等着确认你已连接。请注意，下一个有效id是建立连接时发送的第一个内容，您应该将其用作启动与TWS/Gateway交互的信号。通常，您会实现nextvalidd回调，并在那里调用启动代码，比如placeAllOrders（）或其他什么。
大多数人在他们的程序中放一个睡眠（），等待它完成后再断开连接。这是个坏主意，因为你永远不知道它什么时候完成。在你的情况下，想象一下你想在收到订单后断开连接。你可以在它说收到你的订单后实现order状态回调和断开连接。但是你可以在你的断开连接（）调用之前放一个睡眠（5）或其他东西进行测试。
我不知道这行做什么print（tws_conn.placeOrder（order_id，goog_contract，goog_order））place eorder不返回任何东西，在TWS收到订单后，它会发送一个orderState回调。
表示市场数据有效的“错误”并不是真正的错误，只是信息。如果它说“连接中断”，那么你就知道你没有从那个特定的农场获得数据。
这对谷歌来说并不重要，但主要的交换从来都不是聪明的。这是一个实际的交易，你使用的合同主要是交易。这只用于消除歧义，以防谷歌在其他国家以美元交易。
-
我正在寻找将Python连接到交互式代理应用编程接口。谷歌搜索显示了ibPy的可用性（见https://pypi.python.org/pypi/ib），但是这个库似乎没有得到维护，也不支持Python 3。我还发现https://github.com/colin1alexander/IbPython3但是这个项目已经被取消了。 我知道Quantopian使用交互式代理作为其执行代理，但有一个用于
-
如果我想使用交互式经纪人Java API检查当前头寸，然后通过出售或购买每个头寸的股票来重新平衡这些头寸，我只需要使用EWrapper。position（）方法获取帐户中的当前头寸？或者我应该使用EClientSocket。reqPositions（）方法来获取它？ Ewrapper似乎用于从TWS接收信息到客户端，而EClientSocket用于向TWS发送请求。在这种情况下，我是否同时使用po
-
我正在尝试设置Kafka Connect，目的是运行Elasticsearch chSinkConntor。 Kafka安装程序，由3个使用Kerberos、SSL和ACL保护的代理程序组成。 到目前为止，我一直在尝试使用docker/docker-com的连接器运行连接框架和elasticserch-server本地化（使用Kafka 2.4连接到远程kafka安装（Kafka 2.0.1-实际
-
问题内容： 我正在尝试使用套接字与服务器建立连接。连接管道损坏，如下所示。 这是代码，在此行上引发异常。 注意：如果我关闭套接字连接，立即可以正常工作。但是我想保持连接仍然活跃，所以我手动关闭套接字连接。停止按钮的onclick我正在关闭连接。 我在网上搜索，但没有找到解决此问题的方法。 问题答案： 在您写入连接时，对等方关闭了连接。这通常意味着您发送了一些它不理解的内容。也许是HTTP服务器？还
-
问题内容： 在Python脚本中，是否有任何方法可以判断解释器是否处于交互模式？这将很有用，例如，当您运行交互式Python会话并导入模块时，将执行略有不同的代码（例如，关闭日志记录）。 我已经看过判断python是否处于-i模式并在那里尝试了代码，但是，该函数仅在使用- i标志调用了Python的情况下才返回true，而在用于调用交互模式的命令没有参数时则返回true 。 我的意思是这样的： 问
-
对Python和IB API还不熟悉，但仍停留在这个简单的问题上。此应用程序工作正常，并打印IB服务器回复。然而，我不知道如何将这些数据输入熊猫的数据框或任何其他变量。你如何“把数据拿出来”谢谢 在论坛、文档或youtube上，我找不到任何有用的例子。我想答案一定是将accountSummary返回给pd。系列，但不知道如何。 预期输出将是一个可以在应用程序之外操作的数据系列或变量。