JavaScript 客户端库

npm install bazhuayu-client

import { Client } from "bazhuayu-client";

const client = new Client({ apiKey: "<你的 API Key>" });

import { Client, ApiError, RunFailed } from "bazhuayu-client";

const client = new Client({ apiKey: "<你的 API Key>" });

// 发现
const { items } = await client.search("reviews", { limit: 5 });
for (const card of items) console.log(card.app_id, card.namespace, card.app_name);
const detail = await client.getApp("carol/reviews-query");

// 运行并消费。时间参数一律毫秒；超时抛 TimeoutError 但不取消服务端运行
const run = await client.call("carol/reviews-query", { product: "p-9001" }, {
  maxRecords: 100, timeout: 120_000, raiseOnFailure: true,
});
for await (const record of client.iterateRecords(run.run_id)) {
  console.log(record);
}

// 非阻塞：先发起，再自己轮询
const started = await client.run("carol/reviews-query", { product: "p-9002" }, { wait: 0 });
const polled = await client.getRun(started.run_id, { wait: 60 });

// 对账
console.log(await client.billing({ groupBy: "data_app", tzOffset: 480 }));
for await (const r of client.iterateRuns({ createdFrom: "2026-09-01T00:00:00+08:00" })) {
  console.log(r.run_id, r.state, r.billing.total);
}

// 结果默认保留 90 天，需要长期保留的数据集打标记
await client.setDatasetRetention(run.dataset_id, true);

import { ApiError } from "bazhuayu-client";

try {
  await client.run("carol/reviews-query", {});
} catch (e) {
  if (e instanceof ApiError && e.code === "invalid-input") {
    for (const d of e.details ?? []) console.log(d.path, d.message);
  } else if (e instanceof ApiError && e.retryable) {
    // 退避后重试
  } else {
    throw e;
  }
}