reqPostions() 帮助断开 TWS / Interactive brokers / api

Question

以下是我如何检查未平仓头寸的示例。如果不存在头寸，则创建一个 txt 文件，如果存在未平仓头寸，则删除 .txt 文件。 我的问题是我不知道如何断开它。它也输出错误 -1 见下面的脚本

from ibapi.client import EClient
from ibapi.wrapper import EWrapper
from ibapi.common import *
from ibapi.contract import *
from ib.opt import ibConnection
import os.path
from os import path


class CheckPos(EClient, EWrapper):
            def __init__(self):
                EClient.__init__(self, self)
            def nextValidId(self, orderId:int):
                self.reqPositions()
            def position(self, account: str, contract: Contract, position: float,
                avgCost: float):
                super().position(account, contract, position, avgCost)

                if position >0:
                    try:
                        os.remove("noposition.txt")

                    except:
                       print("Open Positons")



                else:
                    try:
                        open("noposition.txt","w+")
                        print("File Created Sucessfully")

                    except:
                        print("No Open Positions")







def main():
    app = CheckPos()
    app.connect("127.0.0.1", 7497,421 )
    app.run()


if __name__ == "__main__":
    main()    

输出是 错误 -1 2104 市场数据农场连接正常：usfuture 错误 -1 2104 市场数据农场连接正常：usfarm 错误 -1 2106 HMDS 数据场连接正常：ushmds 文件创建成功

Answer 1

您删除了您的 positionEnd() 方法。那是你应该断开连接的时候。

from ib.opt import ibConnection 这行来自 IbPy，删除它。

我不确定您要对文件做什么，但您可能会在回调中返回许多位置。最好将它们添加到列表中，并在程序完成所有位置后对它们进行处理。我在 positionEnd() 方法中写了一些东西，断开连接然后保存数据。

像ERROR -1 2104 Market data farm connection is OK:usfuture 这样的行只是信息。你可以忽略它们，除非他们说它坏了，但这是另一个错误代码。

from ibapi.client import EClient
from ibapi.wrapper import EWrapper
from ibapi.common import *
from ibapi.contract import *

import os

class TestApp(EClient, EWrapper):
    posns = []
    fname = 'fname.txt'

    def __init__(self):
        EClient.__init__(self, self)

    def nextValidId(self, orderId:int):
        print("id", orderId)
        print("starting program")
        self.reqPositions()

    def error(self, reqId:TickerId, errorCode:int, errorString:str):
        print("Error: ", reqId, "", errorCode, "", errorString)

    def position(self, account: str, contract: Contract, position: float, avgCost: float):
        self.posns.append((account, contract.symbol, position, avgCost))
        print(contract.symbol, position)

    def positionEnd(self):
        print("end, disconnecting")
        self.disconnect()

        #write posns to file or delete file if no positions
        if self.posns: #means not empty
            with open(self.fname, "w") as outfile:
                outfile.write('\n'.join(str(posn) for posn in self.posns))
        else: # no posns so delete file
            os.remove(self.fname)

def main():
    app = TestApp()
    app.connect("127.0.0.1", 7497, 421)
    app.run()

if __name__ == "__main__":
    main()