视频生成

# 1. 提交。记下返回的 id
curl "https://token.echohub.io/v1/videos" \
  -H "Authorization: Bearer $ECHO_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "model": "MiniMax-H3",
    "prompt": "夕方の海辺を、柴犬がゆっくり歩いている",
    "seconds": 6,
    "resolution": "768P"
  }'

# 2. 查询进度。VIDEO_ID 填第 1 步返回的 id
VIDEO_ID="task_..."
curl "https://token.echohub.io/v1/videos/$VIDEO_ID" \
  -H "Authorization: Bearer $ECHO_API_KEY"

# 3. status 变成 completed 后，获取文件
curl -o video.mp4 "https://token.echohub.io/v1/videos/$VIDEO_ID/content" \
  -H "Authorization: Bearer $ECHO_API_KEY"

# 创建并启用虚拟环境
python3 -m venv .venv && source .venv/bin/activate
pip install requests

import os
import time

import requests

BASE = "https://token.echohub.io/v1"
HEADERS = {"Authorization": f"Bearer {os.environ['ECHO_API_KEY']}"}


def check(res):
    # 出错时显示 HTTP 状态码和错误正文，然后结束
    if not res.ok:
        raise SystemExit(f"HTTP {res.status_code}: {res.text}")
    return res


# 1. 提交
video = check(requests.post(f"{BASE}/videos", headers=HEADERS, json={
    "model": "MiniMax-H3",
    "prompt": "夕方の海辺を、柴犬がゆっくり歩いている",
    "seconds": 6,
    "resolution": "768P",
})).json()
print("已提交:", video["id"])

# 2. 每 15 秒查询一次进度，直到完成或失败
while video["status"] in ("queued", "in_progress"):
    time.sleep(15)
    video = check(requests.get(f"{BASE}/videos/{video['id']}", headers=HEADERS)).json()
    print(video["status"], video["progress"])

if video["status"] != "completed":
    raise SystemExit(f"生成失败: {video.get('error')}")

# 3. 获取文件
res = check(requests.get(f"{BASE}/videos/{video['id']}/content", headers=HEADERS))
with open("video.mp4", "wb") as f:
    f.write(res.content)
print("已保存到 video.mp4")

import { writeFile } from "node:fs/promises";

const BASE = "https://token.echohub.io/v1";
const auth = { Authorization: `Bearer ${process.env.ECHO_API_KEY}` };

// 出错时显示 HTTP 状态码和错误正文，然后结束
async function check(res) {
  if (!res.ok) throw new Error(`HTTP ${res.status}: ${await res.text()}`);
  return res;
}

// 1. 提交
const submitted = await check(
  await fetch(`${BASE}/videos`, {
    method: "POST",
    headers: { ...auth, "Content-Type": "application/json" },
    body: JSON.stringify({
      model: "MiniMax-H3",
      prompt: "夕方の海辺を、柴犬がゆっくり歩いている",
      seconds: 6,
      resolution: "768P",
    }),
  }),
);
let video = await submitted.json();
console.log("已提交:", video.id);

// 2. 每 15 秒查询一次进度，直到完成或失败
while (video.status === "queued" || video.status === "in_progress") {
  await new Promise((resolve) => setTimeout(resolve, 15_000));
  const res = await check(await fetch(`${BASE}/videos/${video.id}`, { headers: auth }));
  video = await res.json();
  console.log(video.status, video.progress);
}
if (video.status !== "completed") throw new Error(`生成失败: ${JSON.stringify(video.error)}`);

// 3. 获取文件
const res = await check(await fetch(`${BASE}/videos/${video.id}/content`, { headers: auth }));
await writeFile("video.mp4", Buffer.from(await res.arrayBuffer()));
console.log("已保存到 video.mp4");