向量数据库VikingDB
更新指定的任务,当前任务更新只用于 删除任务 的人工确认环节。
Go SDK 通过 vikingdb.New(sess) 创建的客户端实例调用 UpdateVikingdbTask(input) 方法发起任务更新请求,input 参数类型为 vikingdb.UpdateVikingdbTaskInput,包含任务更新所需的完整配置信息。
字段名 | 类型 | 必须 | 说明 |
|---|---|---|---|
TaskId | string | 是 | 任务ID,在创建任务时返回 |
TaskStatus | string | 只有 confirm 状态可以更新,只能更新为 confirmed,必填 | |
参数 | 类型 | 示例值 | 描述 |
|---|---|---|---|
Message | string | success | 操作结果信息 |
运行示例前,请完成以下准备:
- 按“安装与 client 初始化”文档安装 VikingDB V2 Go SDK;将完整代码保存为
main.go后执行go run main.go。- AK/SK 在火山引擎控制台“密钥管理”中创建;Host 和 Region 取自地域和访问域名,并按代码读取方式配置相应环境变量。
- Collection、Index 名称从 VikingDB 控制台对应资源详情获取,Task ID 使用创建或查询任务接口返回的 ID。请将代码中的
<YOUR_...>占位符全部替换为真实值。- 若示例包含 TOS 路径,请从 TOS 控制台确认桶名和对象路径,并替换为真实的
<YOUR_BUCKET_NAME>/<YOUR_TOS_PATH>。
package main import ( "fmt" "os" "github.com/volcengine/volcengine-go-sdk/service/vikingdb" "github.com/volcengine/volcengine-go-sdk/volcengine" "github.com/volcengine/volcengine-go-sdk/volcengine/credentials" "github.com/volcengine/volcengine-go-sdk/volcengine/session" ) func main() { var ( accessKey = os.Getenv("VIKINGDB_AK") secretKey = os.Getenv("VIKINGDB_SK") region = "cn-beijing" ) config := volcengine.NewConfig(). WithRegion(region). WithCredentials(credentials.NewStaticCredentials(accessKey, secretKey, "")) sess, err := session.NewSession(config) if err != nil { panic(err) } svc := vikingdb.New(sess) input := &vikingdb.UpdateVikingdbTaskInput{ TaskId: volcengine.String("<YOUR_TASK_ID>"), TaskStatus: volcengine.String(vikingdb.EnumOfTaskStatusForUpdateVikingdbTaskInputConfirmed), } resp, err := svc.UpdateVikingdbTask(input) if err != nil { panic(err) } fmt.Println(*resp.Message) }
仅支持将任务状态从 confirm 更新为 confirmed。