Amazon and Walmart product data and search, in one API.

# pip install requests; one ASIN per line in asins.txt (10,000 to 1,000,000 lines)
import csv, json, os, time
import requests

API = "https://api.logimu.com"
s = requests.Session()
s.headers["X-API-KEY"] = os.environ["LOGIMU_API_KEY"]

asins = [line.strip() for line in open("asins.txt") if line.strip()]
runs = []
for i in range(0, len(asins), 20_000):  # up to 20,000 ASINs per batch
    batch = s.post(f"{API}/v1/batches", json={
        "name": f"price-history-{i // 20_000 + 1}", "country": "us", "mode": "cache",
        "include": ["history_only"], "asins": asins[i:i + 20_000]}).json()
    run = s.post(f"{API}/v1/batches/{batch['id']}/runs").json()
    runs.append(f"{API}/v1/batches/{batch['id']}/runs/{run['id']}")

with open("price_history.csv", "w", newline="") as f:
    out = csv.writer(f)
    out.writerow(["asin", "date", "buybox_price"])
    for url in runs:
        while s.get(url).json()["status"] in ("queued", "running"):
            time.sleep(10)
        with s.get(f"{url}/result.jsonl", stream=True) as rows:
            for line in rows.iter_lines():
                row = json.loads(line)
                if row["status"] != "ok":  # not found: never billed
                    continue
                history = row["product"].get("buybox_price_history") or {}
                for point in history.get("points", []):
                    out.writerow([row["asin"], point["date"], point["price"]])

// Node 18+; up to 20,000 ASINs per call
const API = "https://api.logimu.com";
const headers = { "X-API-KEY": process.env.LOGIMU_API_KEY, "Content-Type": "application/json" };
const call = async (path, init = {}) => (await fetch(API + path, { headers, ...init })).json();

async function priceHistory(asins, country = "us") {
  const batch = await call("/v1/batches", { method: "POST", body: JSON.stringify(
    { name: "price-history", country, mode: "cache", include: ["history_only"], asins }) });
  const run = await call(`/v1/batches/${batch.id}/runs`, { method: "POST" });
  const path = `/v1/batches/${batch.id}/runs/${run.id}`;
  while (["queued", "running"].includes((await call(path)).status)) {
    await new Promise((r) => setTimeout(r, 10000));
  }
  const jsonl = await (await fetch(`${API}${path}/result.jsonl`, { headers })).text();
  return jsonl.split("\n").filter(Boolean).map((line) => JSON.parse(line))
    .filter((row) => row.status === "ok")
    .map((row) => ({ asin: row.asin, prices: row.product.buybox_price_history?.points ?? [] }));
}

const rows = await priceHistory(["B00M3IFUMK", "B07YYJRXQR"]);
console.log(rows[0].asin, rows[0].prices.slice(-3));