Kling API クイックスタート: CometAPI で動画を生成する

curl https://api.cometapi.com/kling/v1/videos/text2video \
  -H "Authorization: Bearer $COMETAPI_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "prompt": "A small ceramic cup on a wooden table, steam rising in soft morning light",
    "model_name": "kling-v3",
    "mode": "std",
    "duration": "5",
    "sound": "off"
  }'

curl "https://api.cometapi.com/kling/v1/videos/text2video/<task_id>" \
  -H "Authorization: Bearer $COMETAPI_KEY"

import os
import time

import requests

api_key = os.environ["COMETAPI_KEY"]
headers = {
    "Authorization": f"Bearer {api_key}",
    "Content-Type": "application/json",
}

create_response = requests.post(
    "https://api.cometapi.com/kling/v1/videos/text2video",
    headers=headers,
    json={
        "prompt": "A small ceramic cup on a wooden table, steam rising in soft morning light",
        "model_name": "kling-v3",
        "mode": "std",
        "duration": "5",
        "sound": "off",
    },
    timeout=60,
)
create_response.raise_for_status()
task_id = create_response.json()["data"]["task_id"]

for _ in range(60):
    task_response = requests.get(
        f"https://api.cometapi.com/kling/v1/videos/text2video/{task_id}",
        headers={"Authorization": f"Bearer {api_key}"},
        timeout=30,
    )
    task_response.raise_for_status()
    task = task_response.json()["data"]
    if task["task_status"] in {"succeed", "failed"}:
        print(task)
        break
    time.sleep(5)
else:
    raise TimeoutError("Kling task did not finish in time")

const createResponse = await fetch(
  "https://api.cometapi.com/kling/v1/videos/text2video",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.COMETAPI_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      prompt: "A small ceramic cup on a wooden table, steam rising in soft morning light",
      model_name: "kling-v3",
      mode: "std",
      duration: "5",
      sound: "off",
    }),
  },
);

if (!createResponse.ok) {
  throw new Error(await createResponse.text());
}

const created = await createResponse.json();
const taskId = created.data.task_id;

for (let attempt = 0; attempt < 60; attempt += 1) {
  const taskResponse = await fetch(
    `https://api.cometapi.com/kling/v1/videos/text2video/${taskId}`,
    { headers: { Authorization: `Bearer ${process.env.COMETAPI_KEY}` } },
  );

  if (!taskResponse.ok) {
    throw new Error(await taskResponse.text());
  }

  const task = (await taskResponse.json()).data;
  if (["succeed", "failed"].includes(task.task_status)) {
    console.log(task);
    break;
  }
  await new Promise((resolve) => setTimeout(resolve, 5000));
}