Elasticsearch 文档的基本CRUD与批量操作

• Elasticsearch 文档的基本CRUD与批量操作
  • 文档的 CRUD
  • Create 一个文档
    • 第一次调用
    • 第二次调用
    • 小结
  • Get 一个文档
    • 获取一个文档信息
  • 小结
  • Index 文档
  • Update 文档
  • Bulk API
  • 批量读取 mget
  • 批量查询 - msearch
  • 完整Demo
  • 常见问题错误

文档的 CRUD

• Type 名，约定都用 _doc
• Create - 如果ID已经存在，会失败
• Index - 如果ID不存在，创建新的文档。否则，先删除现有的文档，再创建新的文档，版本会增加
• Update - 文档必须已经存在，更新只会对相应字段做增量修改

Create 一个文档

PUT users/_create/1
{
     "user" : "Jack",
    "post_date" : "2020-08-23T14:40:12",
    "message" : "trying out Elasticsearch"
}

第一次调用

第二次调用

小结

• 支持自动生成文档ID和指定文档ID两种方式
• 通过调用 post /users/_doc
  • 系统会自动生成 document id
• 使用 HTTP PUT user/_create/1 创建时，URL中显示指定_create，此时如果该id已经存在，操作失败。

Get 一个文档

GET users/_doc/1

获取一个文档信息

小结

• 找到文档，返回 HTTP 200
  • _index/_type/
  • 版本信息，同一个ID的文档，即使被删除，Version 号也会不断增加
  • _scourc 中默认包含了文档的所有原始信息
• 找不到文档，返回 HTTP 404

Index 文档

PUT users/_doc/1
{
     "user" : "Bob He(MinYang He)"
}

• Index 和 Create 不一样的地方：如果文档不存在，就索引新的文档。否则现有的文档会被删除，新的文档被索引。版本信息 +1。

Update 文档

POST users/_update/1
{
     "doc" : {
         "albums":["Album1","Album2"]
    }
}

• Update 方法不会删除原有的文档，而是实现真正的数据更新。
• POST 方法 /PayLoad 需要包含在”doc”中

Bulk API

#执行第1次
POST _bulk
{ "index" : { "_index" : "test", "_id" : "1" } }
{ "field1" : "value1" }
{ "delete" : { "_index" : "test", "_id" : "2" } }
{ "create" : { "_index" : "test2", "_id" : "3" } }
{ "field1" : "value3" }
{ "update" : {"_id" : "1", "_index" : "test"} }
{ "doc" : {"field2" : "value2"} }

• 支持一次API调用中，对不同的索引进行操作
• 支持四种类型操作
  • index
  • Create
  • Update
  • Delete
• 可以在URL中指定Index，也可以在请求的Payload中进行
• 操作中单条操作失败，并不会影响其他操作
• 返回结果包括了每一条操作执行的结果

批量读取 mget

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

批量查询 - msearch

POST kibana_sample_data_ecommerce/_msearch
{}
{"query" : {"match_all" : {}},"size":1}
{"index" : "kibana_sample_data_flights"}
{"query" : {"match_all" : {}},"size":2}

完整Demo

• Create Document (auto ID generate)
• Get Document By Id
• Create Document (指定ID)
• Index Document
• Update Document

############Create Document############
#create document. 自动生成 _id
POST users/_doc
{
    "user" : "Mike",
    "post_date" : "2019-04-15T14:12:12",
    "message" : "trying out Kibana"
}
#create document. 指定Id。如果id已经存在，报错
PUT users/_doc/1?op_type=create
{
    "user" : "Jack",
    "post_date" : "2019-05-15T14:12:12",
    "message" : "trying out Elasticsearch"
}
#create document. 指定 ID 如果已经存在，就报错
PUT users/_create/1
{
     "user" : "Jack",
    "post_date" : "2019-05-15T14:12:12",
    "message" : "trying out Elasticsearch"
}
### Get Document by ID
#Get the document by ID
GET users/_doc/1
###  Index & Update
#Update 指定 ID  (先删除，在写入)
GET users/_doc/1
PUT users/_doc/1
{
    "user" : "Mike"
}
#GET users/_doc/1
#在原文档上增加字段
POST users/_update/1/
{
    "doc":{
        "post_date" : "2019-05-15T14:12:12",
        "message" : "trying out Elasticsearch"
    }
}
### Delete by Id
# 删除文档
DELETE users/_doc/1
### Bulk 操作
#执行两次，查看每次的结果
#执行第1次
POST _bulk
{ "index" : { "_index" : "test", "_id" : "1" } }
{ "field1" : "value1" }
{ "delete" : { "_index" : "test", "_id" : "2" } }
{ "create" : { "_index" : "test2", "_id" : "3" } }
{ "field1" : "value3" }
{ "update" : {"_id" : "1", "_index" : "test"} }
{ "doc" : {"field2" : "value2"} }
#执行第2次
POST _bulk
{ "index" : { "_index" : "test", "_id" : "1" } }
{ "field1" : "value1" }
{ "delete" : { "_index" : "test", "_id" : "2" } }
{ "create" : { "_index" : "test2", "_id" : "3" } }
{ "field1" : "value3" }
{ "update" : {"_id" : "1", "_index" : "test"} }
{ "doc" : {"field2" : "value2"} }
### mget 操作
GET /_mget
{
    "docs" : [
        {
            "_index" : "test",
            "_id" : "1"
        },
        {
            "_index" : "test",
            "_id" : "2"
        }
    ]
}
#URI中指定index
GET /test/_mget
{
    "docs" : [
        {
            "_id" : "1"
        },
        {
            "_id" : "2"
        }
    ]
}
GET /_mget
{
    "docs" : [
        {
            "_index" : "test",
            "_id" : "1",
            "_source" : false
        },
        {
            "_index" : "test",
            "_id" : "2",
            "_source" : ["field3", "field4"]
        },
        {
            "_index" : "test",
            "_id" : "3",
            "_source" : {
                "include": ["user"],
                "exclude": ["user.location"]
            }
        }
    ]
}
### msearch 操作
POST kibana_sample_data_ecommerce/_msearch
{}
{"query" : {"match_all" : {}},"size":1}
{"index" : "kibana_sample_data_flights"}
{"query" : {"match_all" : {}},"size":2}
### 清除测试数据
#清除数据
DELETE users
DELETE test
DELETE test2

常见问题错误