Elasticsearch CRUD

快来打我* 2022-12-26 11:27 189阅读 0赞

elasticsearch 对文档CRUD  
Bulk API  
mget  
msearch

### Create ###

Create 文档时，如果ID已经存在，会失败  
create document. 自动生成 \_id

POST users/_doc
    {
      "user" : "Mike",
      "post_date" : "2020-12-5",
      "message" : "trying out Kibana"
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70]

#create document, 指定Id，如果id已经存在，会报错
    PUT users/_doc/2?op_type=create
    {
      "user" : "Jack",
      "post_date" : "2020-12-5",
      "message" : "Elasticsearch"
    }

如果id不存在结果如下  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 1]  
如果id 存在则结果为  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 2]

### Read ###

Get the document by ID

GET users/_doc/2

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 3]

### Index ###

Index 可以理解为Create，但是Index的ID不存在时，创建新的文档。否则，先删除旧的文档，在创建新的文档，版本号会增加

PUT users/_doc/2
    {
      "user" : "Mike"
    }

(Index后 \_version 变为了3，Index了两次)  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 4]

### Update ###

update 在原文档上添加字段，文档必须已经存在，更新只会对相应的字段做增量修改

POST users/_update/2/
    {
      "doc": {
        "post_date": "2020-12-5 15:13",
        "message": "trying play CSGO"
      }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 5]

GET users/_doc/2

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 6]

### Delete ###

DELETE users/2

## Bulk API ##

Bulk API 支持在一次调用中，对不同的索引进行操作

支持四种类型的操作

*  Index
 *  Create
 *  Update
 *  Delete

可以在URI中指定 Index ，也可以在请求的 Payload 中进行

操作中单条操作失败时，并不会影响其他操作

返回结果包括了每一条操作执行的结果  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 7]

## 批量读取 - mget ##

> msearch

批量操作，可以减少网络连接所产生的开销，提高性能

GET _mget
    {
      "docs": [
        {
          "_index": "users",
          "_id": 1
        },
        {
          "_index": "users",
          "_id": 2
        }
        ]
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 8]

## ES API 常见错误返回 ##

<table> 
 <thead> 
  <tr> 
   <th>问题</th> 
   <th>原因</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>无法连接</td> 
   <td>网络故障或集群挂了</td> 
  </tr> 
  <tr> 
   <td>连接无法关闭</td> 
   <td>网络故障或节点出错</td> 
  </tr> 
  <tr> 
   <td>429</td> 
   <td>集群过于繁忙</td> 
  </tr> 
  <tr> 
   <td>4xx</td> 
   <td>请求体格式有错</td> 
  </tr> 
  <tr> 
   <td>500</td> 
   <td>集群内部错误</td> 
  </tr> 
 </tbody> 
</table>

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70]: /images/20221120/1f8d8f78184841848765e4c4574854e4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20201205170150144.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20201205170340400.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20201205170512123.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20201205170950735.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20201205171427565.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 6]: https://img-blog.csdnimg.cn/20201205171918656.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 7]: https://img-blog.csdnimg.cn/20201205173303165.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5_size_16_color_FFFFFF_t_70 8]: https://img-blog.csdnimg.cn/20201205173915462.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTY0Mzc5,size_16,color_FFFFFF,t_70