批量获取淘宝商品评论：API 分页策略、并发控制与频率优化

python
import math
import requests
def get_all_comments(item_id, app_key, app_secret):
    base_url = "https://eco.taobao.com/router/rest"
    params = {
        "method": "taobao.item.reviews.get",
        "app_key": app_key,
        "num_iid": item_id,
        "page_no": 1,
        "page_size": 100,
        "format": "json",
        "v": "2.0",
        "timestamp": "2025-11-10 14:30:00"  # 动态生成
    }
    # 生成签名（需按淘宝规则排序参数并加密）
    params["sign"] = generate_sign(params, app_secret)  
    response = requests.get(base_url, params=params).json()
    if response["code"] != "200":
        raise Exception(f"API Error: {response.get('msg')}")
    total_reviews = response["item_reviews_get_response"]["total_reviews"]
    total_pages = math.ceil(total_reviews / 100)
    all_comments = []
    for page in range(1, total_pages + 1):
        params["page_no"] = page
        params["sign"] = generate_sign(params, app_secret)  # 重新签名
        response = requests.get(base_url, params=params).json()
        all_comments.extend(response["item_reviews_get_response"]["reviews"])
    return all_comments

python
import asyncio
import aiohttp
async def fetch_comments(item_id, session, app_key, app_secret):
    url = "https://eco.taobao.com/router/rest"
    params = {
        "method": "taobao.item.reviews.get",
        "app_key": app_key,
        "num_iid": item_id,
        "page_no": 1,
        "page_size": 100,
        "format": "json",
        "v": "2.0"
    }
    params["sign"] = generate_sign(params, app_secret)  # 需实现签名函数
    async with session.get(url, params=params) as response:
        return await response.json()
async def main(item_ids, app_key, app_secret):
    async with aiohttp.ClientSession() as session:
        tasks = [fetch_comments(item_id, session, app_key, app_secret) for item_id in item_ids]
        results = await asyncio.gather(*tasks)
        return results
# 调用示例
item_ids = ["123456789", "987654321"]
comments = asyncio.run(main(item_ids, "YOUR_APP_KEY", "YOUR_APP_SECRET"))