文档中心

向量数据库VikingDB

请输入

任务创建

Collection 数据过滤删除任务

概述

按特定条件批量删除Collection中的数据

请求参数

参数名	类型	必须	说明	子字段	类型	必选	说明
TaskType	string	是	任务类型，填入 filter_delete
TaskParams	map	是	任务参数	collection_name	string	是	Collection 名称，必填
				filter_conds	map	是	过滤条件，支持 must 、must_not、range、range_out 算子，使用参考标量过滤过滤删除 city 为 beijing 且 user_id (0, 4) 之间的数据 `JSON <br> [ <br> { <br> "op": "must", <br> "field": "city", <br> "conds": ["beijing"] <br> }, <br> { <br> "op": "range", <br> "field": "user_id", <br> "gt": 0, <br> "lt": 4 <br> }, <br> <br> ] <br>`
				need_confirm	bool	否	为false时可跳过人工确认环节，默认为true。为 true 时需要执行任务更新接口
				tos_path	string	否	在实际执行数据删除前，将数据备份到指定目录，参考数据导出功能。
				file_type	string	否	备份文件类型 json 或者 parquet，默认为 parquet

若要将数据备份至TOS，请先授权 VikingDB 跨服务访问 TOS 去授权

示例

运行示例前，请完成以下准备：
在 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>")
      filter_conds := make([]interface{}, 0)
      condition1 := make(map[string]interface{})
      condition1["op"] = "must"
      condition1["field"] = "city"
      condition1["conds"] = []string{"beijing"}
      
      
      condition2 := make(map[string]interface{})
      condition2["op"] = "range"
      condition2["field"] = "user_id"
      condition2["gt"] = 0
      condition2["lt"] = 4
      
      filter_conds = append(filter_conds, condition1)
      filter_conds = append(filter_conds, condition2)
      
      task_param := make(map[string]interface{})
      task_param["collection_name"] = "example"
      task_param["filter_conds"] = filter_conds
      task_id, err := service.CreateTask(vikingdb.Filter_Delete, task_param)
      if err != nil {
        fmt.Println(err)
      }
 }

返回值

属性	说明
task_id	uuid

后续处理

如果需要人工确认，可执行任务更新操作

最近更新时间：2026.09.08 15:30:59

这个页面对您有帮助吗？

有用

无用

向量数据库VikingDB

请求参数 #

返回值 #

后续处理 #

请求参数

返回值

后续处理