curl -X POST \
  "https://api.brightdata.com/dca/trigger?collector=$BRIGHT_DATA_COLLECTOR_ID&queue_next=1" \
  -H "Authorization: Bearer $BRIGHTDATA_API_KEY" \
  -H "Content-Type: application/json" \
  -d '[
    {"url": "https://ecommerce-shop-brd.vercel.app/product/echo-portable-speaker"},
    {"url": "https://ecommerce-shop-brd.vercel.app/product/nimbus-cloud-storage"}
  ]'

import os
import requests

API_TOKEN    = os.environ["BRIGHTDATA_API_KEY"]
COLLECTOR_ID = os.environ["BRIGHT_DATA_COLLECTOR_ID"]

response = requests.post(
    f"https://api.brightdata.com/dca/trigger?collector={COLLECTOR_ID}&queue_next=1",
    headers={
        "Authorization": f"Bearer {API_TOKEN}",
        "Content-Type": "application/json",
    },
    json=[
        {"url": "https://ecommerce-shop-brd.vercel.app/product/echo-portable-speaker"},
        {"url": "https://ecommerce-shop-brd.vercel.app/product/nimbus-cloud-storage"},
    ],
)
response.raise_for_status()
snapshot_id = response.json()["collection_id"]
print(snapshot_id)  # j_abc123def456

const triggerUrl =
  `https://api.brightdata.com/dca/trigger` +
  `?collector=${process.env.BRIGHT_DATA_COLLECTOR_ID}&queue_next=1`;

const response = await fetch(triggerUrl, {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.BRIGHTDATA_API_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify([
    { url: "https://ecommerce-shop-brd.vercel.app/product/echo-portable-speaker" },
    { url: "https://ecommerce-shop-brd.vercel.app/product/nimbus-cloud-storage" },
  ]),
});

const { collection_id: snapshotId } = await response.json();
console.log(snapshotId); // j_abc123def456

# Poll every 5 seconds until the response is a JSON array (not an object).
while :; do
  response=$(curl -s \
    "https://api.brightdata.com/dca/dataset?id=$SNAPSHOT_ID" \
    -H "Authorization: Bearer $BRIGHTDATA_API_KEY")
  if [[ "${response:0:1}" == "[" ]]; then
    echo "$response" > results.json
    break
  fi
  sleep 5
done

import json
import time

while True:
    response = requests.get(
        f"https://api.brightdata.com/dca/dataset?id={snapshot_id}",
        headers={"Authorization": f"Bearer {API_TOKEN}"},
    )
    response.raise_for_status()
    body = response.json()
    if isinstance(body, list) and body:
        with open("results.json", "w") as f:
            json.dump(body, f, indent=2)
        break
    time.sleep(5)

const datasetUrl =
  `https://api.brightdata.com/dca/dataset?id=${snapshotId}`;

while (true) {
  const response = await fetch(datasetUrl, {
    headers: { Authorization: `Bearer ${process.env.BRIGHTDATA_API_KEY}` },
  });
  const body = await response.json();
  if (Array.isArray(body) && body.length > 0) {
    await fs.writeFile("results.json", JSON.stringify(body, null, 2));
    break;
  }
  await new Promise((r) => setTimeout(r, 5000));
}