tws-async 0.5.7

注意

该项目已发展成为 IB-insync，所有开发都在那里进行。

代码移植

• TWSClient 已迁移到 ib_insync.client.Client (许多改进)；

• TWSClientQt：新的 Client 可以与PyQt和quamash一起使用。

简介

tws_async 包允许使用 asyncio 标准库或 PyQt5 框架以异步和单线程方式使用Interactive Brokers (IBAPI) 的Python API。

这提供了一种比多线程更简单、更安全、更高效的并发方法。

安装

使用pip安装

pip3 install -U tws_async

注意，在某些系统上，pip3 命令只是 pip。

需要Python版本3.5或更高版本以及 Interactive Brokers Python API。

用法

此包提供了两个客户端，可以用作IBAPI提供的标准EClient的替代品

• TWSClient，适用于asyncio事件循环；

• TWSClientQt，适用于PyQt5事件循环。

这些客户端还继承自ibapi.wrapper.EWrapper，可以使用标准IBAPI版本的方式进行使用。异步客户端使用自己的事件驱动网络代码来替换标准EClient的网络代码，并且将EClient.run()的无穷循环替换为事件循环。

为了简化与合约的工作，此包提供了可以用于任何期望ibapi.contract.Contract的地方的Contract、Stock、Option、Future、Forex、Index、CFD和Commodity类。一些简单案例的示例是Stock('AMD')、Forex('EURUSD')、CFD('IBUS30')或Future('ES', '201612', 'GLOBEX')。要指定更复杂的合约，任何属性都可以作为关键字给出。

要了解更多信息，请参阅官方IBAPI文档或查看这些示例用例

%gui qt5
import asyncio, quamash
loop = quamash.QEventLoop()
asyncio.set_event_loop(loop)

def run_until_complete(self, future):
    future = asyncio.ensure_future(future)
    qApp = qt.QApplication.instance()
    while not future.done():
        qApp.processEvents(qt.QEventLoop.WaitForMoreEvents)
    return future.result()

quamash.QEventLoop.run_until_complete = run_until_complete

更改日志