mcpField
S
stock-rt-subscribe

stock-rt-subscribe

github.com/yourdaylightデータ・データベース19350 回インストール8 週間前に更新
リポジトリ

stock-rt-subscribe について

stock-rt-subscribeは、WebSocketでA株、香港株、ETFのリアルタイム相場を受信するスキルです。銘柄購読やアラートに対応し、PythonやAIエージェントのワークフローから利用できます。

主な機能

  1. 01WebSocketによる相場配信
  2. 02A株、香港株、ETFの購読
  3. 03ポーリング間隔の設定
  4. 04価格変動や戦略アラート
  5. 05Python APIとAIエージェントのワークフロー

活用シーン

  1. 01指定銘柄のリアルタイム監視
  2. 02価格変動やブレイクアウトのアラート
  3. 03AIエージェントのワークフローへの相場監視の組み込み

インストール

コマンドをコピーしてターミナルで実行します。

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

インストール後、Claude Code で/stock-rt-subscribeを入力して読み込まれたか確認します。

同梱ファイル

SKILL.md と一緒にインストールされる参考資料やスクリプト。

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

詳細

プロジェクトの 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日高点

参考文档

コメント

Markdown 対応