技能介绍

解决什么问题

Alpaca Broker 的账户、期刊、资金/转账、成交和非交易活动状态分散在多个事件流中。若只轮询 REST，生命周期变化如 SUBMITTED→ACTIVE、fill、correct、executed 可能延迟或漏掉。该技能面向 SSE（Server-Sent Events）：一条长寿命 HTTP GET，响应为 text/event-stream，逐行解析 data: 里的 JSON。它不是行情 WebSocket；传输、认证和可靠性模型都不同。

核心能力

覆盖账户状态、journal 状态、funding/transfer 状态、trade updates、NTA 等流。注意路径和版本并不统一：v2 流多用 ULID 事件 ID，v1 流同时携带整数 event_id 和 event_ulid。
回放是关键能力。 每个流支持 since/until、since_id/until_id；v1 还支持 since_ulid/until_ulid。必须持久化最后成功处理的事件 ID，并在重连时作为 since cursor 传入；没有 since 不会返回历史，只会收到之后的实时推送。
消费端需要处理静默检测、指数退避重连、单一重连保护；事件先按 event_id upsert/skip 快照，再锁定目标行，按当前状态判断跃迁，处理成功后才推进 cursor。
同一毫秒内 ULID 排序只是近似。对账前建议从几分钟前重启流，并用幂等处理吸收重叠。

适用边界

OpenAPI 无法完整建模 SSE，生成客户端常会挂起；应使用真正的流式 HTTP/SSE 客户端，并确保能设置 Authorization。SSE 适合低延迟事件流，但不能替代周期性对账：长时间宕机、bug 或未处理的事件类型仍可能漏，应定期重拉 activities、journals、transfers 做权威状态 upsert。