TOS文件数据导入任务--向量数据库VikingDB-火山引擎

文档中心

立即注册

导航

TOS文件数据导入任务

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

概述

将 TOS 中的文件数据导入到 Collection 中，要求文件的列名必须和 Collection fields 重合，否则会解析失败

说明

使用前请先授权 VikingDB 跨服务访问 TOS 去授权

请求参数

参数名	类型	必须	说明	子字段	类型	必选	说明
taskType	string	是	任务类型，填入TaskType.DataImport
taskParams	json	是	任务参数	collection_name	string	是	Collection 名称，必填
				file_type	string	是	文件类型, json 或者 parquet，必填
				tos_path	string	是	TOS 路径，格式：{桶名}/{路径}，注意不是域名。必填
				ignore_error	bool	否	设置为 true 时遇到数据会继续解析文件，默认为 false

示例

请求参数

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("", "", "", "","");
        
        taskParams.put("file_type", "parquet");
        taskParams.put("collection_name", "example");
        taskParams.put("tos_path", "bucket_name/tos_path");
        CreateTaskParam taskParam = new CreateTaskParam()
                                    .setTaskType(TaskType.DataImport)
                                    .setTaskParams(taskParams)
                                    .build();
        String task_id = vikingDBService.createTask(taskParam);
    }
}

返回值

属性	说明
task_id	uuid