异步任务 API

用于处理长时间运行的任务，如视频生成、批量处理等。支持任务提交、状态查询、取消和 Webhook 回调。

接口概览

方法	端点	说明
POST	`/v1/async/submit`	提交异步任务
GET	`/v1/async/{task_id}`	查询任务状态
GET	`/v1/async`	列出所有任务
DELETE	`/v1/async/{task_id}`	取消任务

支持的任务类型

video_generation1-5 分钟

视频生成

文生视频、图生视频任务

image_batch根据数量

批量图像

批量生成或处理多张图片

document_analysis30秒-2分钟

文档分析

长文档理解和分析

data_extraction根据文件

数据提取

从文件中提取结构化数据

代码示例

from openai import OpenAI

client = OpenAI(
    api_key="sk-air-your-key",
    base_url="https://nexusflow.hk/v1",
)

# 提交异步任务
response = client.async_tasks.create(
    task_type="video_generation",
    params={
        "model": "wanx2.1-t2v-plus",
        "prompt": "城市夜景延时摄影，霓虹灯闪烁",
        "duration": 10,
    },
    callback_url="https://your-server.com/webhook",  # 可选
)

print(f"任务 ID: {response.task_id}")
print(f"状态: {response.status}")

任务状态流转

等待中

pending

处理中

processing

成功

succeeded

或

失败

failed

最佳实践

使用 Webhook

相比轮询，Webhook 更高效且实时。设置 callback_url 可在任务完成时立即收到通知。

合理的轮询间隔

如果使用轮询，建议间隔 5-10 秒。避免过于频繁的查询，以免触发限流。

处理超时

设置合理的超时时间，如果任务长时间未完成（如 10 分钟），考虑重新提交。

保存 task_id

务必保存返回的 task_id，以便后续查询状态或取消任务。