import requests

def fetch_asin_details(asin: str, api_key: str, marketplace: str = "US") -> dict:
    response = requests.post(
        "https://api.pangolinfo.com/v1/amazon/product",
        headers={"Authorization": f"Bearer {api_key}"},
        json={
            "asin": asin,
            "marketplace": marketplace,
            "fields": ["title", "brand", "price", "bsr",
                       "rating", "review_count", "availability",
                       "bullet_points", "customer_says"]
        },
        timeout=30
    )
    response.raise_for_status()
    return response.json()

result = fetch_asin_details("B07EXAMPLE1", "YOUR_API_KEY")
print(f"标题: {result['title']}")
print(f"价格: ${result['price']['current']}")
print(f"BSR: #{result['bsr']['rank']} in {result['bsr']['category']}")
print(f"评分: {result['rating']}/5.0 ({result['review_count']} reviews)")

from concurrent.futures import ThreadPoolExecutor, as_completed
import requests, time, logging

logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)

class AmazonASINBatchCollector:
    """亚马逊ASIN批量采集器，支持并发控制和错误重试"""
    
    def __init__(self, api_key, marketplace="US", max_workers=5, max_retries=3):
        self.api_key = api_key
        self.marketplace = marketplace
        self.max_workers = max_workers
        self.max_retries = max_retries
        self.session = requests.Session()
        self.session.headers.update({"Authorization": f"Bearer {api_key}"})
    
    def fetch_single(self, asin: str) -> dict:
        for attempt in range(self.max_retries):
            try:
                resp = self.session.post(
                    "https://api.pangolinfo.com/v1/amazon/product",
                    json={"asin": asin, "marketplace": self.marketplace,
                          "fields": ["title", "price", "bsr", "rating",
                                     "review_count", "availability"]},
                    timeout=30
                )
                if resp.status_code == 429:
                    time.sleep(2 ** attempt)  # 指数退避
                    continue
                if resp.status_code == 404:
                    return {"asin": asin, "success": False, "error": "ASIN not found"}
                resp.raise_for_status()
                return {"asin": asin, "success": True, "data": resp.json()}
            except Exception as e:
                if attempt == self.max_retries - 1:
                    return {"asin": asin, "success": False, "error": str(e)}
                time.sleep(2)
        return {"asin": asin, "success": False, "error": "Max retries exceeded"}
    
    def fetch_batch(self, asins: list) -> list:
        results = []
        with ThreadPoolExecutor(max_workers=self.max_workers) as executor:
            futures = {executor.submit(self.fetch_single, a): a for a in asins}
            for i, future in enumerate(as_completed(futures), 1):
                results.append(future.result())
                if i % 10 == 0:
                    ok = sum(1 for r in results if r.get("success"))
                    logger.info(f"进度 {i}/{len(asins)} | 成功 {ok} | 失败 {i-ok}")
        return results

# 使用示例：批量采集100个ASIN
collector = AmazonASINBatchCollector("YOUR_PANGOLINFO_KEY", max_workers=5)
results = collector.fetch_batch(["B07EXAMPLE1", "B07EXAMPLE2"])  # 替换为真实ASIN列表
ok = [r for r in results if r.get("success")]
fail = [r for r in results if not r.get("success")]
print(f"成功: {len(ok)} | 失败: {len(fail)}")