kibana——es的批量操作


一·_mget:

  1.創建的索引如下:

   2.批量查詢:

#查詢兩個
GET _mget
{
  "docs":[
    {
      "_index":"testdb",
      "_type":"ty2",
      "_id":1
    },
      {
      "_index":"testdb",
      "_type":"ty1",
      "_id":1
    }]
    
}
#指明索引查詢
GET testdb/_mget
{
  "docs":[
    {
     
      "_type":"ty2",
      "_id":1
    },
      {
     
      "_type":"ty1",
      "_id":1
    }]
    
}

 

#指明索引和type
GET testdb/ty2/_mget
{
  "docs":[
    {
     
      "_id":1
    },
      {

      "_id":2
    }]
    
}

 

#獲取指定索引和type下的
GET testdb/ty2/_mget
{
  "ids":[1,2]
}

 

二.bulk批量操作:

  增刪改查:把所有操作發送到一個節點解析,在由節點分發,數據量一次也不能提交太多

 
         
注:每條數據第一行為索引及type和id,第二行為數據內容(共兩行,不能分開寫,否則無法解析,除delete(刪除)只有一句之外
#
{"index":{"_index":"test","_type":"type1","_id":"1"}}
{"field1":"value1"}
#
{"create":{"_index":"test","_type":"type1","_id":"1"}}
{"field1":"value1"}
#區別
#index時會檢查_version。如果插入時沒有指定_version,那對於已有的doc,_version會遞增,並對文檔覆蓋。插入時如果指定_version,如果與已有的文檔_version不相等,則插入失敗,如果相等則覆蓋,_version遞增。 #create時也會檢查_version,但是對於已有的文檔,不會創建新文檔,即插入失敗。 {"delete":{"_index":"test","_type":"type1","_id":"1"}} # {"create":{"_index":"test","_type":"type1","_id":"1"}} {"docs":{"field1":"value2"}}

 

#添加案列
POST _bulk
{"index":{"_index":"lagou","_type":"job1","_id":"1"}}
{"title":"haha","salary":"2"}
{"index":{"_index":"lagou","_type":"job2","_id":"2"}}
{"title":"haha","salary":"100"}

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM