电商选品效率翻倍！基于 Open Claw + 淘宝商品 API 实现自动化监控选品（附完整可运行代码）

pip install requests json5 time  # requests用于接口请求，time用于定时轮询

# -*- coding: utf-8 -*-
# 淘宝商品API 单商品查询测试脚本 适配Open Claw
import requests
import json

# ==================== 请手动修改以下配置项 ====================
APP_KEY = "你的Appkey"        # 替换为你自己的Appkey
APP_SECRET = "你的Appsecret"  # 替换为你自己的Appsecret
ITEM_ID = "123456789"        # 替换为目标淘宝商品ID
API_URL = "https://open.onebound.cn/api/taobao/item_get_pro"
# ==========================================================

def get_taobao_item_info():
    """调用淘宝商品详情API，获取单商品数据"""
    # 组装请求参数
    params = {
        "key": APP_KEY,
        "secret": APP_SECRET,
        "num_iid": ITEM_ID,
        "format": "json"
    }
    try:
        # 发起GET请求
        response = requests.get(url=API_URL, params=params, timeout=10)
        # 解析JSON数据
        res_data = json.loads(response.text)
        
        # 判断接口返回状态
        if res_data.get("code") == 0:
            print("✅ 接口调用成功，商品原始数据：")
            print(json.dumps(res_data, ensure_ascii=False, indent=2))
        else:
            print(f"❌ 接口调用失败：{res_data.get('msg', '未知错误')}")
    
    except Exception as e:
        print(f"❌ 请求异常：{str(e)}")

# 主函数（Open Claw调度入口）
if __name__ == "__main__":
    get_taobao_item_info()

# -*- coding: utf-8 -*-
# Open Claw + 淘宝API 批量商品监控&自动化选品脚本
# 功能：批量监控商品、自定义选品规则、定时轮询、结果日志留存
import requests
import json
import time
from datetime import datetime

# ==================== 核心配置区（根据自身选品需求修改） ====================
# 接口密钥
APP_KEY = "你的Appkey"
APP_SECRET = "你的Appsecret"
API_URL = "https://open.onebound.cn/api/taobao/item_get_pro"

# 待监控的商品ID列表（可批量添加竞品/候选选品ID）
MONITOR_ITEM_IDS = [
    "123456789",
    "987654321",
    "1122334455"
]

# 自定义选品筛选规则（重点！按需调整）
SELECT_RULE = {
    "min_price": 19.9,    # 最低售价
    "max_price": 99.9,    # 最高售价
    "min_sale": 500,      # 最低月销量（筛选爆款基础门槛）
    "target_category": ""  # 目标类目，为空则不限制
}

# 轮询间隔（单位：秒），建议300秒以上，避免接口请求频繁
LOOP_INTERVAL = 300
# 日志文件路径（自动记录每一轮选品结果）
LOG_FILE = "taobao_shop_select_log.txt"
# ======================================================================

def write_log(content):
    """写入本地日志，记录监控&选品结果"""
    now_time = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
    log_content = f"[{now_time}] {content}\n"
    with open(LOG_FILE, "a", encoding="utf-8") as f:
        f.write(log_content)
    print(log_content.strip())

def get_single_item(item_id):
    """获取单个商品详细数据"""
    params = {
        "key": APP_KEY,
        "secret": APP_SECRET,
        "num_iid": item_id,
        "format": "json"
    }
    try:
        resp = requests.get(API_URL, params=params, timeout=15)
        data = json.loads(resp.text)
        return data
    except Exception as e:
        write_log(f"商品ID：{item_id} 请求异常：{str(e)}")
        return None

def filter_goods(item_data):
    """根据自定义规则筛选潜力商品，返回筛选结果"""
    if not item_data or item_data.get("code") != 0:
        return False, "接口数据异常"
    
    item_info = item_data.get("data", {})
    # 提取核心选品字段
    item_title = item_info.get("title", "无标题")
    item_price = float(item_info.get("price", 0))
    item_sale = int(item_info.get("sales", 0))
    item_category = item_info.get("category", "未知类目")
    item_url = item_info.get("item_url", "")

    # 规则1：价格区间筛选
    if not (SELECT_RULE["min_price"] <= item_price <= SELECT_RULE["max_price"]):
        return False, f"价格不达标，当前价：{item_price}元"
    
    # 规则2：销量筛选
    if item_sale < SELECT_RULE["min_sale"]:
        return False, f"销量不足，当前销量：{item_sale}"
    
    # 规则3：类目筛选（配置类目时生效）
    if SELECT_RULE["target_category"] and SELECT_RULE["target_category"] not in item_category:
        return False, f"类目不符，当前类目：{item_category}"

    # 全部规则通过，判定为潜力选品
    result = f"【潜力商品】标题：{item_title} | 价格：{item_price}元 | 销量：{item_sale} | 类目：{item_category} | 链接：{item_url}"
    return True, result

def main_monitor():
    """主监控逻辑：批量遍历商品 + 筛选 + 日志记录"""
    write_log("========== 新一轮商品选品监控开始 ==========")
    for item_id in MONITOR_ITEM_IDS:
        item_data = get_single_item(item_id)
        is_pass, msg = filter_goods(item_data)
        write_log(f"商品ID：{item_id} -> {msg}")
    write_log("========== 本轮监控结束 ==========\n")

# 主程序：结合Open Claw实现永久定时轮询
if __name__ == "__main__":
    write_log("系统启动，淘宝自动化选品监控已开启！")
    while True:
        main_monitor()
        # 等待指定时间后进入下一轮监控
        time.sleep(LOOP_INTERVAL)