API 429怎么解决：先分频率、额度、并发和上游限制

const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

async function sendWithBackoff(send) {
  const maxAttempts = 5;
  const maxElapsedMs = 60_000;
  const startedAt = Date.now();

  for (let attempt = 1; attempt <= maxAttempts; attempt += 1) {
    const response = await send();
    if (response.ok) return response;
    if (response.status !== 429) throw new Error("stop: non-retryable HTTP " + response.status);

    const body = await response.clone().json().catch(() => ({}));
    const reason = body?.error?.code || body?.error?.type || "unknown_429";
    if (["credit_balance_exhausted", "organization_spend_limit_exceeded"].includes(reason)) {
      throw new Error("stop: action required for " + reason);
    }

    const rawRetryAfter = response.headers.get("retry-after");
    const retryAfterSeconds = rawRetryAfter !== null && Number.isFinite(Number(rawRetryAfter))
      ? Math.max(0, Number(rawRetryAfter))
      : null;
    const jitterMs = Math.floor(Math.random() * 501);
    const fallbackMs = Math.min(30_000, 1_000 * (2 ** (attempt - 1)));
    const delayMs = (retryAfterSeconds === null ? fallbackMs : retryAfterSeconds * 1_000) + jitterMs;
    const wouldExceedBudget = Date.now() - startedAt + delayMs > maxElapsedMs;
    if (attempt === maxAttempts || wouldExceedBudget) {
      throw new Error("stop: retry budget exhausted; last_reason=" + reason);
    }
    await sleep(delayMs);
  }
}