微店关键词搜索接口实战：从接入到系统对接（附签名避坑代码 + 3 大获客场景）

import hashlib
import time
import urllib.parse
import requests
import os
def generate_weidian_sign(params, app_secret):
    """
    微店签名生成（避坑版）
    关键：1. 毫秒级时间戳 2. 参数按key升序 3. 拼接格式“key=value&key=value”+app_secret
    """
    # 1. 排除sign参数，按参数名ASCII升序排序（微店要求严格，不能乱序）
    sorted_params = sorted([(k, v) for k, v in params.items() if k != "sign"])
    # 2. 拼接参数字符串，格式“key=value&key=value”（别漏&）
    sign_str = "&".join([f"{k}={v}" for k, v in sorted_params])
    # 3. 末尾拼接AppSecret，MD5加密后转大写
    sign_str += app_secret
    return hashlib.md5(sign_str.encode("utf-8")).hexdigest().upper()
def weidian_keyword_search(keyword, page=1, page_size=30):
    """
    微店关键词搜索接口调用（实战版）
    解决：1. 中文关键词编码 2. 时间戳格式 3. 异常捕获
    """
    # 从环境变量拿凭证（安全，避免硬编码）
    app_key = os.getenv("WEIDIAN_APP_KEY", "你的AppKey")
    app_secret = os.getenv("WEIDIAN_APP_SECRET", "你的AppSecret")
    access_token = os.getenv("WEIDIAN_ACCESS_TOKEN", "你的AccessToken")
    # 1. 处理中文关键词（微店要求URL编码）
    encoded_keyword = urllib.parse.quote(keyword, safe='')
    # 2. 构造参数（注意timestamp是毫秒级）
    params = {
        "appkey": app_key,
        "method": "weidian.item.search",
        "timestamp": str(int(time.time() * 1000)),  # 微店特殊：毫秒级时间戳
        "format": "json",
        "v": "1.0",
        "access_token": access_token,
        "keyword": encoded_keyword,
        "page": str(page),
        "page_size": str(page_size)
    }
    # 3. 生成签名
    params["sign"] = generate_weidian_sign(params, app_secret)
    try:
        # 4. 发起POST请求（微店不支持GET，别用错）
        response = requests.post(
            url="https://api.weidian.com/api",
            data=params,  # 微店要求参数放form-data，别用json
            timeout=8,
            verify=True
        )
        response.raise_for_status()  # 捕获4xx/5xx错误
        result = response.json()
        # 5. 处理接口错误
        if result.get("code") != 0:
            error_msg = result.get("msg", "未知错误")
            raise Exception(f"微店API错误[{result['code']}]：{error_msg}（常见原因：access_token过期/关键词为空）")
        # 6. 解析核心数据（只留有用的字段，减少冗余）
        items = result.get("data", {}).get("items", [])
        parsed_items = []
        for item in items:
            parsed_items.append({
                "商品ID": item.get("item_id"),
                "标题": item.get("title"),
                "月销": item.get("sales_month", 0),
                "关键词匹配度": item.get("keyword_match", 0),
                "是否商城店": "是" if item.get("is_mall") == 1 else "否"
            })
        return {
            "总数量": result.get("data", {}).get("total_count", 0),
            "当前页": page,
            "商品列表": parsed_items
        }
    # 7. 捕获常见异常（新手必看）
    except requests.exceptions.Timeout:
        raise Exception("接口调用超时（微店服务器高峰，建议10秒后重试）")
    except requests.exceptions.ConnectionError:
        raise Exception("网络连接失败（检查服务器是否能访问api.weidian.com）")
    except requests.exceptions.HTTPError as e:
        if "429" in str(e):
            raise Exception("调用频率超限（微店企业店50次/分钟，别集中调用）")
        else:
            raise Exception(f"HTTP错误：{str(e)}")
    except Exception as e:
        raise Exception(f"调用失败：{str(e)}")
# 实战调用示例（替换关键词即可）
if __name__ == "__main__":
    try:
        # 搜索“婴儿辅食”，第1页，每页30条
        search_result = weidian_keyword_search(keyword="婴儿辅食", page=1, page_size=30)
        print(f"搜索到{search_result['总数量']}个商品")
        print(f"当前第{search_result['当前页']}页")
        for idx, item in enumerate(search_result['商品列表'], 1):
            print(f"{idx}. 标题：{item['标题']} | 月销：{item['月销']} | 匹配度：{item['关键词匹配度']}")
    except Exception as e:
        print(f"实战提示：{str(e)}")