elasticsearch批量局部更新数据

    def update_data_batch(self,actions):
        """
        批量更新数据
        :param actions:
        :return:
        """
        item_list=[]
        for data in actions:
            dic = {
                "_index": self.index,
                "_type": self._type,
                "_op_type": "update",
                "_id": data.get(‘id‘),
                "doc": data
            }
            item_list.append(dic)
            if len(item_list) == 500:
                success, _ = bulk(self.client, item_list)
                item_list.clear()
        if item_list:
            success, _ = bulk(self.client, item_list)
            print(success, _)
        self.client.indices.refresh()

if __name__ == ‘__main__‘:
    ll=[]
    for i in range(10):
        dic={
            "size":1111,‘id‘:i
        }
        ll.append(dic)
    es_tt.update_data_batch(ll)

    ll = []
    for num, data in enumerate(es_tt.scan_all_data()):
        insert_dic = {
            "_index": es_tt.index,
            "_type": es_tt._type,
            "_op_type": "update",   #指定更新方式插入数据
            "_id": data.get(‘id‘),
            "script": {
                "source": "ctx._source.price=params.price",  #ctx._source.price指定是原数据要更新的字段为price，
                "params": {   #params为参数，params中的字段名可以随便设置，值为用来替换原数据中字段的值
                    "price": num
                }
            }
        }
        ll.append(insert_dic)
    bulk(es_tt.client, ll)