ElasticSearch基本操作有哪些

這篇文章主要介紹“ElasticSearch基本操作有哪些”，在日常操作中，相信很多人在ElasticSearch基本操作有哪些問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”ElasticSearch基本操作有哪些”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

1、_cat

GET /_cat/nodes: 查看所有節點
GET /_cat/health: 查看健康狀況
GET /_cat/master：查看主節點
GET /_cat/indices：查看所有索引 相當于mysql中的showdatabases

2、保存一個文檔

PUT customer/external/1；在customer索引（mysql中的數據庫）下的external類型（mysql中的表）下保存1號數據（唯一標識）為

PUT customer/external/1
{
  "name":"gison"
}

PUT和POST都可以，

POST新增：如果不指定id，會自動生成id。指定id就會修改這個數據，并新增版本號。

PUT可以新增可以修改。PUT必須指定id；由于PUT需要指定id，我們一般用來做修改操作，不指定id會報錯。

操作結果：

{
  "_index" : "customer",
  "_type" : "external",
  "_id" : "1",
  "_version" : 1,
  "result" : "created",
  "_shards" : {
    "total" : 2,
    "successful" : 1,
    "failed" : 0
  },
  "_seq_no" : 0,
  "_primary_term" : 1
}

3、查詢

GET customer/external/1

{
  "_index" : "customer",
  "_type" : "external",
  "_id" : "1",
  "_version" : 2,//版本號
  "_seq_no" : 1,//并發控制字段，每次更新就會+1，用來做樂觀鎖
  "_primary_term" : 1,//同上，主分片重新分配，如重啟，就會變化
  "found" : true,
  "_source" : {
    "name" : "gison"
  }
}

（新版本的es樂觀鎖控制用seq_no,老版本用version）

測試一下樂觀鎖

模擬兩個用戶A跟B都想改上面這條數據，A用戶查出if_seq_no=1，if_primary_term=1，執行更新

PUT customer/external/1?if_seq_no=1&if_primary_term=1
{
  "name":"鳴人"
}

B用戶同樣也查出if_seq_no=1，if_primary_term=1，隨后執行更新

PUT customer/external/1?if_seq_no=1&if_primary_term=1
{
  "name":"卡卡西"
}

A用戶執行結果

{
  "_index" : "customer",
  "_type" : "external",
  "_id" : "1",
  "_version" : 3,
  "result" : "updated",
  "_shards" : {
    "total" : 2,
    "successful" : 1,
    "failed" : 0
  },
  "_seq_no" : 2,
  "_primary_term" : 1
}

B用戶執行結果

{
  "error": {
    "root_cause": [
      {
        "type": "version_conflict_engine_exception",
        "reason": "[1]: version conflict, required seqNo [1], primary term [1]. current document has seqNo [2] and primary term [1]",
        "index_uuid": "XbVN6IayQTWbliz3cOOyGw",
        "shard": "0",
        "index": "customer"
      }
    ],
    "type": "version_conflict_engine_exception",
    "reason": "[1]: version conflict, required seqNo [1], primary term [1]. current document has seqNo [2] and primary term [1]",
    "index_uuid": "XbVN6IayQTWbliz3cOOyGw",
    "shard": "0",
    "index": "customer"
  },
  "status": 409
}

4、更新

 post帶_update

帶_update更新的時候，要加上doc，對比原來數據，與原來一樣就不做任何操作

POST customer/external/1/_update
{
  "doc": {
    "name":"gison"
  }
}

返回結果

{
  "_index" : "customer",
  "_type" : "external",
  "_id" : "1",
  "_version" : 7,
  "result" : "noop",
  "_shards" : {
    "total" : 0,
    "successful" : 0,
    "failed" : 0
  },
  "_seq_no" : 6,
  "_primary_term" : 1
}

post和put不帶_update，都不與前內容做對比

5、刪除

DELETE customer/external/1 // 刪除一條數據
DELETE customer //刪除索引

ES沒有提供刪除類型的操作

6、bulk批量api

POST customer/external/_bulk
{"delete": {"_index": "website", "_type": "blog", "_id": "123"}}
{"create": {"_index": "website", "_type": "blog", "_id": "123"}}
{"title": "first blog"}
{"index": {"_index": "website", "_type": "blog"}}
{"title": "second blog"}
{"update": {"_index": "website", "_type": "blog", "_id": "123"}}
{"doc":{"title": "update blog"}}

語法格式

{action：{metadata}}\n

{request body} \n

{action：{metadata}}\n

{request body} \n

index和create區別

index時會檢查_version。如果插入時沒有指定_version，那對于已有的doc，_version會遞增，并對文檔覆蓋。插入時如果指定_version，如果與已有的文檔_version不相等，則插入失敗，如果相等則覆蓋，_version遞增。

create時也會檢查_version，但是對于已有的文檔，不會創建新文檔，即插入失敗。

到此，關于“ElasticSearch基本操作有哪些”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續學習更多相關知識，請繼續關注億速云網站，小編會繼續努力為大家帶來更多實用的文章！