如何通过API接口实现批量获取淘宝商品数据？（官方与非官方渠道分享）

import requests
import time
import hashlib
import json

# 配置信息（替换为自己的）
APP_KEY = "你的App Key"
APP_SECRET = "你的App Secret"
ACCESS_TOKEN = "你的Access Token"
API_URL = "http://gw.api.taobao.com/router/rest"

def get_taobao_products(keyword, page=1, page_size=20):
    """
    调用淘宝API搜索商品
    :param keyword: 搜索关键词
    :param page: 页码
    :param page_size: 每页数量（最大通常为100）
    :return: 商品数据列表
    """
    # 公共参数
    params = {
        "app_key": APP_KEY,
        "method": "taobao.items.search",
        "format": "json",
        "v": "2.0",
        "sign_method": "md5",
        "timestamp": time.strftime("%Y-%m-%d %H:%M:%S"),
        "access_token": ACCESS_TOKEN,
        # 业务参数
        "q": keyword,  # 搜索关键词
        "page_no": page,
        "page_size": page_size,
        # 可添加其他筛选条件，如价格区间、销量等
        # "start_price": 10,
        # "end_price": 100,
    }
    
    # 生成签名（淘宝API要求的签名算法）
    sorted_params = sorted(params.items(), key=lambda x: x[0])
    sign_str = APP_SECRET + "".join([f"{k}{v}" for k, v in sorted_params]) + APP_SECRET
    params["sign"] = hashlib.md5(sign_str.encode()).hexdigest().upper()
    
    # 发送请求
    response = requests.get(API_URL, params=params)
    result = json.loads(response.text)
    
    # 解析结果
    if "error_response" in result:
        print(f"错误：{result['error_response']['msg']}")
        return []
    return result.get("items_search_response", {}).get("items", {}).get("item", [])

# 批量获取数据（分页示例）
if __name__ == "__main__":
    keyword = "手机"
    total_pages = 5  # 需获取的总页数
    all_products = []
    
    for page in range(1, total_pages + 1):
        print(f"获取第{page}页数据...")
        products = get_taobao_products(keyword, page=page)
        if not products:
            break  # 无数据时停止
        all_products.extend(products)
        time.sleep(1)  # 控制调用频率，避免触发限流
    
    print(f"共获取{len(all_products)}条商品数据")
    # 处理数据（如保存到数据库或文件）
    for item in all_products[:5]:  # 打印前5条示例
        print(f"标题：{item.get('title')}，价格：{item.get('price')}，销量：{item.get('sale')}")