事件总线¶
EventBus 提供轻量级的发布/订阅事件分发机制，是 bt_api_py 事件驱动架构的核心组件。
事件类型¶
| 事件类型 | 描述 | 典型数据 |
|---|---|---|
BarEvent | K 线数据更新 | Bar 容器 |
TickEvent | 行情 Tick 更新 | Ticker 容器 |
OrderEvent | 订单状态变化 | Order 容器 |
TradeEvent | 成交通知 | Trade 容器 |
PositionEvent | 持仓变化 | Position 容器 |
AccountEvent | 账户资金变化 | Account 容器 |
使用示例¶
from bt_api_py import BtApi, EventBus
# 创建自定义事件总线
event_bus = EventBus()
# 注册事件处理函数
def on_bar(bar):
bar.init_data()
print(f"新 K 线: {bar.get_close_price()}")
def on_order(order):
order.init_data()
print(f"订单状态: {order.get_status()}")
event_bus.on("BarEvent", on_bar)
event_bus.on("OrderEvent", on_order)
# 将事件总线传入 BtApi
api = BtApi(
exchange_kwargs={"BINANCE___SPOT": {"api_key": "...", "secret": "..."}},
event_bus=event_bus,
)
# 手动触发事件（用于测试）
event_bus.emit("BarEvent", bar_data)
# 取消订阅
event_bus.off("BarEvent", on_bar)