1. 程式人生 > 其它 >ElasticSearch的批量操作bulk

ElasticSearch的批量操作bulk

技術標籤:elasticsearchelasticsearch

批量插入資料

  1. 同一個index下,不指定_id
POST /gunsIndex/doc/_bulk
{"index":{}}
{"age":100,"name":"張三","address":"北京市順義區","birthday":"2020-10-12"}
{"index":{}}
{"age":121,"name":"張四","address":"北京市順義區1","birthday":"2020-01-13"}
{"index":{}}
{"age":122,"name":"王五","address":"北京市順義區2","birthday":"2020-10-14"}
{"index":{}}
{"age":123,"name":"趙6","address":"北京市順義區3","birthday":"2020-10-15"}
{"index":{}}
{"age":124,"name":"田7","address":"北京市順義區4","birthday":"2020-10-16"}
  1. 同一個index下,指定_id
POST /ttt/doc/_bulk
{"index":{"_id":"1"}}
{"age":100,"name":"張三","address":"北京市順義區","birthday":"2020-10-12"}
{"index":{"_id":"2"}}
{"age":121,"name":"張四","address":"北京市順義區1","birthday":"2020-01-13"}
  1. 不同index下(要指定type),指定id
POST /_bulk
{"index":{"_index":"index8","_type":"doc","_id":"1"}}
{"age":123,"name":"趙6","address":"北京市順義區3","birthday":"2020-10-15"}
{"index":{"_index":"index8","_type":"doc","_id":"2"}}
{"age":124,"name":"田7","address":"北京市順義區4","birthday":"2020-10-16"}
{"index":{"_index":"index9","_type":"doc","_id":"1"}}
{"age":125,"name":"趙6","address":"北京市順義區3","birthday":"2020-10-15"}
{"index":{"_index":"index9","_type":"doc","_id":"2"}}
{"age":126,"name":"田7","address":"北京市順義區4","birthday":"2020-10-16"}
  1. 不同index下(要指定type),不指定id
POST /_bulk
{"index":{"_index":"index5","_type":"doc"}}
{"age":123,"name":"趙6","address":"北京市順義區3","birthday":"2020-10-15"}
{"index":{"_index":"index5","_type":"doc"}}
{"age":124,"name":"田7","address":"北京市順義區4","birthday":"2020-10-16"}
{"index":{"_index":"index6","_type":"doc"}}
{"age":125,"name":"趙6","birthday":"2020-10-15"}
{"index":{"_index":"index6","_type":"doc"}}
{"age":126,"name":"田7","address":"北京市順義區4","birthday":"2020-10-16"}

_bulk的批量操作中index和create操作的區別:create為新增操作,必須要指定index,type,和id;如果索引中已經存在相同id的doc,那麼插入失敗丟擲異常。
index操作是覆蓋操作,也就是如果指定id的情況下,如果id不存在就是新增,如果存在就是覆蓋舊資料

批量修改

POST /_bulk
{"update":{"_index":"index5","_type":"doc","_id":"o5zgdHYBZ16azDSUjUqk"}}
{"doc":{"name":"孫悟空"}}
{"update":{"_index":"index6","_type":"doc","_id":"MZzqdHYBZ16azDSU3kvk"}}
{"doc":{"name":"太白"}}
POST index5/doc/_bulk
{"update":{"_id":"o5zgdHYBZ16azDSUjUqk"}}
{"doc":{"name":"孫悟空12"}}