Elasticsearch REST API小记

Elasticsearch REST API小记

https://www.elastic.co/guide/en/elasticsearch/reference/current/_exploring_your_cluster.html

集群健康状态

[root@elastic1 ~]# curl 'http://192.168.8.101:9200/_cat/health?v'

epoch timestamp cluster status node.total node.data shards pri relo init unassign pending_tasks max_task_wait_time active_shards_percent

1462196271 21:37:51 elasticsearch_cluster green 1 1 0 0 0 0 0 0 - 100.0%

列出所有目录

[root@elastic1 ~]# curl 'http://192.168.8.101:9200/_cat/indices?v'

health status index pri rep docs.count docs.deleted store.size pri.store.size

创建Index

[root@elastic1 ~]# curl -XPUT 'http://192.168.8.101:9200/customer?pretty'

{

"acknowledged" : true

}

[root@elastic1 ~]# curl 'http://192.168.8.101:9200/_cat/indices?v'

health status index pri rep docs.count docs.deleted store.size pri.store.size

yellow open customer 5 1 0 0 650b 650b

提示:health为yellow, 是因为目前是单节点，等加入了replica之后就会转为green

查询Document

[root@elastic1 ~]# curl -XPUT 'http://192.168.8.101:9200/customer/external/1?pretty' -d '

{

"name": "John Doe"

{

"_index" : "customer",

"_type" : "external",

"_id" : "1",

"_version" : 1,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

"created" : true

}

[root@elastic1 ~]# curl -XGET 'http://192.168.8.101:9200/customer/external/1?pretty'

{

"_index" : "customer",

"_type" : "external",

"_id" : "1",

"_version" : 1,

"found" : true,

"_source" : {

"name" : "John Doe"

}

删除Index

https://www.elastic.co/guide/en/elasticsearch/reference/current/_delete_an_index.html

[root@elastic1 ~]# curl -XDELETE 'http://192.168.8.101:9200/customer?pretty'

{

"acknowledged" : true

}

[root@elastic1 ~]# curl 'http://192.168.8.101:9200/_cat/indices?v'

health status index pri rep docs.count docs.deleted store.size pri.store.size

修改数据

https://www.elastic.co/guide/en/elasticsearch/reference/current/_modifying_your_data.html

[root@elastic1 ~]# curl -XPUT 'http://192.168.8.101:9200/customer/external/1?pretty' -d '

{

"name": "John Doe"

{

"_index" : "customer",

"_type" : "external",

"_id" : "1",

"_version" : 1,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

"created" : true

}

[root@elastic1 ~]# curl -XPUT 'http://192.168.8.101:9200/customer/external/1?pretty' -d '

{

"name": "Michal Doe"

{

"_index" : "customer",

"_type" : "external",

"_id" : "1",

"_version" : 2,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

"created" : false

}

ID部分(上面标红的部分)是可选的，上面两条只会修改内容，不会新增，要新增需要不同的ID,如下

[root@elastic1 ~]# curl -XPUT 'http://192.168.8.101:9200/customer/external/2?pretty' -d '

{

"name": "Michal Doe"

{

"_index" : "customer",

"_type" : "external",

"_id" : "2",

"_version" : 1,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

"created" : true

}

采用POST方式时，没有指定ID，Elasticsearch会随机生成一个ID

[root@elastic1 ~]# curl -XPOST 'http://192.168.8.101:9200/customer/external?pretty' -d '

{

"name": "Jane Doe"

{

"_index" : "customer",

"_type" : "external",

"_id" : "AVRx1bl1UyCnWsdaj6t4",

"_version" : 1,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

"created" : true

}

[root@elastic1 ~]# curl 'http://192.168.8.101:9200/_cat/indices?v'

health status index pri rep docs.count docs.deleted store.size pri.store.size

yellow open customer 5 1 3 0 6.3kb 6.3kb

更新Document

[root@elastic1 ~]# curl -XPOST 'http://192.168.8.101:9200/customer/external/1/_update?pretty' -d '

{

"doc": { "name": "Jane Doe", "age": 20 }

{

"_index" : "customer",

"_type" : "external",

"_id" : "1",

"_version" : 3,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

}

https://www.elastic.co/guide/en/elasticsearch/reference/current/modules-scripting.html

也可以通过script来更新，前提是要先启用script

config/elasticsearch.yml中加入最简的两行即可，更严格的动作限制见官网说明

script.inline: true

script.indexed: true

[root@elastic1 ~]# curl -XPOST 'http://192.168.8.101:9200/customer/external/1/_update?pretty' -d '

{

"script" : "ctx._source.age += 5"

{

"_index" : "customer",

"_type" : "external",

"_id" : "1",

"_version" : 4,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

}

删除Document

[root@elastic1 ~]# curl -XDELETE 'http://192.168.8.101:9200/customer/external/2?pretty'

{

"found" : true,

"_index" : "customer",

"_type" : "external",

"_id" : "2",

"_version" : 2,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

}

提示:delete-by-query插件能删除所有匹配查询到的Document

批处理

[root@elastic1 ~]# curl -XPOST 'http://192.168.8.101:9200/customer/external/_bulk?pretty' -d '

{"index":{"_id":"1"}}

{"name": "John Doe" }

{"index":{"_id":"2"}}

{"name": "Jane Doe" }

{

"took" : 13,

"errors" : false,

"items" : [ {

"index" : {

"_index" : "customer",

"_type" : "external",

"_id" : "1",

"_version" : 5,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

"status" : 200

}

}, {

"index" : {

"_index" : "customer",

"_type" : "external",

"_id" : "2",

"_version" : 1,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

"status" : 201

}

} ]

}

[root@elastic1 ~]# curl -XPOST 'http://192.168.8.101:9200/customer/external/_bulk?pretty' -d '

{"update":{"_id":"1"}}

{"doc": { "name": "John Doe becomes Jane Doe" } }

{"delete":{"_id":"2"}}

{

"took" : 11,

"errors" : false,

"items" : [ {

"update" : {

"_index" : "customer",

"_type" : "external",

"_id" : "1",

"_version" : 6,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

"status" : 200

}

}, {

"delete" : {

"_index" : "customer",

"_type" : "external",

"_id" : "2",

"_version" : 2,

"_shards" : {

"total" : 2,

"successful" : 1,

"failed" : 0

"status" : 200,

"found" : true

}

} ]

}