向量数据库VikingDB
查询指定 task 的详情信息和执行进度
字段名 | 类型 | 必须 | 说明 |
|---|---|---|---|
TaskID | string | 是 | 任务ID,在创建任务时返回 |
运行示例前,请完成以下准备:
- 在 Go 项目中安装并引入 VikingDB SDK;将完整代码保存为
main.go后执行go run main.go。- 将
<YOUR_HOST>、<YOUR_REGION>和<YOUR_SCHEME>替换为地域和访问域名中与实例一致的服务地址、地域和协议。- 将
<YOUR_AK>、<YOUR_SK>替换为火山引擎控制台“密钥管理”中创建的 Access Key ID 和 Secret Access Key;请勿把真实凭证提交到代码仓库。- 将 Collection、Index、Task 等资源占位符替换为控制台中对应资源的名称或接口返回的 ID。若示例包含 TOS 路径,请从 TOS 控制台确认桶名和对象路径,并使用
tos://<YOUR_BUCKET_NAME>/<YOUR_OBJECT_KEY>或文档要求的路径格式。
package main import ( "fmt" "github.com/volcengine/volc-sdk-golang/service/vikingdb" ) func main() { service := vikingdb.NewVikingDBService("<YOUR_HOST>", "<YOUR_REGION>", "<YOUR_AK>", "<YOUR_SK>", "<YOUR_SCHEME>") task, err := service.GetTask("<YOUR_TASK_ID>") fmt.Println(task, err) }
属性 | 类型 | 说明 |
|---|---|---|
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。