Collection 数据过滤删除任务--向量数据库VikingDB-火山引擎

文档中心

导航

Collection 数据过滤删除任务

最近更新时间：2025.05.26 14:49:25首次发布时间：2025.05.26 14:49:25

概述

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

请求参数

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

说明

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

示例

请求参数

import java.util.ArrayList;
import java.util.HashMap;
import java.util.IdentityHashMap;
import java.util.List;
import java.util.Random;

import org.apache.http.HttpHost;

import java.util.Map;
import com.volcengine.service.vikingDB.Collection;
import com.volcengine.service.vikingDB.Index;
import com.volcengine.service.vikingDB.VikingDBService;
import com.volcengine.service.vikingDB.common.*;

public class test {
    public static void main(String[] args) throws Exception {
        VikingDBService vikingDBService = new VikingDBService("", "", "", "","");
        HashMap<String, Object> taskParams = new HashMap<>();
        
        List<Map<String, Object>> conditionsList = new ArrayList<>();
        Map<String, Object> condition1 = new HashMap<>();
        condition1.put("op", "must");
        condition1.put("field", "city");
        condition1.put("conds", Arrays.asList("beijing"));
        conditionsList.add(condition1);
        
        Map<String, Object> condition2 = new HashMap<>();
        condition2.put("op", "range");
        condition2.put("field", "user_id");
        condition2.put("gt", 0);
        condition2.put("lt", 4);
        conditionsList.add(condition2);
        
        taskParams.put("filter_conds", conditionsList);
        taskParams.put("collection_name", "example");
        CreateTaskParam taskParam = new CreateTaskParam()
                                    .setTaskType(TaskType.FilterDelete)
                                    .setTaskParams(taskParams)
                                    .build();
        String task_id = vikingDBService.createTask(taskParam);
    }
}

返回值

属性	说明
task_id	uuid

后续处理

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