Python 客户端库

pip install bazhuayu-client

from bazhuayu_client import Client

client = Client(api_key="<你的 API Key>")

from bazhuayu_client import Client, ApiError, RunFailed

with Client(api_key="<你的 API Key>") as client:
    # 发现
    for card in client.search("reviews", limit=5)["items"]:
        print(card["app_id"], card["namespace"], card["app_name"])
    detail = client.get_app("carol/reviews-query")

    # 运行并消费
    run = client.call("carol/reviews-query", {"product": "p-9001"}, max_records=100)
    for record in client.iterate_records(run["run_id"]):
        print(record)

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

    # 对账
    print(client.billing(group_by="data_app", tz_offset=480))
    for r in client.iterate_runs(created_from="2026-09-01T00:00:00+08:00"):
        print(r["run_id"], r["state"], r["billing"]["total"])

    # 结果默认保留 90 天，需要长期保留的数据集打标记
    client.set_dataset_retention(run["dataset_id"], retained=True)

from bazhuayu_client import ApiError

try:
    client.run("carol/reviews-query", {})
except ApiError as e:
    if e.code == "invalid-input":
        for d in e.details or []:
            print(d["path"], d["message"])
    elif e.retryable:
        ...  # 退避后重试
    else:
        raise