在当今快节奏的金融市场，实时数据的获取和展示是至关重要的。而通过 Python 的 TWS-API 和 Bottle-WebSocket 的组合，我们能够轻松构建一个实时金融数据应用。TWS-API 允许我们通过程序化方式与交易所进行互动，获取证券交易和市场数据。而 Bottle-WebSocket 则使得我们能用 WebSocket 技术实现前后端实时通信，让我们的应用能够即时更新数据，让用户体验更加流畅。
简单说，TWS-API 是一个和 Interactive Brokers（IB）进行交互的 API，用来获取市场行情和交易操作。而 Bottle-WebSocket 是一个基于 Bottle 框架的 WebSocket 扩展，支持实时双向通信。这两个库结合在一起，可以构建例如实时股票市场监控、交易信号推送以及历史数据的实时展示等功能。接下来我们来看一些具体的例子和实现代码。
第一个功能就是实时监控股票价格。使用 TWS-API 可以获取到某个股票的最新行情，并通过 WebSocket 将数据实时推送到前端。下面是一个简单的示例代码。
from ib_insync import *from bottle import Bottle, run, static_filefrom bottle_websocket import GeventWebSocketServer, websocketapp = Bottle()ib = IB()ib.connect('127.0.0.1', 7497, clientId=1)clients = set()@app.route('/websocket')@websocketdef websocket_data(ws): clients.add(ws) try: while True: ib.sleep(1) except Exception as e: print(f'WebSocket error: {e}') finally: clients.remove(ws)def broadcast_price(symbol): contract = Stock(symbol, 'SMART', 'USD') ib.reqMktData(contract) while True: market_data = ib.reqMktData(contract) price = market_data.last for client in clients: client.send(price) ib.sleep(1)ib.run(broadcast_price('AAPL'))run(app, server=GeventWebSocketServer)
这段代码中，我们首先连接到 TWS-API，并创建一个 Bottle WebSocket 服务。当 WebSocket 客户端连接时，我们加入客户端列表，接着通过 broadcast_price 函数不断发送 AAPL 股票的最新价格到所有连接的客户端。用户可以通过 WebSocket 实时接收到更新的价格信息。
接下来的第二个功能是交易信号推送。我们可以根据市场行情变化，生成买入或卖出信号，然后通过 WebSocket 推送给用户。以下是实现示例。
def generate_trade_signal(symbol): contract = Stock(symbol, 'SMART', 'USD') ib.reqMktData(contract) while True: market_data = ib.reqMktData(contract) # 简单的买入卖出信号策略 if market_data.last > 150: signal = "卖出信号" elif market_data.last < 100: signal = "买入信号" else: signal = "继续观察" for client in clients: client.send(signal) ib.sleep(5)ib.run(generate_trade_signal('AAPL'))
在这个示例中，我们依旧用到了 TWS-API 获取股价，但增加了一个简单的交易信号逻辑。根据价格变化，系统会决定发送 “买入信号” 或 “卖出信号” 给用户，实现交易策略的实时传达。
第三个功能是展示历史数据的实时更新。我们可以结合 TWS-API 获取历史数据，并通过 WebSocket 向前端推送更新。例如，可以让用户选择不同的时间区间来查看某只股票的历史波动情况。
@app.route("/history/<symbol>")@websocketdef history_data(ws, symbol): clients.add(ws) contract = Stock(symbol, 'SMART', 'USD') historical_data = ib.reqHistoricalData(contract, endDateTime='', durationStr='1 D', barSizeSetting='1 hour', whatToShow='MIDPOINT', useRTH=True) for data in historical_data: ws.send(f"{data.date}: {data.close}") try: while True: ib.sleep(5) except Exception as e: print(f'WebSocket error: {e}') finally: clients.remove(ws)run(app, server=GeventWebSocketServer)
这里，我们在用户连接到 WebSocket 后，获取选定股票的历史数据，直接推送给用户。具备实时性的同时，也能让用户看到过去的数据。通过这种方式，用户对市场的理解会更加全面和直观。
虽然 TWS-API 和 Bottle-WebSocket 的组合能够帮助我们实现许多有趣和实用的功能，但在开发过程中可能会遇到一些问题。比如，连接 TWS 时可能会遇到连接延迟，甚至是拒绝连接的情况。解决这个问题的一个方式是确保 TWS 已经启动且提供了 API 访问。还需要检查 TWS 中的 API 设置，确保符合安全和界面规定。
另一个可能的问题是 WebSocket 客户端的连接数量。在高并发情况下，可能会导致 WebSocket 连接不稳定，甚至限制连接数量。解决方案是使用其他更强大的框架在后端和服务器中持久化 WebSocket 连接，从而更好地支持客户的实现需求。同时，合理的错误处理和重新连接逻辑也会使系统更加健壮。
通过这篇文章，相信你对如何结合 TWS-API 和 Bottle-WebSocket 有了更深入的了解。这不仅让你能在 Python 中轻松获取金融数据，构建实时应用，还能够为你提供更多的想象空间来实现其它有趣的项目。如果你在实现过程中遇到问题，或者对于我提到的功能有任何疑问，随时欢迎留言与我联系。期待看到大家的作品！
