ADX 达人数据 批量
adx-creator-data-batch 用于按 JSON 数组批量创建 ADX 达人数据采集任务。调用方需要在外部应用内为每个条目完成提示词组装,FunClaw 只接收 items[].prompt 并原样转发到 session-hub。
能力信息
| 字段 | 值 |
|---|---|
| 能力 Key | adx-creator-data-batch |
| 能力名称 | ADX 达人数据 批量 |
| 能力类型 | workflow_execute |
| 开放状态 | 可通过统一开放能力执行入口调用 |
底层执行复用平台任务、批量 item 编排、共享远端队列、session-hub creator-data task、资产写入和任务状态追踪能力。外部应用只感知平台 taskId、batchId、批量 item 状态和产出资产。
开始任务
POST /api/open/v1/organizations/{orgId}/capabilities/adx-creator-data-batch:execute
Authorization: Bearer <sk-organization-application-api-key>
Content-Type: application/json请求体
{
"applicationId": "organization-application-id",
"input": {
"items": [
{
"externalItemId": "item-001",
"prompt": "第一条外部已拼好的 ADX 提示词"
},
{
"externalItemId": "item-002",
"prompt": "第二条外部已拼好的 ADX 提示词"
}
]
}
}字段说明:
| 字段 | 必填 | 说明 |
|---|---|---|
applicationId | 否 | 调用方团队应用 ID。传入时必须和 API Key 绑定的应用一致;不传时平台会使用 API Key 绑定的应用。 |
input.items | 是 | 批量任务列表,至少 1 条,最多 100 条。 |
input.items[].externalItemId | 否 | 调用方系统内的行 ID 或幂等辅助标识,用于结果回看。 |
input.items[].prompt | 是 | 外部应用已组装好的 ADX 采集提示词。FunClaw 不再进行服务端提示词拼接,仅将 prompt 原样转发到 session-hub。Top10 看板自动生成的 prompt 会要求 Worker 抓取 30 条素材(fetch_material_top.py --limit 30)并 mirror 全部行;结果页默认展示 10 条,拉黑后从储备池补位。 |
开始任务成功表示平台已接收批量请求,并创建平台任务与批量执行记录。
{
"capabilityKey": "adx-creator-data-batch",
"message": "SUCCEEDED",
"code": 200,
"data": {
"taskId": "platform-task-id",
"batchId": "batch-id",
"status": "RUNNING",
"totalCount": 2,
"succeededCount": 0,
"failedCount": 0,
"pendingCount": 2,
"items": [
{
"itemIndex": 1,
"externalItemId": "item-001",
"status": "RUNNING",
"ossUrl": null,
"artifact": null,
"errorCode": null,
"errorMessage": null,
"startedAt": null,
"finishedAt": null
}
],
"createdAt": "2026-06-16T09:00:00Z",
"updatedAt": "2026-06-16T09:00:01Z"
}
}Agent CLI 映射
Agent CLI 目录中,collect_adx_creator_data_batch 会映射到本开放能力 adx-creator-data-batch。CLI 指令用于 Agent / 数字员工大脑选择和补参数,不改变外部应用的开放 API 契约。
CLI 指令不是外部应用的 capabilityKey;外部应用仍调用本页的 adx-creator-data-batch:execute。完整指令目录见 CLI 目录。
查询当前运行任务
adx-creator-data-batch、adx-creator-data-single、douyin-top10-single、douyin-top10-batch、kuaishou-creator-info-single 和 kuaishou-creator-info-batch 共享底层 douyin-top10 远端资源队列。批量任务本身会串行执行内部 item,并作为父任务占用一个 slot;内部 item 不单独抢占队列。
GET /api/open/v1/organizations/{orgId}/capabilities/adx-creator-data-batch/current-task
Authorization: Bearer <sk-organization-application-api-key>{
"capabilityKey": "adx-creator-data-batch",
"message": "SUCCEEDED",
"code": 200,
"data": {
"running": true,
"queueKey": "douyin-top10",
"ownerCapabilityKey": "adx-creator-data-single",
"taskId": "platform-task-id",
"executionId": "platform-execution-id",
"status": "RUNNING",
"acquiredAt": "2026-06-16T09:00:00Z",
"activeCount": 2,
"capacity": 2,
"owners": []
}
}查询任务
GET /api/open/v1/organizations/{orgId}/capabilities/adx-creator-data-batch/tasks/{taskId}
Authorization: Bearer <sk-organization-application-api-key>taskId 使用开始任务返回的 data.taskId,即平台任务 ID。
部分成功:
{
"capabilityKey": "adx-creator-data-batch",
"message": "SUCCEEDED",
"code": 200,
"data": {
"taskId": "platform-task-id",
"batchId": "batch-id",
"status": "PARTIAL_FAILED",
"totalCount": 2,
"succeededCount": 1,
"failedCount": 1,
"pendingCount": 0,
"items": [
{
"itemIndex": 1,
"externalItemId": "item-001",
"status": "SUCCEEDED",
"ossUrl": "/api/open/v1/organizations/{orgId}/artifacts/artifact-item-001/download",
"artifact": {
"merge_update_event": {
"event_time": "2026-06-16T09:18:00Z",
"event_timezone": "Asia/Shanghai",
"record_count": 10
},
"douyin_top_videos": []
},
"errorCode": null,
"errorMessage": null,
"startedAt": "2026-06-16T09:00:10Z",
"finishedAt": "2026-06-16T09:18:00Z"
},
{
"itemIndex": 2,
"externalItemId": "item-002",
"status": "FAILED",
"ossUrl": null,
"artifact": null,
"errorCode": "UPSTREAM_TIMEOUT",
"errorMessage": "session-hub task timed out",
"startedAt": "2026-06-16T09:18:05Z",
"finishedAt": "2026-06-16T09:38:05Z"
}
],
"createdAt": "2026-06-16T09:00:00Z",
"updatedAt": "2026-06-16T09:38:05Z"
}
}批次级统计直接读取 totalCount、succeededCount、failedCount、pendingCount;单个 item 的错误通过 items[].errorCode 和 items[].errorMessage 表达。
取消任务
运行中的批量任务可以使用平台任务 ID 取消:
POST /api/open/v1/organizations/{orgId}/capabilities/adx-creator-data-batch/tasks/{taskId}:cancel
Authorization: Bearer <sk-organization-application-api-key>取消成功:
{
"capabilityKey": "adx-creator-data-batch",
"message": "SUCCEEDED",
"code": 200,
"data": {
"taskId": "platform-task-id",
"batchId": "batch-id",
"status": "CANCELED",
"totalCount": 2,
"succeededCount": 1,
"failedCount": 0,
"pendingCount": 0,
"items": [
{
"itemIndex": 1,
"externalItemId": "item-001",
"status": "SUCCEEDED",
"ossUrl": "/api/open/v1/organizations/{orgId}/artifacts/artifact-item-001/download",
"artifact": {},
"errorCode": null,
"errorMessage": null,
"startedAt": "2026-06-16T09:00:10Z",
"finishedAt": "2026-06-16T09:18:00Z"
},
{
"itemIndex": 2,
"externalItemId": "item-002",
"status": "CANCELED",
"ossUrl": null,
"artifact": null,
"errorCode": "OPEN_CAPABILITY_CANCELLED_BY_USER",
"errorMessage": "cancelled by open capability caller",
"startedAt": "2026-06-16T09:18:05Z",
"finishedAt": "2026-06-16T09:20:00Z"
}
],
"createdAt": "2026-06-16T09:00:00Z",
"updatedAt": "2026-06-16T09:20:00Z"
}
}已处于 SUCCEEDED、FAILED 或 PARTIAL_FAILED 的终态批量任务不可取消,会返回 409。已取消任务重复调用取消接口时,会返回当前已取消状态。
常见错误
| HTTP 状态 | 场景 |
|---|---|
400 | 缺少 items、items 为空、items 超过 100 条,或单个 item 缺少 prompt。 |
401 | 未提供 Authorization: Bearer <sk-...>。 |
403 | API Key 不属于当前组织、未绑定该应用,或应用未获得本能力授权。 |
404 | 能力不存在、未启用,或查询的任务不属于当前 API Key 绑定应用。 |
409 | 共享 douyin-top10 远端队列已满。 |
501 | 能力存在但后端 executor 尚未注册。 |