import requests
import json

# API配置
API_KEY = "your_api_key_here"
API_ENDPOINT = "https://api.pangolinfo.com/v1/amazon/search"

# 请求参数
params = {
    "keyword": "wireless headphones",  # 搜索关键词
    "marketplace": "amazon.com",       # 亚马逊站点
    "postal_code": "10001",            # 邮编（用于定位特定区域的广告展示）
    "sponsored_only": True,            # 仅返回Sponsored广告结果
    "page": 1,                         # 搜索结果页码
    "detailed": True                   # 返回详细广告数据
}

# 发送请求
headers = {
    "Authorization": f"Bearer {API_KEY}",
    "Content-Type": "application/json"
}

response = requests.post(
    API_ENDPOINT,
    headers=headers,
    data=json.dumps(params)
)

# 处理响应
if response.status_code == 200:
    sponsored_ads = response.json()
    
    # 打印Sponsored广告数据
    for ad in sponsored_ads["data"]["sponsored_ads"]:
        print(f"ASIN: {ad['asin']}")
        print(f"标题: {ad['title']}")
        print(f"广告位置: {ad['position']}")
        print(f"广告类型: {ad['ad_type']}")
        print(f"品牌: {ad['brand']}")
        print(f"价格: {ad['price']}")
        print("-------------------")
else:
    print(f"请求失败: {response.status_code}")
    print(response.text)

import requests
import json
import pandas as pd
import time
from concurrent.futures import ThreadPoolExecutor

# API配置
API_KEY = "your_api_key_here"
API_ENDPOINT = "https://api.pangolinfo.com/v1/amazon/search"

# 关键词列表
keywords = [
    "wireless headphones",
    "bluetooth earbuds",
    "noise cancelling headphones",
    "gaming headset",
    "workout earphones"
]

# 抓取单个关键词的Sponsored广告
def fetch_sponsored_ads(keyword):
    params = {
        "keyword": keyword,
        "marketplace": "amazon.com",
        "postal_code": "10001",
        "sponsored_only": True,
        "page": 1,
        "detailed": True
    }
    
    headers = {
        "Authorization": f"Bearer {API_KEY}",
        "Content-Type": "application/json"
    }
    
    try:
        response = requests.post(
            API_ENDPOINT,
            headers=headers,
            data=json.dumps(params)
        )
        
        if response.status_code == 200:
            return {
                "keyword": keyword,
                "data": response.json()["data"]["sponsored_ads"]
            }
        else:
            print(f"请求失败 ({keyword}): {response.status_code}")
            return {"keyword": keyword, "data": []}
    except Exception as e:
        print(f"请求异常 ({keyword}): {str(e)}")
        return {"keyword": keyword, "data": []}

# 并行处理多个关键词
results = []
with ThreadPoolExecutor(max_workers=5) as executor:
    for result in executor.map(fetch_sponsored_ads, keywords):
        results.append(result)

# 整理数据为DataFrame
all_ads = []
for result in results:
    keyword = result["keyword"]
    for ad in result["data"]:
        ad_data = {
            "keyword": keyword,
            "asin": ad.get("asin", ""),
            "title": ad.get("title", ""),
            "brand": ad.get("brand", ""),
            "position": ad.get("position", ""),
            "ad_type": ad.get("ad_type", ""),
            "price": ad.get("price", "")
        }
        all_ads.append(ad_data)

# 创建DataFrame并导出
df = pd.DataFrame(all_ads)
df.to_csv("amazon_sponsored_ads_data.csv", index=False)
print(f"已抓取 {len(all_ads)} 条Sponsored广告数据，已保存到CSV文件")