接口使用说明

快速开始

在个人中心创建 API Key。请求时优先将 Key 放入 X-Api-Key 请求头，不要把 Key 写进浏览器前端、公开仓库或截图。

MCP 接入

支持无状态 Streamable HTTP MCP。将服务地址设为 https://jinniu.ziyoutang.com/mcp，并在请求头中使用 Authorization: Bearer YOUR_API_KEY；也兼容 X-Api-Key。

MCP 复用当前账号的数据权限。

请帮我添加并连接这个MCP服务：
名称：金牛行情数据
类型：Streamable HTTP
地址：https://jinniu.ziyoutang.com/mcp
鉴权：Authorization: Bearer YOUR_API_KEY

安装后请读取tools/list验证连接；如果不能自动添加，请告诉我配置入口。

连接验证

curl -X POST 'https://jinniu.ziyoutang.com/mcp' \
  -H 'Authorization: Bearer YOUR_API_KEY' \
  -H 'Content-Type: application/json' \
  -H 'Accept: application/json, text/event-stream' \
  -d '{"jsonrpc":"2.0","id":1,"method":"initialize","params":{"protocolVersion":"2025-06-18","capabilities":{},"clientInfo":{"name":"example","version":"1.0"}}}'

连接后通过 tools/list 获取当前工具及输入参数说明；通过 tools/call 查询数据。返回数据使用 data.fields + data.items 结构。

faq_search 可搜索已核验、可解释的FAQ，参数为 q（关键词，可省略）和 page（默认1），固定每页20条。未确认的问题不返回，查询不扣行情日额度；答案适用范围见返回的 scope，分页信息见 data.meta。已连接的AI如看不到新工具，请刷新工具列表或重新连接MCP。

调用规则

调用频率与并发

• 历史、实时及 MCP 调用均为每账户每分钟最多 60 次。
• 同一 API Key 最多同时发起 2 个并发请求；达到上限时服务端会返回 429 和 Retry-After: 2，请等待已有请求完成后再继续下一批。
• 账户数据权限到期、权限关闭或超限时，接口会拒绝请求。删除或重新生成 API Key 不会重置账户调用次数。

单次返回与批量查询

• 分钟线不限制固定自然日跨度；超过单次返回量时请按时间范围分批查询。
• 所有 API 支持可选 gzip 响应压缩：带 Accept-Encoding: gzip 时返回压缩内容；不带时按默认 JSON 返回。常见浏览器和 HTTP 客户端会自动协商并解压。
• 请妥善保管 API Key。发现泄露时，在个人中心轮换 Key，旧 Key 会立即失效。
• 数据仅限研究、学习和个人使用，使用者应自行核验并遵守适用的法律、平台与数据使用规则。

规范调用建议

• 按代码和时间范围分批查询，并通过 fields 仅请求所需字段；已成功获取的数据请保存在本地，避免重复拉取。
• 收到 429 时必须按照 Retry-After 等待后再重试，不要立即连续重发；网络异常建议间隔 2、5、10 秒逐步重试，最多 3 次。
• 大批量历史数据建议安排在非交易时段执行；实时接口仅查询当前业务需要的代码，不要循环请求全市场。

import json
import time
import requests

API_KEY = "YOUR_API_KEY"
URL = "https://jinniu.ziyoutang.com/api/stk_mins"

session = requests.Session()
session.headers.update({
    "X-Api-Key": API_KEY,
    "Content-Type": "application/json",
    "Accept-Encoding": "gzip",
})

def query_minutes(ts_code, start_date, end_date):
    payload = {
        "ts_code": ts_code,
        "freq": "1min",
        "start_date": start_date,
        "end_date": end_date,
        "fields": "ts_code,trade_time,open,close,high,low,vol,amount",
        "limit": 4000,
    }
    retry_delays = [2, 5, 10]

    for attempt in range(4):
        try:
            response = session.post(URL, json=payload, timeout=60)
            if response.status_code == 429:
                time.sleep(int(response.headers.get("Retry-After", 5)))
                continue
            response.raise_for_status()
            return response.json()
        except requests.RequestException:
            if attempt == 3:
                raise
            time.sleep(retry_delays[attempt])

# 按日期串行查询；同一 API Key 最多同时运行 2 个并发请求。
dates = ["2026-09-08", "2026-09-09", "2026-09-10"]
for trade_date in dates:
    result = query_minutes(
        ts_code="000001.SZ",
        start_date=f"{trade_date} 09:30:00",
        end_date=f"{trade_date} 15:00:00",
    )
    with open(f"000001.SZ_{trade_date}.json", "w", encoding="utf-8") as file:
        json.dump(result, file, ensure_ascii=False)
    time.sleep(1)

错误码

400 参数错误，401 API Key 无效或已删除，403 账户期限或数据权限不满足，429 请求超过限额，503 行情数据暂不可用。错误响应包含 code、message 和 data 字段。