PHP 示例

下面示例覆盖认证检查、启动 Worker、用返回的 run_slug 查询结果三步。

示例中的 YOUR_WORKER_ID 是占位符。请替换为要运行的 Worker slug，或把 owner/name 路径写成 owner~name。input 必须按该 Worker 的输入 schema 构造；不同 Worker 的字段不一定相同。

默认使用 is_async: true 异步提交并轮询结果。如需等待执行完成，把 is_async 改为 false，并用 offset / limit 控制同步返回的数据窗口。

<?php
$apiBaseUrl = "https://openapi.coreclaw.com";
$apiKey = getenv("CORECLAW_API_KEY");
$workerId = getenv("CORECLAW_WORKER_ID") ?: "YOUR_WORKER_ID";

if (!$apiKey) {
    throw new RuntimeException("Set CORECLAW_API_KEY first.");
}

function coreclaw_request(string $method, string $path, ?array $query = null, ?array $body = null): array
{
    global $apiBaseUrl, $apiKey;

    $url = $apiBaseUrl . $path;
    if ($query) {
        $url .= "?" . http_build_query($query);
    }

    $headers = ["Authorization: Bearer " . $apiKey];
    $options = [
        CURLOPT_CUSTOMREQUEST => $method,
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_HTTPHEADER => $headers,
    ];

    if ($body !== null) {
        $headers[] = "Content-Type: application/json";
        $options[CURLOPT_HTTPHEADER] = $headers;
        $options[CURLOPT_POSTFIELDS] = json_encode($body, JSON_UNESCAPED_SLASHES);
    }

    $ch = curl_init($url);
    curl_setopt_array($ch, $options);
    $raw = curl_exec($ch);
    $status = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
    curl_close($ch);

    if ($raw === false || $status < 200 || $status >= 300) {
        throw new RuntimeException("HTTP " . $status . ": " . $raw);
    }

    $payload = json_decode($raw, true);
    if (($payload["code"] ?? null) !== 0) {
        throw new RuntimeException($raw);
    }
    return $payload;
}

function wait_for_run(string $runId, int $timeoutSeconds = 300): array
{
    $deadline = microtime(true) + $timeoutSeconds;
    $delaySeconds = 2;
    while (microtime(true) < $deadline) {
        $detail = coreclaw_request("GET", "/api/v2/worker-runs/" . rawurlencode($runId));
        $runData = $detail["data"];
        $status = $runData["status"] ?? null;
        if ($status === "succeeded") {
            return $runData;
        }
        if (in_array($status, ["failed", "aborting"], true)) {
            $logs = coreclaw_request("GET", "/api/v2/worker-runs/" . rawurlencode($runId) . "/log");
            throw new RuntimeException(json_encode([
                "status" => $status,
                "err_msg" => $runData["err_msg"] ?? null,
                "request_id" => $detail["request_id"] ?? null,
                "logs" => $logs["data"] ?? null,
            ]));
        }
        if (!in_array($status, ["ready", "running"], true)) {
            throw new RuntimeException("Unexpected run status: " . $status);
        }
        sleep($delaySeconds);
        $delaySeconds = min($delaySeconds * 2, 15);
    }
    throw new RuntimeException("Timed out waiting for run " . $runId);
}

$account = coreclaw_request("GET", "/api/v2/users/account");
print_r($account["data"]);

$run = coreclaw_request("POST", "/api/v2/workers/" . rawurlencode($workerId) . "/runs", null, [
    // Replace input.parameters.custom with fields from the Worker's input schema.
    "input" => [
        "parameters" => [
            "custom" => [
                "keywords" => ["coffee"],
                "base_location" => "New York,USA",
                "max_results" => 1,
            ],
        ],
    ],
    "is_async" => true,
    "offset" => 1,
    "limit" => 20,
]);
$runId = $run["data"]["run_slug"];
echo "Run ID: " . $runId . PHP_EOL;

$completedRun = wait_for_run($runId);

$results = coreclaw_request("GET", "/api/v2/worker-runs/" . rawurlencode($runId) . "/result", [
    "offset" => 1,
    "limit" => 20,
]);
print_r(["status" => $completedRun["status"], "results" => $results["data"]]);