mcpField
S
stock-rt-subscribe

stock-rt-subscribe

github.com/yourdaylightData & databases19350 installsUpdated 8w ago
Repository

About stock-rt-subscribe

stock-rt-subscribe is a skill for receiving real-time A-share, Hong Kong stock, and ETF quotes over a WebSocket connection. It supports symbol subscriptions, price alerts, and programmatic or AI Agent workflows.

Key features

  1. 01Streams quotes over WebSocket
  2. 02Subscribes to A-shares, Hong Kong stocks, and ETFs
  3. 03Configurable polling interval
  4. 04Price movement and strategy alerts
  5. 05Python API and AI Agent workflow

Use cases

  1. 01Monitoring selected stock symbols in real time
  2. 02Triggering alerts on price moves or breakouts
  3. 03Integrating quote monitoring into an AI Agent workflow

Install

Copy the command and run it in a terminal.

$npx skills add https://github.com/yourdaylight/stock_datasource --skill stock-rt-subscribe

After installing, type/stock-rt-subscribein Claude Code to confirm it loaded.

Bundled files

References and scripts installed along with SKILL.md.

references/
api.md
strategy_config.json
scripts/
ai_agent_integration.py
alert_engine.py
strategy_engine.py
subscribe_client.py

Details

From the project README

实时股票数据订阅（WebSocket）

通过 WebSocket 长连接 实时接收 A 股、港股、ETF 行情数据，每 3~5 秒更新一次。

架构

Receiver Node (HTTP API) → scripts/subscribe_client.py → ws://localhost:8765 → 客户端

环境准备

pip install requests websockets
export STOCK_RT_NODE_URL="http://your-node:9100"
export STOCK_RT_TOKEN="your-token"   # 可选，有鉴权时设置

快速开始

一次性查询（验证连通性）
python3 scripts/subscribe_client.py --symbols 00700.HK 600519.SH --once
启动 WebSocket 推送服务
# 基础订阅
python3 scripts/subscribe_client.py --symbols 00700.HK 09988.HK 600519.SH

# 指定节点和端口
python3 scripts/subscribe_client.py --node-url http://your-node:9100 --ws-port 8765 --symbols 00700.HK

# 涨跌幅告警（±2% 触发）
python3 scripts/subscribe_client.py --symbols 00700.HK --alert-pct 2.0

# 输出到文件
python3 scripts/subscribe_client.py --symbols 00700.HK --output ticks.jsonl
编程方式启动
from scripts.subscribe_client import StockWSServer

server = StockWSServer(
    node_url="http://your-node:9100",
    symbols=["00700.HK", "09988.HK"],
    poll_interval=3.0,
)
server.add_callback(lambda sym, tick: print(f"{tick.name}: {tick.close}"))
server.run(port=8765)
AI Agent 集成
from scripts.ai_agent_integration import StockDataAgent

agent = StockDataAgent()
agent.install()  # 检查依赖、验证节点连通性

# 完整工作流（订阅 + 告警监控 60 秒）
import asyncio
asyncio.run(agent.complete_workflow(['00700.HK', '600519.SH'], duration=60))

告警策略

告警规则配置见 references/strategy_config.json，内置策略：

  • limit_up_down：涨停/跌停监控
  • big_move：大幅波动（≥ ±5%）
  • vol_spike：成交量异动（≥ 近5日均量3倍）
  • price_breakout：价格突破近20日高点

参考文档

Comments

Markdown supported