response = requests.get(api_url, params=params)# 获取剩余日配额remaining_quota = response.headers.get("X-API-QUOTA-REMAINING", "未知")print(f"当前剩余日配额：{remaining_quota} 次")

import timeimport requestsdef rate_limited_request(api_url, params, interval=0.12):
    """
    带频率控制的请求函数
    :param interval: 请求间隔（秒），默认0.12秒（≈8 QPS）
    """
    # 间隔等待
    time.sleep(interval)
    try:
        response = requests.get(api_url, params=params, timeout=15)
        return response    except Exception as e:
        print(f"请求失败：{e}")
        return None

params = {
    "applicationId": APP_ID,
    "itemCode": ITEM_CODE,
    "format": "json",
    # 仅返回需要的字段，提升效率
    "elements": "itemName,itemPrice,availability,reviewAverage,shopName"}

params = {
    "applicationId": APP_ID,
    # 多个商品编码用逗号分隔，最多100个
    "itemCode": "shop001:item123456,shop002:item654321",
    "hits": 100,  # 每页最多100条
    "format": "json"}

def check_quota(response):
    """
    检查剩余配额并告警
    """
    remaining = response.headers.get("X-API-QUOTA-REMAINING", 0)
    try:
        remaining = int(remaining)
    except ValueError:
        remaining = 0
    
    # 配额阈值告警（剩余<2000次时告警）
    if remaining < 2000:
        print(f"警告：剩余配额不足2000次，当前剩余{remaining}次")
        # 可添加邮件/短信告警逻辑
    return remaining

def get_headers():
    return {
        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36",
        "Accept": "application/json, text/plain, */*",
        "Accept-Language": "ja-JP,ja;q=0.9,en-US;q=0.8,en;q=0.7",
        "Referer": "https://webservice.rakuten.co.jp/",  # 来源设为乐天开发者平台
        "Connection": "keep-alive"
    }# 调用时添加请求头response = requests.get(api_url, params=params, headers=get_headers(), timeout=15)

import random# 代理池（替换为你的有效代理，格式：http://ip:port）PROXY_POOL = [
    "http://123.45.67.89:8080",
    "http://98.76.54.32:3128"]def get_random_proxy():
    """随机获取代理"""
    return random.choice(PROXY_POOL) if PROXY_POOL else None# 调用时添加代理proxy = get_random_proxy()proxies = {"http": proxy, "https": proxy} if proxy else Noneresponse = requests.get(api_url, params=params, headers=get_headers(), proxies=proxies, timeout=15)

import redisimport jsonfrom functools import wraps# 初始化Redis连接redis_client = redis.Redis(host="localhost", port=6379, db=0, decode_responses=True)CACHE_EXPIRE = 3600  # 缓存1小时def cache_decorator(expire=CACHE_EXPIRE):
    def wrapper(func):
        @wraps(func)
        def inner(application_id, item_code):
            # 构造缓存键
            cache_key = f"rakuten:item:{item_code}"
            # 先查缓存
            cached_data = redis_client.get(cache_key)
            if cached_data:
                return json.loads(cached_data)
            # 缓存未命中，调用API
            result = func(application_id, item_code)
            if result:
                redis_client.setex(cache_key, expire, json.dumps(result))
            return result        return inner    return wrapper# 使用缓存装饰器包装API调用函数@cache_decorator(expire=3600)def get_rakuten_item_detail(application_id, item_code):
    # 原有API调用逻辑...
    pass

from requests.exceptions import RequestExceptiondef request_with_retry(api_url, params, max_retry=3):
    """
    指数退避重试请求
    :param max_retry: 最大重试次数
    """
    retry_count = 0
    while retry_count < max_retry:
        try:
            headers = get_headers()
            proxy = get_random_proxy()
            proxies = {"http": proxy, "https": proxy} if proxy else None
            response = requests.get(api_url, params=params, headers=headers, proxies=proxies, timeout=15)
            
            if response.status_code == 429:
                # 指数退避等待
                sleep_time = 2 ** retry_count                print(f"触发限流，等待{sleep_time}秒后重试...")
                time.sleep(sleep_time)
                retry_count += 1
                continue
            
            response.raise_for_status()
            return response        
        except RequestException as e:
            print(f"请求失败（重试{retry_count+1}/{max_retry}）：{e}")
            retry_count += 1
            time.sleep(1)
    
    print("多次重试失败，放弃请求")
    return None