Отримати Wan video

GET

videos

{task_id}

cURL

curl https://api.cometapi.com/v1/videos/<TASK_ID> \
  -H "Authorization: Bearer $COMETAPI_KEY"

import os
import time
import requests

TASK_ID = "<TASK_ID>"
headers = {"Authorization": "Bearer " + os.environ["COMETAPI_KEY"]}
terminal_statuses = {"completed", "failed", "error"}

while True:
    response = requests.get(
        f"https://api.cometapi.com/v1/videos/{TASK_ID}",
        headers=headers,
        timeout=60,
    )
    response.raise_for_status()
    task = response.json()
    print(task["status"], task.get("progress"))
    if task["status"] in terminal_statuses:
        print(task.get("video_url"))
        break
    time.sleep(10)

const TASK_ID = "<TASK_ID>";
const terminalStatuses = new Set(["completed", "failed", "error"]);

while (true) {
  const response = await fetch(
    `https://api.cometapi.com/v1/videos/${TASK_ID}`,
    { headers: { Authorization: `Bearer ${process.env.COMETAPI_KEY}` } },
  );
  const task = await response.json();
  console.log(task.status, task.progress);
  if (terminalStatuses.has(task.status)) {
    console.log(task.video_url);
    break;
  }
  await new Promise((resolve) => setTimeout(resolve, 10_000));
}

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.cometapi.com/v1/videos/{task_id}",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.cometapi.com/v1/videos/{task_id}"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("https://api.cometapi.com/v1/videos/{task_id}")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

{
  "id": "task_example",
  "model": "wan2.6",
  "object": "video",
  "status": "queued",
  "progress": 0,
  "created_at": 1779938152
}

Використовуйте цей endpoint після створення задачі Wan video. Він повертає стан задачі та включає video_url після завершення задачі.

Перевірте ці поля

status повідомляє, чи має задача стан queued, in_progress, completed, failed або error.
progress — це приблизний відсоток завершення.
video_url з’являється у відповідях для завершених задач.
error з’являється, коли задача завершується з помилкою.

Процес polling

Спочатку створіть задачу

Почніть із Create a Wan video і збережіть повернений id.

Виконуйте polling за ID задачі

Надсилайте ID задачі до цього endpoint, доки status не набуде значення completed, failed або error.

Завантажте MP4 файл

Коли status дорівнює completed, викличте Retrieve Wan video content.

Авторизації

Authorization

string

header

обов'язково

Bearer authentication. Use your CometAPI API key.

Параметри шляху

task_id

string

обов'язково

Task ID returned by POST /v1/videos.

Відповідь

Current Wan video task state.

string

обов'язково

Task ID. Use this value as task_id in retrieve and content requests.

Приклад:

"task_example"

object

string

обов'язково

Object type. Wan video tasks return video.

Приклад:

"video"

model

string

обов'язково

Model ID used for the task.

Приклад:

"wan2.6"

status

enum<string>

обов'язково

Task lifecycle status. Poll until the value is completed, failed, or error.

Доступні опції:

queued,

in_progress,

completed,

failed,

error

Приклад:

"queued"

progress

integer

обов'язково

Task progress as a coarse percentage.

Необхідний діапазон: 0 <= x <= 100

Приклад:

0

created_at

integer

обов'язково

Task creation time as a Unix timestamp in seconds.

Приклад:

1779938152

task_id

string

Compatibility alias for id. The value matches id when present.

Приклад:

"task_example"

completed_at

integer

Task completion time as a Unix timestamp in seconds. This field appears on completed tasks.

Приклад:

1779938219

video_url

string

Temporary video delivery URL. This field appears on completed tasks.

Приклад:

"<temporary-video-url>"

error

object

Failure details. This field appears when the task fails.

Створити відео Wan

Попередня

Завантаження відеоконтенту Wan

Наступна

cURL

curl https://api.cometapi.com/v1/videos/<TASK_ID> \
  -H "Authorization: Bearer $COMETAPI_KEY"

import os
import time
import requests

TASK_ID = "<TASK_ID>"
headers = {"Authorization": "Bearer " + os.environ["COMETAPI_KEY"]}
terminal_statuses = {"completed", "failed", "error"}

while True:
    response = requests.get(
        f"https://api.cometapi.com/v1/videos/{TASK_ID}",
        headers=headers,
        timeout=60,
    )
    response.raise_for_status()
    task = response.json()
    print(task["status"], task.get("progress"))
    if task["status"] in terminal_statuses:
        print(task.get("video_url"))
        break
    time.sleep(10)

const TASK_ID = "<TASK_ID>";
const terminalStatuses = new Set(["completed", "failed", "error"]);

while (true) {
  const response = await fetch(
    `https://api.cometapi.com/v1/videos/${TASK_ID}`,
    { headers: { Authorization: `Bearer ${process.env.COMETAPI_KEY}` } },
  );
  const task = await response.json();
  console.log(task.status, task.progress);
  if (terminalStatuses.has(task.status)) {
    console.log(task.video_url);
    break;
  }
  await new Promise((resolve) => setTimeout(resolve, 10_000));
}

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.cometapi.com/v1/videos/{task_id}",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.cometapi.com/v1/videos/{task_id}"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("https://api.cometapi.com/v1/videos/{task_id}")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

{
  "id": "task_example",
  "model": "wan2.6",
  "object": "video",
  "status": "queued",
  "progress": 0,
  "created_at": 1779938152
}

Модерація контенту

API-ключі

Перевірте ці поля

Процес polling

Авторизації

Параметри шляху

Відповідь

​Перевірте ці поля

​Процес polling

Авторизації

Параметри шляху

Відповідь

Перевірте ці поля

Процес polling