同步与异步任务模式

import { setTimeout } from "node:timers/promises";

const apiKey = process.env.AIBASE_API_KEY || "AIBase_xxxxxxxxxxxxxxxx";
const headers = {
  "AIBase-API-Key": apiKey,
  "Content-Type": "application/json",
};

// 1. 提交异步任务
const submitRes = await fetch("https://api.aibase.cn/v1/openapi/tasks", {
  method: "POST",
  headers,
  body: JSON.stringify({
    apiCode: "geo.ranking",
    data: {
      keyword: "性价比高的智能手机推荐",
      brandKeyword: ["小米", "华为"],
      platforms: ["deepseek", "baidu"],
    },
  }),
});
const submitData = await submitRes.json();
if (submitData.code !== 200) {
  throw new Error(`提交失败: ${JSON.stringify(submitData)}`);
}

const taskId = submitData.data.taskId;
console.log("任务已创建，taskId:", taskId);

// 2. 轮询状态（间隔 10 秒）
const maxRetries = 30;
for (let i = 0; i < maxRetries; i++) {
  await setTimeout(10000);
  const queryRes = await fetch(`https://api.aibase.cn/v1/openapi/tasks/${taskId}`, {
    headers,
  });
  const queryData = await queryRes.json();
  const status = queryData.data?.status;

  if (status === 2) {
    console.log("任务成功！结果:", queryData.data.result);
    break;
  } else if (status === 1) {
    console.log(`[${i + 1}/${maxRetries}] 任务处理中，继续等待...`);
  } else {
    throw new Error(`任务失败或终止，status: ${status}`);
  }
}

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.time.Duration;

public class AIBaseAsyncDemo {
    public static void main(String[] args) throws Exception {
        String apiKey = System.getenv().getOrDefault("AIBASE_API_KEY", "AIBase_xxxxxxxxxxxxxxxx");
        HttpClient client = HttpClient.newHttpClient();

        // 1. 提交任务
        String submitJson = """
            {
              "apiCode": "geo.ranking",
              "data": {
                "keyword": "性价比高的智能手机推荐",
                "brandKeyword": ["小米", "华为"],
                "platforms": ["deepseek", "baidu"]
              }
            }
            """;
        HttpRequest submitReq = HttpRequest.newBuilder()
            .uri(URI.create("https://api.aibase.cn/v1/openapi/tasks"))
            .header("AIBase-API-Key", apiKey)
            .header("Content-Type", "application/json")
            .POST(HttpRequest.BodyPublishers.ofString(submitJson))
            .build();

        HttpResponse<String> submitResp = client.send(submitReq, HttpResponse.BodyHandlers.ofString());
        // 需引入 JSON 库解析返回的 taskId，此处以变量伪代码示意
        String taskId = "task_d77143abc87642d4842ff588197faa89"; 

        // 2. 轮询查询（间隔 10 秒）
        for (int i = 0; i < 30; i++) {
            Thread.sleep(10000);
            HttpRequest queryReq = HttpRequest.newBuilder()
                .uri(URI.create("https://api.aibase.cn/v1/openapi/tasks/" + taskId))
                .header("AIBase-API-Key", apiKey)
                .GET()
                .build();
            HttpResponse<String> queryResp = client.send(queryReq, HttpResponse.BodyHandlers.ofString());
            // 判断返回体中的 status：
            // status == 2 -> 获取 data.result，跳出循环
            // status == 1 -> 继续等待
            // status >= 3 -> 异常终止
        }
    }
}

# 1. 提交任务获取 taskId
curl --location 'https://api.aibase.cn/v1/openapi/tasks' \
  --header 'AIBase-API-Key: AIBase_xxxxxxxxxxxxxxxx' \
  --header 'Content-Type: application/json' \
  --data '{
    "apiCode": "geo.ranking",
    "data": {
      "keyword": "性价比高的智能手机推荐",
      "brandKeyword": ["小米", "华为"],
      "platforms": ["deepseek", "baidu"]
    }
  }'

# 2. 间隔 10 秒轮询查询
curl --location 'https://api.aibase.cn/v1/openapi/tasks/task_d77143abc87642d4842ff588197faa89' \
  --header 'AIBase-API-Key: AIBase_xxxxxxxxxxxxxxxx'