按特定条件批量更新数据,不支持vector、sparse_vector、text 类型字段的更新
参数名 | 类型 | 必须 | 说明 | 子字段 | 类型 | 必选 | 说明 |
|---|---|---|---|---|---|---|---|
task_type | string | 是 | 任务类型,填入 filter_update | ||||
task_params | map | 是 | 任务参数 | collection_name | string | 是 | Collection 名称,必填 |
filter_conds | array | 是 | 过滤条件,支持 must 、must_not、range、range_out 算子,使用参考标量过滤 | ||||
update_fields | map | 是 | 需要更新的字段值,必须是标量字段,不支持vector、sparse_vector、text 类型字段的更新 |
运行示例前,请完成以下准备:
- 安装对应版本的 VikingDB Python SDK,将完整代码保存为
example.py后执行python3 example.py。- AK/SK 在火山引擎控制台“密钥管理”中创建;Host 和 Region 取自地域和访问域名。请按代码的参数或环境变量读取方式完成配置。
- Collection、Index 名称从 VikingDB 控制台对应资源详情获取;Task ID 使用创建或查询任务接口返回的 ID。请将
<YOUR_...>占位符替换为真实值。- 若示例包含 TOS 路径,请从 TOS 控制台确认桶名和对象路径,并替换为真实的
<YOUR_BUCKET_NAME>/<YOUR_TOS_PATH>。
from volcengine.viking_db import * vikingdb_service = VikingDBService() vikingdb_service.set_ak() vikingdb_service.set_sk() task_params = { "collection_name": "example", # collection 名称 "filter_conds": [ { "op": "must", "field": "city", "conds": ["beijing"] }, { "op": "range", "field": "user_id", "gt": 0, "lt": 4 } ], "update_fields": { "city": "shanghai" } } task_id = vikingdb_service.create_task(TaskType.Filter_Update, task_params)
属性 | 说明 |
|---|---|
task_id | uuid |
| 字段 | 类型 | 含义 |
|---|---|---|
code | int | 业务状态码;成功时为 0。 |
message | string | 状态说明。 |
request_id | string | 请求唯一标识。 |
task_id | string | 创建成功的离线任务唯一标识,后续用于查询、更新或删除任务。 |
| 字段 | 类型 | 含义 |
|---|---|---|
code | int | 业务状态码;成功时为 0。 |
message | string | 状态说明。 |
request_id | string | 请求唯一标识。 |
task_id | string | 创建成功的离线任务唯一标识,后续用于查询、更新或删除任务。 |
| 字段 | 类型 | 含义 |
|---|---|---|
code | int | 业务状态码;成功时为 0。 |
message | string | 状态说明或错误信息。 |
request_id | string | 请求唯一标识,用于问题排查。 |
data | object / array | 接口业务数据;没有业务数据时可为空。 |
本接口的业务错误码、触发条件和处理建议统一参见向量库 V1 错误码。排查时请保留响应中的 request_id。