京东开放平台商品评论接口实战：分页获取 + 评论过滤 + 结构化解析（附 Python 代码）

import requests
import hashlib
import time
import json

class JDCommentAPI:
    """京东商品评论接口（官方API·生产级封装）"""
    def __init__(self, app_key, app_secret):
        self.app_key = app_key
        self.app_secret = app_secret
        self.api_url = "https://api.jd.com/routerjson"
        self.timeout = 10

    def create_sign(self, params):
        """京东官方SHA256签名（标准实现）"""
        sorted_items = sorted(params.items())
        sign_str = self.app_secret + "".join(f"{k}{v}" for k, v in sorted_items) + self.app_secret
        return hashlib.sha256(sign_str.encode("utf-8")).hexdigest().upper()

    def get_goods_comments(self, goods_id, page=1, page_size=20, comment_type=0):
        """
        获取商品评论
        :param goods_id: 商品ID
        :param page: 页码
        :param page_size: 每页数量
        :param comment_type: 0-全部 1-好评 2-中评 3-差评 4-图/视频
        """
        # 13位时间戳
        timestamp = str(int(time.time() * 1000))

        # 业务参数
        param_json = {
            "goodsId": goods_id,
            "page": page,
            "pageSize": page_size,
            "commentType": comment_type
        }

        # 公共参数
        params = {
            "method": "jd.union.open.goods.comment.query",
            "app_key": self.app_key,
            "timestamp": timestamp,
            "v": "1.0",
            "format": "json",
            "param_json": json.dumps(param_json)
        }

        # 生成签名
        params["sign"] = self.create_sign(params)

        try:
            resp = requests.post(self.api_url, data=params, timeout=self.timeout)
            result = resp.json()

            # 错误判断
            if "error_response" in result:
                err = result["error_response"]
                return {"code": -1, "msg": err.get("zh_desc", "接口异常")}

            # 解析评论数据
            res_data = result.get("jd_union_open_goods_comment_query_response", {}).get("result", {})
            comment_list = res_data.get("commentInfoList", [])
            total = res_data.get("totalCount", 0)

            # 结构化输出
            comments = []
            for c in comment_list:
                comments.append({
                    "content": c.get("content"),
                    "creation_time": c.get("creationTime"),
                    "nickname": c.get("nickname"),
                    "score": c.get("score"),
                    "is_video": c.get("isVideo"),
                    "img_list": c.get("imgUrlList", [])
                })

            time.sleep(0.8)  # 防风控间隔
            return {
                "code": 200,
                "msg": "success",
                "total": total,
                "comments": comments
            }

        except Exception as e:
            return {"code": 500, "msg": f"请求异常：{str(e)}"}

# ———— 调用示例 ————
if __name__ == "__main__":
    APP_KEY = "你的app_key"
    APP_SECRET = "你的app_secret"

    api = JDCommentAPI(APP_KEY, APP_SECRET)
    # 获取商品评论（全部评论）
    res = api.get_goods_comments(goods_id="100012345678", page=1, page_size=20, comment_type=0)
    print(json.dumps(res, ensure_ascii=False, indent=2))