Szybki start z Veo 3 API: generowanie filmów z CometAPI

curl https://api.cometapi.com/v1/videos \
  -H "Authorization: Bearer $COMETAPI_KEY" \
  -F model=veo3.1-fast \
  -F "prompt=A paper kite floats above a field." \
  -F seconds=4 \
  -F size=1280x720

curl "https://api.cometapi.com/v1/videos/<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}"}

create_response = requests.post(
    "https://api.cometapi.com/v1/videos",
    headers=headers,
    files={
        "model": (None, "veo3.1-fast"),
        "prompt": (None, "A paper kite floats above a field."),
        "seconds": (None, "4"),
        "size": (None, "1280x720"),
    },
    timeout=60,
)
create_response.raise_for_status()
task_id = create_response.json()["id"]

for _ in range(60):
    retrieve_response = requests.get(
        f"https://api.cometapi.com/v1/videos/{task_id}",
        headers=headers,
        timeout=30,
    )
    retrieve_response.raise_for_status()
    task = retrieve_response.json()
    if task["status"] in {"completed", "failed", "error"}:
        print(task)
        break
    time.sleep(5)
else:
    raise TimeoutError("Veo task did not finish in time")

const form = new FormData();
form.append("model", "veo3.1-fast");
form.append("prompt", "A paper kite floats above a field.");
form.append("seconds", "4");
form.append("size", "1280x720");

const createResponse = await fetch("https://api.cometapi.com/v1/videos", {
  method: "POST",
  headers: { Authorization: `Bearer ${process.env.COMETAPI_KEY}` },
  body: form,
});

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

const { id } = await createResponse.json();

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

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

  const task = await retrieveResponse.json();
  if (["completed", "failed", "error"].includes(task.status)) {
    console.log(task);
    break;
  }
  await new Promise((resolve) => setTimeout(resolve, 5000));
}