實時獲取京東指定商品的當(dāng)前價格，示例實戰(zhàn)

管理

編輯

刪除

鍵盤上的螞蟻 2025-07-09 11:23:47

暫不處理

以下是實時獲取京東指定商品當(dāng)前價格的實戰(zhàn)示例，包含接口分析、代碼實現(xiàn)及反爬處理，適用于開發(fā)者快速落地價格監(jiān)控功能：

一、京東商品價格接口分析

京東商品價格數(shù)據(jù)通過獨立 API 接口返回，核心特點：

接口地址：https://p.3.cn/prices/mgets（公開可訪問，登錄）
請求方式：GET
關(guān)鍵參數(shù)：skuIds=J_商品ID（商品 ID 需拼接前綴J_）
返回格式：JSON，包含原價、當(dāng)前價、促銷價等信息

二、實戰(zhàn)代碼實現(xiàn)（Python）

1. 基礎(chǔ)版：單商品價格獲取

import requests
import json

def get_jd_price(sku_id):
    """
    獲取京東指定商品當(dāng)前價格
    :param sku_id: 商品ID（如100012345678）
    :return: 價格字典（含原價、當(dāng)前價等）
    """
    # 構(gòu)造請求參數(shù)
    url = "https://p.3.cn/prices/mgets"
    params = {
        "skuIds": f"J_{sku_id}",  # 必須拼接J_前綴
        "type": 1,
        "area": "1_72_2799_0",    # 地區(qū)編碼（可固定，不影響價格獲?。?        "pduid": "1234567890",   # 隨機用戶ID，可固定
        "_": "1688888888888"     # 時間戳（可選，增加隨機性）
    }
    
    # 請求頭（模擬瀏覽器）
    headers = {
        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.0.0 Safari/537.36",
        "Referer": f"https://item.jd.com/{sku_id}.html",  #  Referer必須與商品頁一致
        "Accept": "application/json, text/plain, */*"
    }
    
    try:
        # 發(fā)送請求
        response = requests.get(url, params=params, headers=headers, timeout=10)
        response.encoding = "utf-8"
        
        # 解析響應(yīng)
        if response.status_code == 200:
            price_data = json.loads(response.text)
            if price_data and len(price_data) > 0:
                # 提取核心價格字段
                return {
                    "sku_id": sku_id,
                    "current_price": float(price_data[0]["p"]),  # 當(dāng)前售價
                    "original_price": float(price_data[0]["m"]), # 原價（市場價）
                    "price_time": response.headers.get("Date")   # 價格更新時間
                }
            else:
                return {"error": "未獲取到價格數(shù)據(jù)"}
        else:
            return {"error": f"請求失敗，狀態(tài)碼：{response.status_code}"}
    
    except Exception as e:
        return {"error": f"接口調(diào)用異常：{str(e)}"}

# 使用示例
if __name__ == "__main__":
    # 京東商品ID（可從商品詳情頁URL獲取，如https://item.jd.com/100032608854.html中的100032608854）
    sku_id = "100032608854"
    price_info = get_jd_price(sku_id)
    
    if "error" in price_info:
        print(f"獲取失?。簕price_info['error']}")
    else:
        print(f"商品ID：{price_info['sku_id']}")
        print(f"當(dāng)前價格：￥{price_info['current_price']}")
        print(f"原價：￥{price_info['original_price']}")
        print(f"價格時間：{price_info['price_time']}")

2. 進階版：批量獲取 + 反爬優(yōu)化

import requests
import json
import time
import random
from fake_useragent import UserAgent

