ChatGPT API调用实战：如何正确处理’请取消阻止’错误及请求重试机制

1次阅读

没有评论

共计 2978 个字符，预计需要花费 8 分钟才能阅读完成。

最近在调用 ChatGPT API 时，你是否遇到过返回 ’ 请取消阻止 ’ 的情况？这种错误通常发生在以下场景：

短时间内发送了过多请求，触发了 API 的速率限制
请求内容包含可能被识别为敏感的词汇或主题
会话状态异常或认证令牌过期

作为一个中级开发者，我们需要深入了解这些错误背后的机制，并构建健壮的处理方案。

当遇到 ’ 请取消阻止 ’ 错误时，我们有几种处理策略可选：

简单重试
立即重新发送相同请求
适用于临时性网络问题
风险：可能加剧服务器负载
指数退避重试
每次重试间隔时间按指数增长
公式：delay = min(backoff_factor * (2 ** attempts), max_delay)
适合处理临时性过载
熔断机制
当错误率达到阈值时，暂时停止请求
经过冷却期后尝试恢复
适合处理持续性系统问题

选择依据：
– 对于偶发错误，使用指数退避
– 对于系统级问题，采用熔断
– 简单重试仅用于网络抖动等极短暂问题

import requests
import time
import jwt
from datetime import datetime, timedelta

# JWT 认证
api_key = 'your_api_key'
payload = {
    'iss': 'your_service',
    'exp': datetime.utcnow() + timedelta(minutes=30)
}
token = jwt.encode(payload, api_key, algorithm='HS256')

headers = {'Authorization': f'Bearer {token}',
    'Content-Type': 'application/json'
}

# 带退避的重试逻辑
def make_request_with_backoff(url, payload, max_retries=3, backoff_factor=1):
    for attempt in range(max_retries):
        try:
            response = requests.post(url, json=payload, headers=headers)

            if response.status_code == 429:  # 速率限制
                wait_time = min(backoff_factor * (2 ** attempt), 60)
                time.sleep(wait_time)
                continue

            if response.status_code == 403:  # 认证 / 阻止
                # 可能需要刷新令牌或检查内容
                raise Exception('Authentication or content block issue')

            return response.json()

        except Exception as e:
            if attempt == max_retries - 1:
                raise
            continue

    raise Exception('Max retries exceeded')

const axios = require('axios');
const jwt = require('jsonwebtoken');

// JWT 认证
const apiKey = 'your_api_key';
const token = jwt.sign(
    { 
        iss: 'your_service',
        exp: Math.floor(Date.now() / 1000) + (30 * 60) 
    }, 
    apiKey
);

const headers = {'Authorization': `Bearer ${token}`,
    'Content-Type': 'application/json'
};

// 带令牌桶的限流
class RateLimiter {constructor(tokensPerInterval, interval) {
        this.tokens = tokensPerInterval;
        this.tokensPerInterval = tokensPerInterval;
        this.interval = interval;
        this.lastRefill = Date.now();}

    async acquire() {this.refillTokens();
        while (this.tokens < 1) {await new Promise(resolve => setTimeout(resolve, 100));
            this.refillTokens();}
        this.tokens--;
    }

    refillTokens() {const now = Date.now();
        const elapsed = now - this.lastRefill;
        if (elapsed > this.interval) {
            this.tokens = this.tokensPerInterval;
            this.lastRefill = now;
        }
    }
}

// 使用限流器
const limiter = new RateLimiter(10, 60000); // 10 请求 / 分钟

async function makeRequest(url, data) {await limiter.acquire();
    try {const response = await axios.post(url, data, { headers});
        return response.data;
    } catch (error) {if (error.response?.status === 429) {
            // 处理速率限制
            const retryAfter = error.response.headers['retry-after'] || 5;
            await new Promise(resolve => setTimeout(resolve, retryAfter * 1000));
            return makeRequest(url, data);
        }
        throw error;
    }
}

在客户端实现基础的关键词过滤
使用正则表达式匹配常见敏感模式
记录触发过滤的请求用于后续分析

使用 Redis 等集中式存储维护全局计数器
考虑采用 ’ 滑动窗口 ’ 算法而非简单计数
实现本地缓存减少网络请求

# metrics.yaml 示例
metrics:
  - name: api_requests_total
    type: counter
    help: Total API requests made
    labels: [status_code]

  - name: api_retries_total
    type: counter
    help: Total retry attempts

  - name: api_response_time_seconds
    type: histogram
    help: API response time distribution
    buckets: [0.1, 0.5, 1, 2, 5]