网站服务器失去响应,全网推广服务流程,dnf交易网站建设,关于网站建设的论文提纲文档#xff08;二#xff09;#xff1a;更新 1.创建测试数据2.更新文档2.1 在原有基础上新增字段2.2 在原有字段基础上部分修改字段值2.3 存在则更新#xff0c;不存在则插入给定值#xff08;upsert#xff09;2.4 全部文档更新#xff08;批量更新#xff09;2.5 基… 文档二更新 1.创建测试数据2.更新文档2.1 在原有基础上新增字段2.2 在原有字段基础上部分修改字段值2.3 存在则更新不存在则插入给定值upsert2.4 全部文档更新批量更新2.5 基于 Painless 脚本的批量更新2.6 基于 Ingest 预处理管道的批量更新2.7 取消更新2.8 总结 在 Elasticsearch 中更新文档 需要满足以下前置条件
文档必须存在除非使用 upsert 操作索引必须存在用户需要有写入权限write 或 all 权限_version 冲突检查如果指定 if_seq_no 和 if_primary_term
1.创建测试数据
创建索引users
PUT /users
{mappings: {properties: {name: { type: text },email: { type: keyword },age: { type: integer },created_at: { type: date }}}
}创建索引products
PUT /products
{mappings: {properties: {name: { type: keyword },price: { type: double },category: { type: keyword }}}
}创建索引orders
PUT /orders
{mappings: {properties: {order_id: { type: keyword },amount: { type: double },status: { type: keyword },discount: { type: double }}}
}创建索引books
PUT /books
{mappings: {properties: {title: { type: text },publish_date: { type: keyword },formatted_date: { type: date }}}
}2.更新文档
2.1 在原有基础上新增字段
写入数据。
POST /users/_doc/1
{name: John Doe,email: johnexample.com
}场景给现有文档添加新字段。例如给用户文档添加 age 字段。
POST /users/_update/1
{doc: {age: 30 # 新增字段}
}2.2 在原有字段基础上部分修改字段值
写入数据。
POST /users/_doc/2
{name: Alice,email: aliceold.com,age: 25
}场景修改文档的某个字段。例如更新用户的 email。
POST /users/_update/2
{doc: {email: alicenew.com}
}2.3 存在则更新不存在则插入给定值upsert
如果文档不存在直接更新会报错。 场景如果文档存在则更新否则插入upsert新文档类似 INSERT ... ON DUPLICATE KEY UPDATE。
POST /users/_update/3
{doc: {name: Bob,age: 40},upsert: {name: Bob,age: 40,created_at: 2023-01-01}
}2.4 全部文档更新批量更新
写入数据。
POST /products/_bulk
{index:{_id:1}}
{name:Laptop,price:1000,category:Electronics}
{index:{_id:2}}
{name:Coffee,price:5,category:Food}场景更新索引中的所有文档例如将所有商品的 price 增加 10 % 10\% 10%使用 _update_by_query。
POST /products/_update_by_query
{query: { match_all: {} }, # 匹配所有文档script: {source: ctx._source.price ctx._source.price * 1.1D, # 价格增加 10%D表示doublelang: painless}
}2.5 基于 Painless 脚本的批量更新
写入数据。
POST /orders/_bulk
{index:{_id:O1001}}
{order_id:O1001,amount:1500,status:pending}
{index:{_id:O1002}}
{order_id:O1002,amount:800,status:pending}场景使用脚本动态更新文档。例如根据条件修改 status。
POST /orders/_update_by_query
{query: { range: { amount: { gte: 1000 } } # 金额 1000 的订单},script: {source: ctx._source.status VIP; # 更新 statusctx._source.discount 0.1; # 新增 discount 字段,lang: painless}
}2.6 基于 Ingest 预处理管道的批量更新
写入数据。
POST /books/_bulk
{index:{_id:B001}}
{title:Elasticsearch Guide,publish_date:2023-05-20}
{index:{_id:B002}}
{title:Kibana Handbook,publish_date:2023-08-15}场景在写入或更新时自动处理数据。例如标准化日期格式。
步骤 1创建预处理管道
PUT _ingest/pipeline/format_date_pipeline
{description: 标准化日期格式,processors: [{date: {field: publish_date,target_field: formatted_date,formats: [yyyy-MM-dd],timezone: UTC}}]
}步骤 2使用管道更新文档
POST /books/_update_by_query?pipelineformat_date_pipeline
{query: { match_all: {} }
}2.7 取消更新
场景在更新过程中取消任务如长时间运行的 _update_by_query。
步骤 1准备测试数据10万条文档
POST /products/_bulk
{index:{}}
{name:Test,price:10,category:A}
{index:{}}
{name:Test,price:10,category:B}
...重复直到文档数足够多步骤 2发起一个真实的长任务
POST /products/_update_by_query?wait_for_completionfalse
{query: { match_all: {} },script: {source: ctx._source.price 0.1,lang: painless}
}步骤 3查找任务 ID
GET _tasks?actions*update_by_query{nodes: {node-1: {tasks: {abc123: { # 任务 IDaction: indices:data/write/update/byquery,description: update_by_query [products]}}}}
}步骤 4取消任务
POST _tasks/abc123/_cancel{acknowledged: true,task_failures: []
}2.8 总结
更新类型适用场景API新增字段扩展文档结构POST /index/_update/{id}修改字段部分更新POST /index/_update/{id}存在则更新否则插入避免重复插入POST /index/_update/{id} upsert批量更新全量修改POST /index/_update_by_query脚本更新复杂逻辑POST /index/_update_by_query PainlessIngest 管道数据预处理POST /index/_update_by_query?pipelinexxx取消更新终止任务POST _tasks/{task_id}/_cancel
这些方法覆盖了 Elasticsearch 文档更新的主要需求可根据业务场景选择合适的方式。
