Google Shopping（异步）

curl -X POST "https://api.seermartech.cn/v3/merchant/google/products/task_post" \
  -H "Authorization: Bearer smt_live_YOUR_KEY" \
  -H "Content-Type: application/json" \
  -d '[{"keyword": "wireless earbuds", "location_code": 2840, "language_code": "en", "depth": 50}]'

import time
import requests
 
API_KEY = "smt_live_YOUR_KEY"
BASE = "https://api.seermartech.cn/v3"
HEADERS = {"Authorization": f"Bearer {API_KEY}"}
 
post = requests.post(
    f"{BASE}/merchant/google/products/task_post",
    headers={**HEADERS, "Content-Type": "application/json"},
    json=[{"keyword": "wireless earbuds", "location_code": 2840, "language_code": "en", "depth": 50}],
    timeout=60,
)
task_id = post.json()["tasks"][0]["id"]
 
for _ in range(30):
    get = requests.get(f"{BASE}/merchant/google/products/task_get/{task_id}", headers=HEADERS, timeout=60)
    data = get.json()
    if data["tasks"][0]["status_code"] == 20000:
        print(len(data["tasks"][0]["result"][0]["items"]), "products")
        break
    time.sleep(10)

const API_KEY = "smt_live_YOUR_KEY";
const BASE = "https://api.seermartech.cn/v3";
 
async function fetchGoogleShopping() {
  const postResp = await fetch(`${BASE}/merchant/google/products/task_post`, {
    method: "POST",
    headers: { Authorization: `Bearer ${API_KEY}`, "Content-Type": "application/json" },
    body: JSON.stringify([{ keyword: "wireless earbuds", location_code: 2840, language_code: "en", depth: 50 }]),
  });
  const taskId = (await postResp.json()).tasks[0].id;
  for (let i = 0; i < 30; i++) {
    const getResp = await fetch(`${BASE}/merchant/google/products/task_get/${taskId}`, {
      headers: { Authorization: `Bearer ${API_KEY}` },
    });
    const data = await getResp.json();
    if (data.tasks[0].status_code === 20000) return data;
    await new Promise((r) => setTimeout(r, 10_000));
  }
}