异步任务

curl -X POST https://api.elkapi.com/v1/task/submit \
  -H "Authorization: Bearer $API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "model": "kling-v3/text-to-video",
    "input": {
      "prompt": "一只金色的柴犬在樱花树下奔跑，慢镜头，电影质感",
      "duration": "5",
      "aspect_ratio": "16:9"
    },
    "callback_url": "https://your-server.com/webhook/task"
  }'

curl https://api.elkapi.com/v1/task/task_abc123 \
  -H "Authorization: Bearer $API_KEY"

import time
import requests

API_KEY = "YOUR_API_KEY"
BASE_URL = "https://api.elkapi.com/v1"

# 1. 提交任务
submit_resp = requests.post(
    f"{BASE_URL}/task/submit",
    headers={
        "Authorization": f"Bearer {API_KEY}",
        "Content-Type": "application/json",
    },
    json={
        "model": "kling-v3/text-to-video",
        "input": {
            "prompt": "一只金色的柴犬在樱花树下奔跑",
            "duration": "5",
            "aspect_ratio": "16:9",
        },
    },
)

task = submit_resp.json()
task_id = task["id"]
print(f"任务已提交: {task_id}")

# 2. 轮询等待完成
while True:
    resp = requests.get(
        f"{BASE_URL}/task/{task_id}",
        headers={"Authorization": f"Bearer {API_KEY}"},
    )
    result = resp.json()
    status = result["status"]
    print(f"状态: {status}")

    if status == "completed":
        print("生成结果:", result["outputs"])
        break
    elif status == "failed":
        print("任务失败:", result.get("error", "Unknown error"))
        break

    time.sleep(5)