异步任务

curl https://vibetoken.cn/v1/videos/generations/f47ac10b-58cc-4372-a567-0e02b2c3d479 \
  -H "Authorization: Bearer sk-rb-xxxxxxxxxxxx"

import time, requests

def wait_for_video(gen_id, api_key, interval=3, timeout=600):
    headers = {"Authorization": f"Bearer {api_key}"}
    url = f"https://vibetoken.cn/v1/videos/generations/{gen_id}"
    elapsed = 0
    while elapsed < timeout:
        s = requests.get(url, headers=headers).json()
        if s["status"] == "success":
            return s["data"][0]["url"]
        if s["status"] == "failed":
            raise RuntimeError("Generation failed")
        time.sleep(interval)
        elapsed += interval
    raise TimeoutError("Generation timed out")

async function waitForVideo(genId, apiKey, { interval = 3000, timeout = 600000 } = {}) {
  const url = `https://vibetoken.cn/v1/videos/generations/${genId}`;
  const start = Date.now();
  while (Date.now() - start < timeout) {
    const r = await fetch(url, { headers: { Authorization: `Bearer ${apiKey}` } });
    const s = await r.json();
    if (s.status === "success") return s.data[0].url;
    if (s.status === "failed") throw new Error("Generation failed");
    await new Promise((r) => setTimeout(r, interval));
  }
  throw new Error("Generation timed out");
}