将 TOS 中的文件数据导入到 Collection 中，要求文件的列名必须和 Collection fields 重合，否则会解析失败
说明
使用前请先授权 VikingDB 跨服务访问 TOS 去授权
参数名 | 类型 | 必须 | 说明 | 子字段 | 类型 | 必选 | 说明 |
|---|---|---|---|---|---|---|---|
TaskType | string | 是 | 任务类型，填入TaskType.Data_Import | ||||
TaskParams | json | 是 | 任务参数 | collection_name | string | 是 | Collection 名称，必填 |
file_type | string | 是 | 文件类型, json 或者 parquet，必填 | ||||
tos_path | string | 是 | TOS 路径，格式 ：{桶名}/{路径}，注意不是域名。必填 | ||||
ignore_error | bool | 否 | 设置为 true 时遇到数据会继续解析文件，默认为 false |
package main import ( "fmt" "github.com/volcengine/volc-sdk-golang/service/vikingdb" ) func main() { service := vikingdb.NewVikingDBService("", "", "", "", "") task_param := make(map[string]interface{}) task_param["collection_name"] = "example" task_param["file_type"] = "parquet" task_param["tos_path"] = "bucket_name/tos_path" task_id, err := service.CreateTask(vikingdb.Data_Import, task_param) if err != nil { fmt.Println(err) } }
属性 | 说明 |
|---|---|
task_id | uuid |