# 安装核心库pip install requests # 发送HTTP请求pip install fastapi # 封装API（轻量高效）pip install uvicorn # 运行API服务pip install python-dotenv # 管理环境变量（保护敏感信息）pip install beautifulsoup4 # 可选：解析HTML格式数据

import requestsimport timefrom dotenv import load_dotenvimport os# 加载环境变量（避免硬编码敏感信息）load_dotenv()

USER_AGENT = os.getenv("USER_AGENT")

COOKIE = os.getenv("TAOBAO_COOKIE")def get_taobao_item_data(num_iid: str) -> dict:"""

获取淘宝商品详情页公开数据

:param num_iid: 商品ID

:return: 商品数据字典（失败返回空字典）

"""# 接口参数（需根据实际抓包结果调整）url = "https://h5api.m.taobao.com/h5/mtop.taobao.item.get/1.0/"params = {"num_iid": num_iid,"type": "item","dataType": "json","timestamp": str(int(time.time() * 1000)) # 生成毫秒级时间戳}# 请求头（模拟浏览器）headers = {"User-Agent": USER_AGENT,"Cookie": COOKIE,"Referer": f"https://item.taobao.com/item.htm?id={num_iid}" # 模拟来源页}try:# 发送请求（设置超时时间，避免无限等待）response = requests.get(url, params=params, headers=headers, timeout=10)

response.raise_for_status() # 若状态码非200，抛出HTTPError# 解析响应（淘宝部分接口返回格式含外层包裹，需调整）data = response.json()if data.get("ret", [])[0] == "SUCCESS::调用成功":return data.get("data", {}).get("item", {}) # 提取商品核心数据else:print(f"接口返回错误：{data.get('ret', [])}")return {}except requests.exceptions.HTTPError as e:print(f"HTTP错误：{e}（可能被反爬）")return {}except requests.exceptions.Timeout as e:print(f"请求超时：{e}")return {}except Exception as e:print(f"未知错误：{e}")return {}# 测试：获取指定商品数据if __name__ == "__main__":

item_data = get_taobao_item_data("123456789")print("商品数据：", item_data)

def extract_item_key_info(item_data: dict) -> dict:"""

提取商品关键信息

:param item_data: 接口返回的原始商品数据

:return: 简化后的关键信息字典

"""if not item_data:return {}# 提取核心字段（字段名需根据实际接口返回调整）key_info = {"商品ID": item_data.get("num_iid", ""),"商品标题": item_data.get("title", ""),"现价": item_data.get("price", ""),"原价": item_data.get("original_price", ""),"销量": item_data.get("sale_count", ""),"店铺名称": item_data.get("shop", {}).get("shop_name", ""),"详情图URL列表": item_data.get("desc_images", []), # 商品详情图"主图URL列表": [item_data.get("pic_url", "")] + item_data.get("pic_urls", []) # 主图+轮播图}return key_info# 测试：提取关键信息if __name__ == "__main__":

item_data = get_taobao_item_data("123456789")

key_info = extract_item_key_info(item_data)print("商品关键信息：", key_info)

from fastapi import FastAPI, Query, HTTPExceptionfrom fastapi.middleware.cors import CORSMiddlewareimport timefrom crawl_taobao import get_taobao_item_data, extract_item_key_info # 导入爬取函数from dotenv import load_dotenv# 加载环境变量load_dotenv()

app = FastAPI(title="淘宝商品公开数据API", version="1.0")# 解决跨域问题（允许前端调用）app.add_middleware(

CORSMiddleware,

allow_origins=["*"], # 生产环境需指定具体域名，避免安全风险allow_credentials=True,

allow_methods=["*"],

allow_headers=["*"],

)# 记录请求频率（防止单IP高频爬取）request_records = {}

MAX_REQUESTS_PER_MINUTE = 60 # 每分钟最大请求数（可调整）def check_request_limit(client_ip: str) -> bool:"""检查请求频率限制"""current_time = time.time()# 清理1分钟前的记录request_records[client_ip] = [t for t in request_records.get(client_ip, []) if current_time - t < 60]# 判断是否超过限制if len(request_records[client_ip]) >= MAX_REQUESTS_PER_MINUTE:return False# 记录当前请求时间request_records[client_ip].append(current_time)return True@app.get("/api/taobao/item", summary="获取淘宝商品公开数据")def get_item_info(num_iid: str = Query(..., description="淘宝商品ID（从商品URL中提取）"),

client_ip: str = Query(..., description="客户端IP（用于请求频率控制）")):# 检查请求频率if not check_request_limit(client_ip):raise HTTPException(status_code=429, detail="请求过于频繁，请1分钟后再试")# 爬取并提取数据item_data = get_taobao_item_data(num_iid)if not item_data:raise HTTPException(status_code=404, detail="商品数据获取失败（可能商品不存在或被反爬）")

key_info = extract_item_key_info(item_data)return {"code": 200,"message": "success","data": key_info

}if __name__ == "__main__":import uvicorn# 运行API服务（默认端口8000）uvicorn.run("main:app", host="0.0.0.0", port=8000, reload=True)