class JDPriceFetcher:
    def __init__(self):
        self.ua = UserAgent()
        self.proxies = self._get_proxies()  # 代理池（可選，高頻請求時使用）
        self.area_codes = [
            "1_72_2799_0",  # 北京地區(qū)
            "2_281_0_0",    # 上海地區(qū)
            "3_340_0_0"     # 廣州地區(qū)
        ]
    
    def _get_proxies(self):
        """獲取代理IP（示例：實際需對接代理服務(wù)）"""
        # 免費代理示例（不穩(wěn)定，生產(chǎn)環(huán)境建議使用付費代理）
        return {
            # "http": "http://123.45.67.89:8080",
            # "https": "https://123.45.67.89:8080"
        }
    
    def _get_headers(self, sku_id):
        """動態(tài)生成請求頭"""
        return {
            "User-Agent": self.ua.random,  # 隨機User-Agent
            "Referer": f"https://item.jd.com/{sku_id}.html",
            "Accept": "application/json, text/plain, */*",
            "Connection": "keep-alive",
            "Cache-Control": "no-cache"
        }
    
    def fetch_price(self, sku_id):
        """獲取單個商品價格（帶反爬處理）"""
        url = "https://p.3.cn/prices/mgets"
        params = {
            "skuIds": f"J_{sku_id}",
            "type": 1,
            "area": random.choice(self.area_codes),  # 隨機地區(qū)編碼
            "pduid": str(random.randint(1000000000, 9999999999)),  # 隨機用戶ID
            "_": int(time.time() * 1000)  # 實時時間戳
        }
        
        try:
            # 隨機延遲（1-3秒），避免高頻請求
            time.sleep(random.uniform(1, 3))
            
            response = requests.get(
                url,
                params=params,
                headers=self._get_headers(sku_id),
                proxies=self.proxies,
                timeout=10,
                verify=False  # 忽略SSL證書驗證（可選，部分代理需要）
            )
            
            if response.status_code == 200:
                price_data = json.loads(response.text)
                if price_data and len(price_data) > 0:
                    return {
                        "sku_id": sku_id,
                        "current_price": float(price_data[0]["p"]),
                        "original_price": float(price_data[0]["m"]),
                        "status": "success"
                    }
                else:
                    return {"sku_id": sku_id, "error": "價格數(shù)據(jù)為空", "status": "fail"}
            else:
                return {
                    "sku_id": sku_id,
                    "error": f"狀態(tài)碼：{response.status_code}",
                    "status": "fail"
                }
        
        except Exception as e:
            return {
                "sku_id": sku_id,
                "error": str(e),
                "status": "fail"
            }
    
    def batch_fetch(self, sku_ids):
        """批量獲取多個商品價格"""
        results = []
        for sku_id in sku_ids:
            print(f"正在獲取商品 {sku_id} 價格...")
            result = self.fetch_price(sku_id)
            results.append(result)
        return results

# 批量獲取示例
if __name__ == "__main__":
    fetcher = JDPriceFetcher()
    # 待查詢的商品ID列表
    sku_ids = [
        "100032608854",  # 示例商品1
        "100012345678",  # 示例商品2
        "100008348544"   # 示例商品3
    ]
    
    # 批量獲取價格
    prices = fetcher.batch_fetch(sku_ids)
    
    # 打印結(jié)果
    print("\n===== 價格查詢結(jié)果 =====")
    for item in prices:
        if item["status"] == "success":
            print(f"商品 {item['sku_id']}：當(dāng)前價 ￥{item['current_price']}，原價 ￥{item['original_price']}")
        else:
            print(f"商品 {item['sku_id']}：獲取失敗，原因：{item['error']}")

三、關(guān)鍵技術(shù)點解析

參數(shù)構(gòu)造：skuIds必須以J_為前綴（京東商品 ID 格式要求）area參數(shù)為地區(qū)編碼（如1_72_2799_0代表北京朝陽區(qū)），不影響價格但增加請求真實性
反爬處理：隨機 User-Agent：使用fake_useragent庫生成不同設(shè)備的瀏覽器標(biāo)識Referer 驗證：必須與商品詳情頁 URL 一致，否則可能返回 403請求延遲：每次請求間隔 1-3 秒，避免觸發(fā)頻率限制代理 IP：高頻請求時使用代理池，防止 IP 被封
數(shù)據(jù)解析：核心字段：p（當(dāng)前價）、m（原價），返回值為字符串需轉(zhuǎn)為浮點數(shù)異常處理：針對網(wǎng)絡(luò)超時、JSON 解析失敗等情況返回錯誤信息

四、注意事項

合規(guī)性：非商業(yè)用途合理調(diào)用（建議≤100 次 / 小時）遵守京東robots.txt規(guī)則（https://www.jd.com/robots.txt）數(shù)據(jù)不得用于商業(yè)售賣或惡意競爭
接口穩(wěn)定性：京東可能不定期調(diào)整接口參數(shù)，需定期測試代碼若返回 403/429，需增加延遲或更換 IP
通過以上示例，可快速實現(xiàn)京東商品價格的實時獲取，結(jié)合定時任務(wù)和數(shù)據(jù)存儲，可進一步構(gòu)建價格監(jiān)控系統(tǒng)，為用戶提供降價提醒、趨勢分析等增值服務(wù)。

請登錄后查看

鍵盤上的螞蟻最后編輯于2025-07-09 11:23:47

快捷回復(fù)