经过一系列操作,终于可以开始操作 Elasticsearch 了,Elasticsearch 中的 API 遵循了 REST 风格,利用其提供的 REST API 可以管理索引,更改实例参数,检查节点和集群状态,并且对索引中的文档数据数据进行 CRUD 操作。
2.1 操作 index
索引相当于数据库,所以我们先来学习一下索引的基本操作。
(1)创建 index
创建索引一般使用 PUT 方法:
PUT /my-index-001
如果有定义 mapping,则可以在创建索引的同时带上 mapping:
PUT /my-index-002{ "mappings": { "properties": { "field1": { "type": "text" } } } }
同时,创建索引的时候还可以给索引创建别名:
PUT /my-index-003{ "mappings": { "properties": { "field1": { "type": "text" } } }, "aliases": { "alias_name": {} } }
有了别名之后,查询索引可以使用别名进行查询。
(2)索引别名有什么用
索引别名其实在某些场景的时候是非常有用的,比如当我们上线之后,如果因为某些业务变动,导致需要修改字段,那么这时候在 Elasticsearch 中就需要重建索引。重建索引的时候我们可以指定一个相同的别名,而如果我们的代码中就是通过别名进行查询时,这时候重建索引后就可以实现无缝衔接了。
(3)删除索引
删除索引采用 DELETE 方法。
DELETE /my-index-0001
(4)查询索引
查询索引信息采用 GET 方法,这个可以返回索引的 setting,mapping,aliases 以及分片等信息。
GET /my-index-001
(5)exist 索引
判断索引是否存在,采用的是 HEAD 方法。
HEAD /my-index-001
clone index
克隆索引之前,必须要先把一个索引改成只读(同时需保证集群状态为绿色):
PUT /my-index-004/_settings { "settings": { "index.blocks.write": true } }
改成只读后,就可以使用 POST 方法进行克隆索引:
POST /my-index-004/_clone/cloned-my-index-004
2.2 操作 document
学会了 index 的基本操作,接下来就就可以学习一下 document(数据) 的基本操作。
(1)插入 document
插入 document 采用的是 POST 方法:
PUT my-index-001/_create/1{ "@timestamp": "2099-11-15T13:12:00", "message": "GET /search HTTP/1.1 200 1070000", "user": { "id": "kimchy" } }
上面的语句中因为没有生成 id,所以 Elasticsearch 会自动生成一个 id 值。
插入指定 id 文档,则可以使用 _resource 语句:
PUT my-index-001/_create/1{ "@timestamp": "2099-11-15T13:12:00", "message": "GET /search HTTP/1.1 200 1070000", "user
或者指定 op_type=create:
PUT my-index-001/_doc/2?op_type=create { "@timestamp": "2099-11-15T13:12:00", "message": "GET /search HTTP/1.1 200 1070000", "user": { "id": "kimchy" } }
(2)查询 document
简单的查询语句可以使用 GET 方法:
GET /my-index-001/_search
查询之后得到如下结果(我们的源数据在 hits 里面,外面的字段是 Elasticsearch 自带的通用字段):
如果想只查询特定 id 文档则可以使用如下语句:
GET /my-index-001/_doc/1
而如果我们想指定返回字段或者指定不返回字段,则可以使用 _source 等参数(下面这句话则表示只返回 *.id 的字段且不返回 @timestamp 字段):
GET my-index-001/_doc/1?_source_includes=*.id&_source_excludes=@timestamp
有些有时候如果针对我们自己存储的字段,一个都不想返回,则可以使用如下语句:
GET my-index-001/_doc/1?_source=false
(3)删除 document
删除文档使用 DELETE 方法,删除语法为:DELETE /<index>/_doc/<_id>。
指定 id 删除,超时时间为 5 分钟:
DELETE /my-index-001/_doc/1?timeout=5m
如果想删除所有字段,则可以使用 delete_by_query 语句:
POST my-index-001/_delete_by_query { "query": { "match_all": {} } }
同样的,delete_by_query 也可以指定条件删除:
POST /my-index-001/_delete_by_query { "query": { "match": { "user.id": "elkbee" } } }
(4)更新 document
更新 document 一般使用 POST 方法,使用 _update 类型,下面我们来演示一个更新语句:
插入一条数据到 test 索引:
PUT test/_doc/1 { "name":"双子孤狼", "age":18, "address":"广东深圳"}
对 name 字段进行更新:
POST test/_update/1 { "doc": { "name": "智云盈嘉" } }
执行查询语句 GET test/_search 进行查询,则发现 name 字段已被更新
使用脚本更新 document
更新语句还可以使用 script 来实现更灵活的操作(如下则表示将 age 字段增加 4):
POST test/_update/1 { "script" : { "source": "ctx._source.age += params.count", "lang": "painless", "params" : { "count" : 4 } } }
和 delete_by_query 语句一样,更新语句也可以使用 update_by_query 语句:
POST test/_update_by_query { "script": { "source": "ctx._source.age += params.count", "lang": "painless", "params" : { "count" : 4 } }, "query": { "match": { "name": "智云盈嘉" } } }
elasticsearch:http://www.zhi-clouds.com/
2.1 操作 index
索引相当于数据库,所以我们先来学习一下索引的基本操作。
(1)创建 index
创建索引一般使用 PUT 方法:
PUT /my-index-001
如果有定义 mapping,则可以在创建索引的同时带上 mapping:
PUT /my-index-002{ "mappings": { "properties": { "field1": { "type": "text" } } } }
同时,创建索引的时候还可以给索引创建别名:
PUT /my-index-003{ "mappings": { "properties": { "field1": { "type": "text" } } }, "aliases": { "alias_name": {} } }
有了别名之后,查询索引可以使用别名进行查询。
(2)索引别名有什么用
索引别名其实在某些场景的时候是非常有用的,比如当我们上线之后,如果因为某些业务变动,导致需要修改字段,那么这时候在 Elasticsearch 中就需要重建索引。重建索引的时候我们可以指定一个相同的别名,而如果我们的代码中就是通过别名进行查询时,这时候重建索引后就可以实现无缝衔接了。
(3)删除索引
删除索引采用 DELETE 方法。
DELETE /my-index-0001
(4)查询索引
查询索引信息采用 GET 方法,这个可以返回索引的 setting,mapping,aliases 以及分片等信息。
GET /my-index-001
(5)exist 索引
判断索引是否存在,采用的是 HEAD 方法。
HEAD /my-index-001
clone index
克隆索引之前,必须要先把一个索引改成只读(同时需保证集群状态为绿色):
PUT /my-index-004/_settings { "settings": { "index.blocks.write": true } }
改成只读后,就可以使用 POST 方法进行克隆索引:
POST /my-index-004/_clone/cloned-my-index-004
2.2 操作 document
学会了 index 的基本操作,接下来就就可以学习一下 document(数据) 的基本操作。
(1)插入 document
插入 document 采用的是 POST 方法:
PUT my-index-001/_create/1{ "@timestamp": "2099-11-15T13:12:00", "message": "GET /search HTTP/1.1 200 1070000", "user": { "id": "kimchy" } }
上面的语句中因为没有生成 id,所以 Elasticsearch 会自动生成一个 id 值。
插入指定 id 文档,则可以使用 _resource 语句:
PUT my-index-001/_create/1{ "@timestamp": "2099-11-15T13:12:00", "message": "GET /search HTTP/1.1 200 1070000", "user
或者指定 op_type=create:
PUT my-index-001/_doc/2?op_type=create { "@timestamp": "2099-11-15T13:12:00", "message": "GET /search HTTP/1.1 200 1070000", "user": { "id": "kimchy" } }
(2)查询 document
简单的查询语句可以使用 GET 方法:
GET /my-index-001/_search
查询之后得到如下结果(我们的源数据在 hits 里面,外面的字段是 Elasticsearch 自带的通用字段):
如果想只查询特定 id 文档则可以使用如下语句:
GET /my-index-001/_doc/1
而如果我们想指定返回字段或者指定不返回字段,则可以使用 _source 等参数(下面这句话则表示只返回 *.id 的字段且不返回 @timestamp 字段):
GET my-index-001/_doc/1?_source_includes=*.id&_source_excludes=@timestamp
有些有时候如果针对我们自己存储的字段,一个都不想返回,则可以使用如下语句:
GET my-index-001/_doc/1?_source=false
(3)删除 document
删除文档使用 DELETE 方法,删除语法为:DELETE /<index>/_doc/<_id>。
指定 id 删除,超时时间为 5 分钟:
DELETE /my-index-001/_doc/1?timeout=5m
如果想删除所有字段,则可以使用 delete_by_query 语句:
POST my-index-001/_delete_by_query { "query": { "match_all": {} } }
同样的,delete_by_query 也可以指定条件删除:
POST /my-index-001/_delete_by_query { "query": { "match": { "user.id": "elkbee" } } }
(4)更新 document
更新 document 一般使用 POST 方法,使用 _update 类型,下面我们来演示一个更新语句:
插入一条数据到 test 索引:
PUT test/_doc/1 { "name":"双子孤狼", "age":18, "address":"广东深圳"}
对 name 字段进行更新:
POST test/_update/1 { "doc": { "name": "智云盈嘉" } }
执行查询语句 GET test/_search 进行查询,则发现 name 字段已被更新
使用脚本更新 document
更新语句还可以使用 script 来实现更灵活的操作(如下则表示将 age 字段增加 4):
POST test/_update/1 { "script" : { "source": "ctx._source.age += params.count", "lang": "painless", "params" : { "count" : 4 } } }
和 delete_by_query 语句一样,更新语句也可以使用 update_by_query 语句:
POST test/_update_by_query { "script": { "source": "ctx._source.age += params.count", "lang": "painless", "params" : { "count" : 4 } }, "query": { "match": { "name": "智云盈嘉" } } }
elasticsearch:http://www.zhi-clouds.com/