实战教程：借助 Open Claw + 淘宝商品 API，低成本实现电商自动化监控与智能选品

# 执行命令安装依赖
pip install requests  # 用于发送HTTP接口请求
pip install schedule  # 基础定时任务库（搭配Open Claw使用）

import requests
import json

# ========== 请自行修改以下配置参数 ==========
# 接口请求地址
API_URL = "https://open.onebound.cn/taobao/item_get_pro"
# 你的接口密钥（平台申请获取）
APP_KEY = "你的Appkey"
APP_SECRET = "你的Secret"
# 目标淘宝商品ID（可在商品详情页URL中提取）
TARGET_ITEM_ID = "689012345678"

def get_taobao_item_detail(item_id: str) -> dict:
    """
    调用淘宝商品高阶接口，获取单款商品完整数据
    :param item_id: 淘宝商品ID
    :return: 商品结构化数据字典
    """
    # 组装接口请求参数
    params = {
        "appkey": APP_KEY,
        "secret": APP_SECRET,
        "num_iid": item_id,  # 商品ID，接口固定字段
        "format": "json"     # 指定返回数据格式为JSON
    }

    try:
        # 发送GET请求调用接口
        response = requests.get(url=API_URL, params=params, timeout=10)
        # 解析JSON数据
        result = response.json()

        # 接口状态判断
        if result.get("code") != 0:
            print(f"接口调用失败：{result.get('msg')}")
            return {}
        
        # 提取核心商品数据
        item_data = result.get("data", {})
        return item_data

    except Exception as e:
        print(f"请求异常，错误信息：{str(e)}")
        return {}

# 测试单商品查询
if __name__ == "__main__":
    item_info = get_taobao_item_detail(TARGET_ITEM_ID)
    if item_info:
        print("===== 淘宝商品基础信息 =====")
        print(f"商品标题：{item_info.get('title')}")
        print(f"现价：{item_info.get('price')} 元")
        print(f"原价：{item_info.get('org_price')} 元")
        print(f"累计销量：{item_info.get('sales')}")
        print(f"库存数量：{item_info.get('stock')}")
        print(f"所属类目：{item_info.get('category_name')}")
        print(f"商品链接：{item_info.get('item_url')}")

def batch_item_filter(item_id_list: list) -> list:
    """
    批量抓取商品数据，并根据规则筛选潜力选品
    :param item_id_list: 商品ID列表
    :return: 筛选后的优质商品列表
    """
    good_items = []
    # 遍历所有商品ID，逐个查询数据
    for item_id in item_id_list:
        data = get_taobao_item_detail(item_id)
        if not data:
            continue
        
        # ========== 自定义选品规则（可按需修改） ==========
        price = float(data.get("price", 0))
        sales = int(data.get("sales", 0))
        stock = int(data.get("stock", 0))
        # 规则1：价格区间 10~100元；规则2：销量大于500；规则3：库存大于10
        if 10 <= price <= 100 and sales > 500 and stock > 10:
            good_items.append({
                "item_id": item_id,
                "title": data.get("title"),
                "price": price,
                "sales": sales,
                "stock": stock,
                "item_url": data.get("item_url")
            })
    return good_items

# 批量选品测试
if __name__ == "__main__":
    # 待监控/选品的商品ID集合
    item_ids = [
        "689012345678",
        "689012345679",
        "689012345680",
        "689012345681"
    ]
    # 执行筛选
    result_list = batch_item_filter(item_ids)
    print(f"\n===== 筛选出 {len(result_list)} 款潜力商品 =====")
    for item in result_list:
        print(f"【{item['title']}】价格：{item['price']}元 | 销量：{item['sales']} | 链接：{item['item_url']}")

import schedule
import time

# 存储商品历史数据（用于对比变动）
history_data = {}
# 监控的商品ID列表
MONITOR_ITEM_IDS = ["689012345678", "689012345679"]

def monitor_item_change():
    """商品变动监控主函数，定时执行"""
    global history_data
    print(f"\n【{time.strftime('%Y-%m-%d %H:%M:%S')}】开始新一轮监控...")

    for item_id in MONITOR_ITEM_IDS:
        current_data = get_taobao_item_detail(item_id)
        if not current_data:
            continue
        
        # 首次监控，初始化历史数据
        if item_id not in history_data:
            history_data[item_id] = {
                "price": current_data.get("price"),
                "stock": current_data.get("stock")
            }
            print(f"初始化商品【{current_data.get('title')}】监控数据")
            continue
        
        # 对比历史数据，判断变动
        old_price = history_data[item_id]["price"]
        old_stock = history_data[item_id]["stock"]
        new_price = current_data.get("price")
        new_stock = current_data.get("stock")
        title = current_data.get("title")

        # 价格变动预警
        if old_price != new_price:
            print(f"⚠️ 价格预警：{title} 原价{old_price}元 → 现价{new_price}元")
        # 库存变动预警（库存低于5触发断货提醒）
        if int(new_stock) < 5:
            print(f"⚠️ 库存预警：{title} 库存仅剩{new_stock}件，即将断货！")
        elif old_stock != new_stock:
            print(f"ℹ️ 库存变动：{title} 库存{old_stock} → {new_stock}")

        # 更新历史数据
        history_data[item_id]["price"] = new_price
        history_data[item_id]["stock"] = new_stock

# 配置定时任务：每5分钟执行一次监控
schedule.every(5).minutes.do(monitor_item_change)

# 启动定时监控（接入Open Claw后，可由Open Claw托管任务）
if __name__ == "__main__":
    print("淘宝商品监控系统已启动，每5分钟自动轮询...")
    while True:
        schedule.run_pending()
        time.sleep(1)