向量数据库VikingDB
查询指定 task 的详情信息和执行进度
字段名 | 类型 | 必须 | 说明 |
|---|---|---|---|
task_id | string | 是 | 任务ID,在创建任务时返回 |
运行示例前,请完成以下准备:
- 安装对应版本的 VikingDB Python SDK,将完整代码保存为
example.py后执行python3 example.py。- AK/SK 在火山引擎控制台“密钥管理”中创建;Host 和 Region 取自地域和访问域名。请按代码的参数或环境变量读取方式完成配置。
- Collection、Index 名称从 VikingDB 控制台对应资源详情获取;Task ID 使用创建或查询任务接口返回的 ID。请将
<YOUR_...>占位符替换为真实值。- 若示例包含 TOS 路径,请从 TOS 控制台确认桶名和对象路径,并替换为真实的
<YOUR_BUCKET_NAME>/<YOUR_TOS_PATH>。
from volcengine.viking_db import * if __name__ == '__main__': vikingdb_service = VikingDBService() vikingdb_service.set_ak() vikingdb_service.set_sk() task = vikingdb_service.get_task("<YOUR_TASK_ID>")
属性 | 类型 | 说明 |
|---|---|---|
task_id | string | 任务ID |
task_type | string | 任务类型 |
task_status | string | 任务状态 |
update_person | string | 任务更新人 |
update_time | string | 任务信息更新时间 |
create_time | string | 任务信息创建时间 |
process_info | map | 任务处理信息,例如进度等 |
task_params | map | 任务配置信息,用户填入 |
data_import | 数据导入任务 |
|---|---|
data_export | 数据导出任务 |
filter_update | 数据过滤更新任务 |
filter_delete | 数据过滤删除任务 |
init | queued | confirm | confirmed | running | done | fail |
|---|---|---|---|---|---|---|
初始化中 | 排队中 | 需要人工确认 | 已确认 | 执行中 | 完成 | 失败 |
字段 | 类型 | 说明 |
|---|---|---|
task_progress | string | 任务进度 例如50% |
err_msg | string | 任务错误信息 |
sampled_data | list | 采样5条数据用于展示 |
sampled_timestamp | int64 | 采样的时间戳,后写入的数据不会被处理 |
scan_data_count | int64 | 当前扫描数据量 |
total_data_count | int64 | collection 数据总条数(预估) |
total_filter_count | int64 | 已经过滤出的数据 |
create_time 与 update_time 为字符串,格式为 YYYY-MM-DD HH:mm:ss,时区为 Asia/Shanghai(UTC+8)。解析时不要按本地系统时区二次偏移。
sampled_timestamp 类型为 int64,单位为毫秒,是 Unix Epoch 时间戳;晚于该采样点写入的数据不会被本次任务处理。
| 字段 | 类型 | 含义 |
|---|---|---|
code | int | 业务状态码;成功时为 0。 |
message | string | 状态说明或错误信息。 |
request_id | string | 请求唯一标识,用于问题排查。 |
data | object / array | 接口业务数据;没有业务数据时可为空。 |
本接口的业务错误码、触发条件和处理建议统一参见向量库 V1 错误码。排查时请保留响应中的 request_id。