告别 “搜不到 / 慢半拍”！搜好货商品搜索接口技术拆解

import requests
import hashlib
import urllib.parse
import json
import redis
import os  # 用环境变量存密钥，更安全
# 1. 签名生成（搜好货工业接口专属规则）
def generate_souhaohuo_sign(params, api_secret):
    # 移除已有sign，按ASCII升序排序
    if "sign" in params:
        params.pop("sign")
    sorted_params = sorted(params.items(), key=lambda x: x[0])
    # 拼接参数（特殊字符编码，适配工业关键词）
    param_str = ""
    for key, value in sorted_params:
        # 处理型号里的特殊字符（如“/”“-”）
        encoded_val = urllib.parse.quote(str(value), safe='')
        param_str += f"{key}{encoded_val}"
    # 首尾加secret，MD5加密
    sign_str = f"{api_secret}{param_str}{api_secret}"
    return hashlib.md5(sign_str.encode('utf-8')).hexdigest().upper()
# 2. 带工业场景缓存的搜索函数
def search_souhaohuo_industrial(keyword, category="", page_size=50, page_num=1):
    # 从环境变量拿密钥，避免泄露
    api_key = os.getenv("SOUHAOHUO_API_KEY")
    api_secret = os.getenv("SOUHAOHUO_API_SECRET")
    if not api_key or not api_secret:
        raise Exception("请先配置SOUHAOHUO_API_KEY和SOUHAOHUO_API_SECRET环境变量")
    # 连接Redis（本地，工业场景建议单独建库）
    r = redis.Redis(host='localhost', port=6379, db=1, decode_responses=True)
    # 缓存键：带品类，避免工业/非工业数据混装
    cache_key = f"souhaohuo_industrial_{keyword}_{category}_{page_size}_{page_num}"
    # 先查缓存（工业高频词缓存久，低频词短）
    if cached_data := r.get(cache_key):
        print("从缓存获取工业商品数据，响应更快！")
        return json.loads(cached_data)
    # 构建参数（加工业品类筛选）
    params = {
        "api_key": api_key,
        "keyword": keyword,
        "page_size": page_size,
        "page_num": page_num
    }
    if category:  # 传工业品类编码，精准筛选
        params["category"] = category
    # 生成签名
    params["sign"] = generate_souhaohuo_sign(params, api_secret)
    # 发送请求（搜好货工业接口地址）
    url = "https://api.souhaohuo.com/item_search"
    response = requests.get(url, params=params, timeout=10)
    # 处理响应
    if response.status_code == 200:
        data = response.json()
        # 工业词缓存策略：高频10分钟（600秒），低频3分钟（180秒）
        expire_time = 600 if keyword in ["电机", "阀门", "轴承"] else 180
        r.setex(cache_key, expire_time, json.dumps(data))
        return data
    else:
        raise Exception(f"请求失败：状态码{response.status_code}，原因{response.text}")
# 3. 工业场景示例调用（搜“电机Y2-132M”，品类编码1001）
if __name__ == "__main__":
    try:
        # 配置环境变量（实际部署时在服务器配置，别写代码里）
        os.environ["SOUHAOHUO_API_KEY"] = "你的api_key"
        os.environ["SOUHAOHUO_API_SECRET"] = "你的api_secret"
        # 搜索工业电机（品类编码1001）
        result = search_souhaohuo_industrial(
            keyword="电机Y2-132M",
            category="1001",
            page_size=50,
            page_num=1
        )
        # 打印工业商品关键信息（型号、价格、销量）
        for item in result["items"]:
            print(f"商品名：{item['title']} | 型号：{item.get('model', '无')} | 价格：{item['price']} | 销量：{item['sales']}")
    except Exception as e:
        print(f"开发报错：{str(e)}")