异步任务与结果

export REQUEST_KEY="$(uuidgen)"

# 1. 提交任务，返回 202 与结果信封
curl https://api.tokentosea.com/v1/videos \
  -H "Authorization: Bearer $TOKENTOSEA_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: $REQUEST_KEY" \
  -d '{
    "model": "cogvideox-3",
    "prompt": "A red cube slowly rotates on a white table. Steady camera.",
    "duration": 5,
    "quality": "speed",
    "size": "1280x720",
    "fps": 30,
    "with_audio": false
  }'

# 2. 每 5–10 秒查询一次，直到 status 为 succeeded / failed / needs_review
curl "https://api.tokentosea.com/v1/results/$REQUEST_KEY" \
  -H "Authorization: Bearer $TOKENTOSEA_API_KEY"

# 3. 用 output.data[0].url 下载（链接最长 300 秒有效）
curl -L -o video.mp4 "粘贴 output.data[0].url"

import os
import time
import uuid

import requests

API = "https://api.tokentosea.com/v1"
AUTH = {"Authorization": f"Bearer {os.environ['TOKENTOSEA_API_KEY']}"}
key = str(uuid.uuid4())

submit = requests.post(
    f"{API}/videos",
    headers={**AUTH, "Idempotency-Key": key},
    json={
        "model": "cogvideox-3",
        "prompt": "A red cube slowly rotates on a white table. Steady camera.",
        "duration": 5,
        "quality": "speed",
        "size": "1280x720",
        "fps": 30,
        "with_audio": False,
    },
    timeout=120,
)
if submit.status_code not in (200, 202):
    raise SystemExit(f"提交失败：{submit.status_code} {submit.text}")
print("已受理：", submit.json().get("id"), "幂等键：", key)

deadline = time.time() + 30 * 60
while True:
    envelope = requests.get(f"{API}/results/{key}", headers=AUTH, timeout=30).json()
    status = envelope.get("status")
    if status == "succeeded":
        break
    if status in ("failed", "needs_review"):
        raise SystemExit(f"任务结束：{status} {envelope.get('error')} run_id={envelope.get('run_id')}")
    if time.time() > deadline:
        raise SystemExit(f"仍在处理，稍后用同一幂等键继续查询：{key}")
    time.sleep(8)

for index, item in enumerate(envelope["output"]["data"]):
    file = requests.get(item["url"], timeout=300)
    if file.status_code == 403:  # 签名已过期：重新获取下载链接
        fresh = requests.get(f"{API}/assets/{item['asset_id']}/download-url", headers=AUTH, timeout=30).json()
        file = requests.get(fresh["url"], timeout=300)
    file.raise_for_status()
    name = f"video-{index}.mp4"
    with open(name, "wb") as output:
        output.write(file.content)
    print("已保存", name, item["mime_type"], item["asset_id"])

import { randomUUID } from 'node:crypto';
import { writeFile } from 'node:fs/promises';

const API = 'https://api.tokentosea.com/v1';
const AUTH = { Authorization: `Bearer ${process.env.TOKENTOSEA_API_KEY}` };
const key = randomUUID();
const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

const submit = await fetch(`${API}/videos`, {
  method: 'POST',
  headers: { ...AUTH, 'Content-Type': 'application/json', 'Idempotency-Key': key },
  body: JSON.stringify({
    model: 'cogvideox-3',
    prompt: 'A red cube slowly rotates on a white table. Steady camera.',
    duration: 5,
    quality: 'speed',
    size: '1280x720',
    fps: 30,
    with_audio: false,
  }),
});
if (![200, 202].includes(submit.status)) throw new Error(`提交失败：${submit.status} ${await submit.text()}`);
console.log('已受理：', (await submit.json()).id, '幂等键：', key);

const deadline = Date.now() + 30 * 60_000;
let envelope;
for (;;) {
  envelope = await (await fetch(`${API}/results/${key}`, { headers: AUTH })).json();
  if (envelope.status === 'succeeded') break;
  if (['failed', 'needs_review'].includes(envelope.status)) {
    throw new Error(`任务结束：${envelope.status} ${envelope.error?.code ?? ''} run_id=${envelope.run_id}`);
  }
  if (Date.now() > deadline) throw new Error(`仍在处理，稍后用同一幂等键继续查询：${key}`);
  await sleep(8_000);
}

for (const [index, item] of envelope.output.data.entries()) {
  let file = await fetch(item.url);
  if (file.status === 403) {
    // 签名已过期：重新获取下载链接
    const fresh = await (await fetch(`${API}/assets/${item.asset_id}/download-url`, { headers: AUTH })).json();
    file = await fetch(fresh.url);
  }
  if (!file.ok) throw new Error(`下载失败：HTTP ${file.status}`);
  const name = `video-${index}.mp4`;
  await writeFile(name, Buffer.from(await file.arrayBuffer()));
  console.log('已保存', name, item.mime_type, item.asset_id);
}