用途:通过 WebSocket 长连接实时接收 A 股、港股、ETF 行情数据,每 3~5 秒更新一次。架构为 Receiver Node(HTTP API)→ scripts/subscribe_client.py → ws://localhost:8765 → 客户端。
主要能力:一次性查询验证连通性;启动 WebSocket 推送服务;按涨跌幅触发告警(如 ±2%);将数据输出到文件(ticks.jsonl);以编程方式启动服务并注册回调;与 AI Agent 集成执行订阅加告警监控工作流。内置告警策略包括涨停/跌停监控、大幅波动(≥ ±5%)、成交量异动(≥ 近5日均量3倍)、价格突破近20日高点。
使用方式:先安装依赖 pip install requests websockets,并设置环境变量 STOCK_RT_NODE_URL,可选设置 STOCK_RT_TOKEN。一次性查询示例:python3 scripts/subscribe_client.py --symbols 00700.HK 600519.SH --once。启动推送服务示例:python3 scripts/subscribe_client.py --symbols 00700.HK 09988.HK 600519.SH;可指定 --node-url、--ws-port、--alert-pct、--output。编程方式可导入 StockWSServer 并调用 add_callback、run。AI Agent 集成可导入 StockDataAgent,调用 install 与 complete_workflow。
适用场景:需要实时监控 A 股、港股、ETF 行情并触发告警或落盘记录的场景。
限制:需自备可用的 Receiver Node 地址,鉴权时需提供 token;具体数据字段、消息格式与排错细节见 references/api.md,告警策略配置见 references/strategy_config.json;资料未提供收费、价格、平台支持范围等信息。