我已经提到了以下查询。（Bulk update查询和per document更新查询）
核心逻辑在中script，这在两个查询中都相同。
我建议您按照逻辑进行自我解释。基本上，脚本会遍历嵌套文档，并根据您指定的条件对其进行count相应的更新。
POST <your_index_name>/_update_by_query
{
"query": {
"match_all": {}
},
"script": {
"lang": "painless",
"source": """
if(ctx._source.ref_counter.contains(params.cur_data)){
for(int i=0; i<ctx._source.ref_counter.size(); i++)
{
HashMap myKV = ctx._source.ref_counter.get(i);
if(myKV.get(params.key_ref)==params.key_ref_value){
myKV.put(params.key_count, params.key_count_value_new);
}
}
//ctx._source.ref_counter.add(params.new_data);
}""",
"params": {
"cur_data": { "ref_name": "test2", "count": 2},
"new_data": { "ref_name": "test2", "count": 22},
"key_ref": "ref_name",
"key_ref_value": "test2",
"key_count": "count",
"key_count_value_new": 80
}}
}
POST <your_index_name>/<your_mapping>/1/_update
{
"script": {
"lang": "painless",
"source": """
if(ctx._source.ref_counter.contains(params.cur_data)){
for(int i=0; i<ctx._source.ref_counter.size(); i++)
{
HashMap myKV = ctx._source.ref_counter.get(i);
if(myKV.get(params.key_ref)==params.key_ref_value){
myKV.put(params.key_count, params.key_count_value_new);
}
}
//ctx._source.ref_counter.add(params.new_data);
}""",
"params": {
"cur_data": { "ref_name": "test2", "count": 2},
"new_data": { "ref_name": "test2", "count": 22},
"key_ref": "ref_name",
"key_ref_value": "test2",
"key_count": "count",
"key_count_value_new": 80
}
}
}
希望对您有所帮助，如有任何疑问，请与我们联系！
602392714
清零编程群