es按字段全部更新置0、批量更新bulk

新增字段

PUT http://host/index名字/_mapping
{"properties":{"last_time_used":{"type" : "date"}}
}


全部更新

参考&＃xff1a;http://t.zoukankan.com/itBlogToYpl-p-13367859.html
https://www.zhihu.com/question/400814362/answer/1284775773

###
try:updateBody &＃61; {"script": {"source": "ctx._source[&＃39;字段名&＃39;] &＃61; params[&＃39;字段名&＃39;]",## "source": "ctx._source.&＃39;字段名&＃39;&＃61; params.&＃39;字段名&＃39;","lang": "painless","params": {"字段名": 0}}}print("here")es_client.update_by_query(index&＃61;_index, body&＃61;updateBody)
except:pass


批量更新


{&＃39;_op_type&＃39;: &＃39;update&＃39;,&＃39;_index&＃39;: &＃39;index-name&＃39;,&＃39;_type&＃39;: &＃39;document&＃39;,&＃39;_id&＃39;: 42,&＃39;doc&＃39;: {&＃39;question&＃39;: &＃39;The life, universe and everything.&＃39;}
}


ACTIONS &＃61; []
_index &＃61; "*8st_"
k &＃61; 0
for i in final:response &＃61; es_client.search(body&＃61;{"query": {"bool": {"must": [{"term": {"aid": i[0]}}], }},# "_source": ["_id"]}, index&＃61;_index)# print(response)for j in response["hits"]["hits"]:_id &＃61; j["_id"]# print(_id)ACTIONS.append({"_index": _index,&＃39;_op_type&＃39;: &＃39;update&＃39;,"_id": _id,"_source": {"doc": {"aid_score": float(i[1])}}})k&＃43;&＃61;1print(k)elasticsearch.helpers.bulk(es_client, ACTIONS, index&＃61;_index, raise_on_error&＃61;False)