How to Scrape Google Maps Reviews: Get Every Review of a Business, Not Just 5

step1-find-business.mjs

const API_KEY = "YOUR_API_KEY";
const BASE = "https://api.openwebninja.com/local-business-data";

const res = await fetch(
  `${BASE}/search?` + new URLSearchParams({ query: "Russ & Daughters Cafe, New York", limit: 1 }),
  { headers: { "x-api-key": API_KEY } }
);
const { data } = await res.json();
const { name, address, business_id, place_id, rating, review_count } = data[0];
console.log({ name, address, business_id, place_id, rating, review_count });

output

{
  name: 'Russ & Daughters Cafe',
  address: '127 Orchard St, New York, NY 10002',
  business_id: '0x89c25986daaa7ce7:0x7a4f998a3fd281a8',
  place_id: 'ChIJ53yq2oZZwokRqIHSP4qZT3o',
  rating: 4.6,
  review_count: 3731
}

from reviews-to-csv.mjs

// Step 3: follow the cursor until there is none
const reviews = [];
let cursor, calls = 0;
try {
  do {
    const params = { business_id: businessId, limit: 100, sort_by: "newest" };
    if (cursor) params.cursor = cursor;
    const page = await get("/business-reviews-v2", params);
    reviews.push(...page.reviews);
    cursor = page.cursor;
    calls++;
  } while (cursor);

reviews-to-csv.mjs

// reviews-to-csv.mjs: every Google Maps review of a business, saved to CSV.
// Setup: npm install csv
// Run: node reviews-to-csv.mjs "Russ & Daughters Cafe, New York"
//  or: node reviews-to-csv.mjs <place_id, business_id or Google Maps place link>
import { writeFileSync } from "node:fs";
import { createInterface } from "node:readline/promises";
import { stringify } from "csv/sync";

const API_KEY = "YOUR_API_KEY";
const BASE = "https://api.openwebninja.com/local-business-data";

async function get(path, params) {
  const res = await fetch(`${BASE}${path}?${new URLSearchParams(params)}`, {
    headers: { "x-api-key": API_KEY },
  });
  if (!res.ok) throw new Error(`${res.status}: ${await res.text()}`);
  return (await res.json()).data;
}

// Step 1: use the ID you already have, or search by name and confirm the match
const input = process.argv[2];
let businessId = input.match(/0x[0-9a-f]+:0x[0-9a-f]+/i)?.[0] ?? (/^[\w-]{20,}$/.test(input) ? input : null);
if (!businessId) {
  const [b] = await get("/search", { query: input, limit: 1 });
  console.log(`${b.name}, ${b.address}: ${b.review_count} reviews`);
  const rl = createInterface({ input: process.stdin, output: process.stdout });
  const answer = await rl.question("Pull every review of this business? (y/n) ");
  rl.close();
  if (answer.trim().toLowerCase() !== "y") process.exit(0);
  businessId = b.business_id;
}

// Step 3: follow the cursor until there is none
const reviews = [];
let cursor, calls = 0;
try {
  do {
    const params = { business_id: businessId, limit: 100, sort_by: "newest" };
    if (cursor) params.cursor = cursor;
    const page = await get("/business-reviews-v2", params);
    reviews.push(...page.reviews);
    cursor = page.cursor;
    calls++;
  } while (cursor);
} finally {
  // Step 4: save what we have, even if a call failed partway (for example, out of credits)
  const columns = ["review_datetime_utc", "rating", "review_text", "owner_response_text", "author_name", "review_link"];
  writeFileSync("reviews.csv", stringify(reviews, { header: true, columns }));
  // Remember the newest review so new-reviews.mjs only fetches what comes after it
  const newest = reviews.find((r) => r.review_timestamp)?.review_timestamp;
  if (newest) writeFileSync("last-run.json", JSON.stringify({ newest }));
  console.log(`Saved ${reviews.length} reviews to reviews.csv in ${calls} calls`);
}

output

Russ & Daughters Cafe, 127 Orchard St, New York, NY 10002: 3731 reviews
Pull every review of this business? (y/n) y
Saved 3731 reviews to reviews.csv in 38 calls

output

Saved 3731 reviews to reviews.csv in 38 calls

new-reviews.mjs

// new-reviews.mjs: only the reviews posted since the last run.
import { existsSync, readFileSync, writeFileSync } from "node:fs";

const API_KEY = "YOUR_API_KEY";
const BASE = "https://api.openwebninja.com/local-business-data";
const BUSINESS_ID = "0x89c25986daaa7ce7:0x7a4f998a3fd281a8"; // Russ & Daughters Cafe
const STATE = "last-run.json";

const since = existsSync(STATE) ? JSON.parse(readFileSync(STATE, "utf8")).newest : 0;
const fresh = [];
let cursor, calls = 0, done = false;
while (!done) {
  const params = { business_id: BUSINESS_ID, limit: 100, sort_by: "newest" };
  if (cursor) params.cursor = cursor;
  const res = await fetch(`${BASE}/business-reviews-v2?${new URLSearchParams(params)}`, {
    headers: { "x-api-key": API_KEY },
  });
  const { data } = await res.json();
  calls++;
  for (const r of data.reviews) {
    if (r.review_timestamp && r.review_timestamp <= since) { done = true; break; }
    fresh.push(r);
  }
  cursor = data.cursor;
  if (!cursor) done = true;
}

const newest = fresh.find((r) => r.review_timestamp)?.review_timestamp;
if (newest) writeFileSync(STATE, JSON.stringify({ newest }));
writeFileSync("new-reviews.json", JSON.stringify(fresh, null, 2));
console.log(`${fresh.length} new reviews in ${calls} call(s)`);

output

0 new reviews in 1 call(s)

retry.mjs

const API_KEY = "YOUR_API_KEY";
const BASE = "https://api.openwebninja.com/local-business-data";

// Retry 429 and 5xx with backoff (2 s, 4 s, 8 s). Fail fast on other errors.
async function get(path, params, tries = 4) {
  for (let attempt = 1; ; attempt++) {
    const res = await fetch(`${BASE}${path}?${new URLSearchParams(params)}`, {
      headers: { "x-api-key": API_KEY },
    });
    if (res.ok) return (await res.json()).data;
    const retryable = res.status === 429 || res.status >= 500;
    if (!retryable || attempt === tries) throw new Error(`${res.status}: ${await res.text()}`);
    await new Promise((r) => setTimeout(r, 1000 * 2 ** attempt));
  }
}

const page = await get("/business-reviews-v2", { business_id: "0x89c25986daaa7ce7:0x7a4f998a3fd281a8", limit: 5 });
console.log("ok:", page.reviews.length, "reviews");

output

ok: 5 reviews