Pagination

const API = process.env.RETRIEVER_API_URL;
const HEADERS = { Authorization: `Bearer ${process.env.RETRIEVER_API_KEY}` };

async function* rows(tableId) {
  let cursor = null;
  do {
    const qs = new URLSearchParams({ limit: "1000", ...(cursor ? { cursor } : {}) });
    const res = await fetch(`${API}/v1/tables/${tableId}/rows?${qs}`, { headers: HEADERS });
    const page = await res.json();
    if (!res.ok) throw new Error(`${res.status} ${page.error.code}`);
    yield* page.items;
    cursor = page.next_cursor;
  } while (cursor);
}

for await (const row of rows("tbl_001")) console.log(row.values);

import os, requests

API = os.environ["RETRIEVER_API_URL"]
HEADERS = {"Authorization": f"Bearer {os.environ['RETRIEVER_API_KEY']}"}

def rows(table_id):
    cursor = None
    while True:
        params = {"limit": 1000, **({"cursor": cursor} if cursor else {})}
        res = requests.get(f"{API}/v1/tables/{table_id}/rows", headers=HEADERS, params=params, timeout=30)
        res.raise_for_status()
        page = res.json()
        yield from page["items"]
        cursor = page["next_cursor"]
        if not cursor:
            break

for row in rows("tbl_001"):
    print(row["values"])

curl "$RETRIEVER_API_URL/v1/tables/tbl_001/rows?limit=100" -H "Authorization: Bearer $RETRIEVER_API_KEY"
# page suivante : reprendre next_cursor
curl "$RETRIEVER_API_URL/v1/tables/tbl_001/rows?limit=100&cursor=eyJ0YWJsZUlkIjoi..." -H "Authorization: Bearer $RETRIEVER_API_KEY"