Node.js SDK

npm install "github:ZenRows/zenrows-node-sdk#feature/batch-api/rc"

import { ZenRowsBatchClient } from "zenrows/batch";

const client = new ZenRowsBatchClient("YOUR_ZENROWS_API_KEY");

const job = await client.submitRegular({
  urls: [
    "https://www.scrapingcourse.com/ecommerce/product/abominable-hoodie",
    "https://www.scrapingcourse.com/ecommerce/product/adrienne-trek-jacket",
  ],
  zenrowsParams: { js_render: "true", premium_proxy: "true" },
});

const run = await job.run.wait();
console.log(`${run.data.stats.successful}/${run.data.stats.total} succeeded`);

for await (const row of run.results({ status: "successful" })) {
  console.log(row.externalId ?? row.taskId, "->", row.resultUrl);
}

const job = await client.submitRegular({
  urls: ["https://www.scrapingcourse.com/ecommerce/product/abominable-hoodie"],
  zenrowsParams: {
    js_render: "true",
    premium_proxy: "true",
    proxy_country: "us",
    wait_for: ".price",
    response_type: "markdown", // html | markdown | plaintext | pdf
  },
});

const job = await client.submitRegular({
  urls: [
    { url: "https://www.scrapingcourse.com/ecommerce/product/artemis-running-short",
      externalId: "order-42", zenrowsParams: { proxy_country: "de" } },
    { url: "https://www.scrapingcourse.com/ecommerce/product/atomic-endurance-tee",
      externalId: "order-43", metadata: { sku: "ABC-1" } },
  ],
  zenrowsParams: { js_render: "true" },
});

// One file per task, client-side, tune parallelism:
await client.job(jobId).run.downloadToDir("./out", { concurrency: 8 });

// The whole run as one server-side zip:
await client.job(jobId).run.downloadAllResults("results.zip");

// A single task's body, to disk or memory, inside a loop:
for await (const row of run.results({ status: "successful" })) {
  await run.downloadTaskToDir(row, "./out");
  // or: const { body } = await run.downloadTaskToMemory(row);
}

const job = await client.submitOpen({ zenrowsParams: { js_render: "true" } });

await job.addTasks({ tasks: [{ url: "https://www.scrapingcourse.com/ecommerce/page/1" }] });
await job.addTasks({ tasks: [{ url: "https://www.scrapingcourse.com/ecommerce/page/2" }], lastBatch: true });

const run = await job.run.wait();

const fileInputId = await client.uploadCsv("urls.csv", {
  fields: { url: "URL", externalId: "Customer Ref" }, // column name (header: true) or 0-based index
  header: true,
});
const job = await client.submitRegular({ fileInputId, zenrowsParams: { js_render: "true" } });

for await (const job of client.iterJobs({ jobType: "regular", status: "closed" })) {
  console.log(job.jobId, job.data.status);
}

for await (const run of client.iterRuns("01J...", { pageSize: 50 })) {
  console.log(run.runId, run.data.status);
}

for await (const row of client.iterResults("01J...", { status: "failed" })) {
  console.log(row.taskId, row.error?.code);
}

// Re-run every task:
const full = await client.job(jobId).rerun();

// Re-run only the failures (pass { includePending: true } to also pick up tasks that never started).
// Successful results carry over, so you don't pay to re-scrape them:
const run = await client.job(jobId).retryFailed();
await run.wait();

const job = await client.submitScheduled({
  schedule: { every: "6h" },
  urls: ["https://www.scrapingcourse.com/ecommerce/"],
});

await job.schedule.pause();  // stop firing new runs
await job.schedule.resume();
await job.schedule.update({ times: ["09:00"], days: ["mon", "fri"], tz: "Europe/Berlin" });

await job.run.pause();       // reversibly suspend the current run (a different endpoint)
await job.run.resume();
await job.run.stop();        // end the current run

const job = await client.submitRegular({
  urls: ["https://www.scrapingcourse.com/ecommerce/"],
  webhook: { url: "https://your-app.com/webhooks/zenrows", signature: true },
});

await client.job(jobId).run.downloadAllResults("results.zip");

const est = await client.estimateCost({
  type: "regular",
  tasks: [{ url: "https://a" }, { url: "https://b" }],
  zenrowsParams: { js_render: "true" },
});
console.log(String(est)); // "10 credits (2 tasks)"
console.log(est.format()); // per-tier breakdown table

const run = await client.job(jobId).run.wait();
const spend = run.data.stats.spend;
if (spend) console.log(`this run used ${spend.credits} usage (cost ${spend.cost})`);

const created = await client.rotateHmacKey(); // the first call creates the active key
console.log(created.kid, created.secret);     // the secret is returned ONCE, so store it now

// Phased rotation:
await client.rotateHmacKey();       // stage a candidate (start accepting both)
await client.finalizeHmacKey();     // promote the candidate to active, retire the old one
// await client.cancelHmacRotation(); // or discard the candidate
await client.listHmacKeys();        // metadata only; never returns secrets

import { BatchApiError } from "zenrows/batch";

try {
  await client.getJob("does-not-exist");
} catch (err) {
  if (err instanceof BatchApiError && err.code === "not_found") {
    // ...
  } else {
    throw err;
  }
}

const client = new ZenRowsBatchClient("YOUR_ZENROWS_API_KEY", {
  timeout: 30_000, // per-request, ms
  retries: 3,      // 0 disables
});

const job = await client.submitRegular({
  urls: ["https://www.scrapingcourse.com/ecommerce/"],
  idempotencyKey: "nightly-2026-06-08",
});