aifinlab/skills/cn-stock-data

cn-stock-data 统一金融数据层

核心能力

• 统一代码格式: SH600519 / SZ000001 / HK00700 / AAPL.O，也接受纯数字 600519（自动推断市场）
• 统一返回字段: 英文 snake_case（date, open, close, high, low, volume, amount, pct_change 等）
• 智能路由: 每种数据类型有最优源优先级链，自动 fallback
• 跨市场: 港股/美股自动路由到 pysnowball

数据类型 & 路由优先级

| 类型 | 命令 | 路由链 | |------|------|--------| | K线 | kline | efinance → akshare → adata → ashare → snowball | | 实时行情 | quote | efinance → adata → snowball | | 资金流向 | fund_flow | efinance → adata → snowball | | 财务指标 | finance | adata(43字段) → akshare → snowball | | 北向资金 | north_flow | adata（独占） | | 跨市场 | 自动 | snowball（独占） |

CLI 用法

SCRIPTS_DIR="$SKILLS_ROOT/cn-stock-data/scripts"

# K线（日/周/月/分钟）
python "$SCRIPTS_DIR/cn_stock_data.py" kline --code SH600519 --freq daily --start 2026-01-01

# 实时行情（支持多只，逗号分隔）
python "$SCRIPTS_DIR/cn_stock_data.py" quote --code SH600519,SZ000001

# 跨市场行情（自动路由到 snowball）
python "$SCRIPTS_DIR/cn_stock_data.py" quote --code HK00700,AAPL.O

# 资金流向
python "$SCRIPTS_DIR/cn_stock_data.py" fund_flow --code SZ000001

# 财务指标
python "$SCRIPTS_DIR/cn_stock_data.py" finance --code SH600519

# 北向资金
python "$SCRIPTS_DIR/cn_stock_data.py" north_flow

# 强制指定数据源
python "$SCRIPTS_DIR/cn_stock_data.py" kline --code SH600519 --source akshare

# 检查各源可用状态
python "$SCRIPTS_DIR/cn_stock_data.py" status

统一返回格式（JSON）

{
  "ok": true,
  "source": "efinance",
  "fallback_used": false,
  "code": "SH600519",
  "data_type": "kline",
  "count": 30,
  "data": [
    {"date": "2026-03-14", "open": 1880.0, "close": 1895.5, "high": 1900.0, "low": 1875.0, "volume": 25000, "amount": 47000000, "pct_change": 0.82}
  ]
}

频率参数

--freq: daily, weekly, monthly, 1min, 5min, 15min, 30min, 60min

代码格式支持

| 输入 | 解析结果 | |------|---------| | SH600519 | 上交所贵州茅台 | | SZ000001 | 深交所平安银行 | | 600519 | 自动推断→SH600519 | | 000001 | 自动推断→SZ000001 | | HK00700 | 港股腾讯 | | AAPL.O | 美股苹果 |

编程接口（Python import）

import sys; sys.path.insert(0, "$SKILLS_ROOT/cn-stock-data/scripts")
from routing import execute_with_fallback, get_available_sources

# K线
result = execute_with_fallback("kline", "get_kline", code="SH600519", freq="daily", start="2026-01-01")
if result["ok"]:
    for row in result["data"][:3]:
        print(row)

# 行情
result = execute_with_fallback("quote", "get_quote", code="SH600519", codes=["SH600519", "SZ000001"])

# 状态检查
print(get_available_sources())

注意事项

• pysnowball 的 kline/finance/fund_flow 需要 token（从 xueqiu.com cookie 获取），无 token 时自动跳过
• ashare 只支持 K 线（日/周/月/分钟），无行情/资金流/财务
• akshare K 线只支持日/周/月，不支持分钟级
• 分钟级 K 线优先用 efinance，fallback 到 ashare