veo-3.1-fast

import json
import os
import time
from urllib.request import Request, urlopen
from urllib.parse import quote

BASE = "https://tommyapi.com/v1"
KEY = os.environ["TOMMYAPI_KEY"]

def request(path, payload=None):
    data = json.dumps(payload).encode() if payload is not None else None
    req = Request(BASE + path, data=data, headers={
        "Authorization": "Bearer " + KEY,
        "Content-Type": "application/json",
    })
    with urlopen(req, timeout=150) as response:
        return json.load(response)

# 只提交一次；保存 task_id，查询中断后继续查这个任务。
task = request("/video/generations", {
    "model": "veo-3.1-fast",
    "prompt": "霓虹城市夜景，镜头缓慢向前推进",
    "duration": 4,
})
task_id = task["task_id"]
print("task_id:", task_id, flush=True)
for _ in range(120):
    time.sleep(5)
    task = request("/videos/" + quote(task_id, safe=""))
    if task["status"] == "succeeded":
        print(task["video_url"])
        break
    if task["status"] == "failed":
        raise RuntimeError(task.get("fail_reason") or "视频生成失败")
else:
    raise TimeoutError("查询超时；保存 task_id 继续查询，不要重复提交：" + task_id)

# 在环境变量 TOMMYAPI_KEY 中设置 API Key。此请求会创建一个计费任务。
curl --fail-with-body https://tommyapi.com/v1/video/generations \
  -H "Authorization: Bearer $TOMMYAPI_KEY" \
  -H "Content-Type: application/json" \
  -d '{"model":"veo-3.1-fast","prompt":"霓虹城市夜景，镜头缓慢向前推进","duration":4}'

# 保存返回的 task_id，用实际值替换 TASK_ID；每隔 5 秒查询这个任务。
curl --fail-with-body https://tommyapi.com/v1/videos/TASK_ID \
  -H "Authorization: Bearer $TOMMYAPI_KEY"

# status=succeeded 时读取 video_url；status=failed 时读取 fail_reason。
# 查询超时后继续查询同一 task_id，不要重复提交生成请求。

const BASE = "https://tommyapi.com/v1";
const KEY = process.env.TOMMYAPI_KEY;
if (!KEY) throw new Error("请设置 TOMMYAPI_KEY");

async function request(path, payload) {
  const response = await fetch(BASE + path, {
    method: payload ? "POST" : "GET",
    headers: { Authorization: `Bearer ${KEY}`, "Content-Type": "application/json" },
    body: payload ? JSON.stringify(payload) : undefined,
    signal: AbortSignal.timeout(150000),
  });
  const body = await response.json();
  if (!response.ok) throw new Error(JSON.stringify(body));
  return body;
}

// 只提交一次；保存 task_id，查询中断后继续查这个任务。
const created = await request("/video/generations", {
  model: "veo-3.1-fast",
  prompt: "霓虹城市夜景，镜头缓慢向前推进",
  duration: 4,
});
const taskId = created.task_id;
console.log("task_id:", taskId);
let completed = false;
for (let attempt = 0; attempt < 120; attempt++) {
  await new Promise(resolve => setTimeout(resolve, 5000));
  const task = await request("/videos/" + encodeURIComponent(taskId));
  if (task.status === "succeeded") {
    console.log(task.video_url);
    completed = true;
    break;
  }
  if (task.status === "failed") throw new Error(task.fail_reason || "视频生成失败");
}
if (!completed) throw new Error("查询超时；继续查询这个 task_id，不要重复提交：" + taskId);