时间戳与分页

import os
import time
import requests

BASE_URL = "https://open-api-v4.coinglass.com"
HEADERS = {"CG-API-KEY": os.environ["COINGLASS_API_KEY"]}
INTERVAL_MS = {'1m': 60000, '3m': 180000, '5m': 300000, '15m': 900000, '30m': 1800000, '1h': 3600000, '2h': 7200000, '4h': 14400000, '6h': 21600000, '8h': 28800000, '12h': 43200000, '1d': 86400000, '1w': 604800000}

# 按你的 API 等级填写每分钟请求上限：业余 30、初创 80、标准 300、专业 1200；同一个 Key 的其他程序也会占用额度，可以再调低
REQUESTS_PER_MINUTE = 30

def fetch_range(path, params, interval, start_ms, end_ms, limit=1000):
    if interval not in INTERVAL_MS:
        raise ValueError(f"不支持的 interval: {interval}")
    if isinstance(limit, bool) or not isinstance(limit, int) or not 1 <= limit <= 1000:
        raise ValueError("limit 必须是 1～1000 的整数")
    step = INTERVAL_MS[interval] * limit
    rows = {}
    for s in range(start_ms, end_ms, step):
        query = dict(params, interval=interval, limit=limit,
                     start_time=s, end_time=min(s + step, end_ms))
        resp = requests.get(BASE_URL + path, headers=HEADERS, params=query, timeout=10)
        body = resp.json()
        if body.get("code") != "0":
            raise RuntimeError(body.get("msg"))
        for r in body["data"]:
            rows[r["time"]] = r          # 以 time 去重
        time.sleep(60 / REQUESTS_PER_MINUTE)  # 按每分钟请求上限控制间隔
    return [rows[t] for t in sorted(rows)]

const BASE_URL = "https://open-api-v4.coinglass.com";
const HEADERS = { "CG-API-KEY": process.env.COINGLASS_API_KEY };
const INTERVAL_MS = {"1m": 60000, "3m": 180000, "5m": 300000, "15m": 900000, "30m": 1800000, "1h": 3600000, "2h": 7200000, "4h": 14400000, "6h": 21600000, "8h": 28800000, "12h": 43200000, "1d": 86400000, "1w": 604800000};

// 按你的 API 等级填写每分钟请求上限：业余 30、初创 80、标准 300、专业 1200；同一个 Key 的其他程序也会占用额度，可以再调低
const REQUESTS_PER_MINUTE = 30;

async function fetchRange(path, params, interval, startMs, endMs, limit = 1000) {
  if (!Object.prototype.hasOwnProperty.call(INTERVAL_MS, interval)) {
    throw new RangeError(`不支持的 interval: ${interval}`);
  }
  if (!Number.isInteger(limit) || limit < 1 || limit > 1000) {
    throw new RangeError("limit 必须是 1～1000 的整数");
  }
  const step = INTERVAL_MS[interval] * limit;
  const rows = new Map();
  for (let s = startMs; s < endMs; s += step) {
    const query = new URLSearchParams({
      ...params, interval, limit,
      start_time: s, end_time: Math.min(s + step, endMs),
    });
    const body = await (await fetch(`${BASE_URL}${path}?${query}`, { headers: HEADERS })).json();
    if (body.code !== "0") throw new Error(body.msg);
    for (const r of body.data) rows.set(r.time, r); // 以 time 去重
    await new Promise((r) => setTimeout(r, 60000 / REQUESTS_PER_MINUTE)); // 按每分钟请求上限控制间隔
  }
  return [...rows.keys()].sort((a, b) => a - b).map((t) => rows.get(t));
}