导入数据并搜索
前提条件
开通百度智能云Elasticsearch服务（参考创建集群）且可访问Elasticsearch集群（参考访问Elasticsearch服务）后，可以通过附赠的kibana节点访问Elasticsearch集群，然后可以创建索引、导入数据和搜索数据。
创建索引
在导入数据之前，可以评估shard和创建索引，以下示例创建一个名称为index_name的索引。
1PUT index_name
2{
3 "settings": {
4 "index": {
5 "number_of_shards": 1,
6 "number_of_replicas": 1
7 }
8 }
9}其中，number_of_shards指主分片数，number_of_replicas指每个主分片有多少个副本分片数。Elasticsearch 7.0以下版本默认创建5个主分片和1个副本分片，Elasticsearch 7.0及以上版本默认创建1个主分片和1个副本分片。主分片数只能在索引创建前指定，且索引创建后不能动态修改，只能通过reindex或split等方式达到修改目的，副本分片数可以动态修改。
创建成功，返回如下结果。
1{
2 "acknowledged" : true,
3 "shards_acknowledged" : true,
4 "index" : "index_name"
5}返回结果各个字段的含义如下所示。
| 返回字段 | 含义 |
|---|---|
| acknowledged | 索引在集群中是否创建成功 |
| shards_acknowledged | 每个分片组在超时之前是否激活了所需数量的分片 |
| index | 索引名称 |
注：返回值中acknowledged或者shards_acknowledged为false时，索引创建操作仍然可能成功，这两个值只是表示操作是否在超时之前完成。假设acknowledged为false，新创建的索引更新集群状态时超时，创建索引操作仍然可能会在之后执行成功。假设shards_acknowledged为false，新创建的索引成功更新集群状态，但激活所需数量的分片超时，默认只启动主分片。
导入数据
导入单条数据
以下示例创建单个文档并导入数据。
1PUT index_name/_doc/1
2{
3 "name": "Amber Adams",
4 "age": 32
5}导入数据成功，返回如下结果。
1{
2 "_index" : "index_name",
3 "_type" : "_doc",
4 "_id" : "1",
5 "_version" : 1,
6 "result" : "created",
7 "_shards" : {
8 "total" : 2,
9 "successful" : 1,
10 "failed" : 0
11 },
12 "_seq_no" : 0,
13 "_primary_term" : 1
14}返回结果各个字段的含义如下所示。
| 返回字段 | 含义 |
|---|---|
| index | 索引名称 |
| _type | 文档类型 |
| _id | 文档唯一标识符 |
| _version | 文档版本，每次更新文档，版本都会增加 |
| result | 操作结果 |
| _shards | 被操作的分片总数量、成功数量、失败数量 |
| _seq_no | 文档序列号，序列号用于确保旧版本文档不会覆盖新版本 |
| _primary_term | 主项 |
可以使用如下命令查询数据来进行验证。
1GET index_name/_search
2{
3"query": { "match_all": {} }
4}导入多条数据
以下示例使用_bulk API创建多个文档并导入数据。
1POST _bulk
2{"index":{"_index": "index_name", "_id": 2}}
3{"name": "Fulton Rich","age": 40}
4{"index":{"_index": "index_name", "_id": 3}}
5{"name": "Virginia Ayala", "age": 12}
6{"index":{"_index": "index_name", "_id": 4}}
7{"name": "Mcgee Mooney", "age": 23}
8{"index":{"_index": "index_name", "_id": 5}}
9{"name": "Burton Meyers", "age": 60}可以使用如下命令查询插入的数据来进行验证。
1GET index_name/_search
2{
3"query": { "match_all": {} }
4}搜索数据
向集群导入数据之后，可以进行数据搜索，比如查询索引、全文搜索、按条件搜索等。
查询索引
如下命令查询集群的所有索引。
1GET _cat/indices?v查询结果如下所示。
1health status index uuid pri rep docs.count docs.deleted store.size pri.store.size
2green open index_name GKL71ejiT0CyqJZgVgkMjA 3 1 5 0 11.2kb 11.2kb查询结果各个字段的含义如下所示。
| 返回字段 | 含义 |
|---|---|
| health | 索引健康状态 |
| status | 索引的开启状态 |
| index | 索引名称 |
| uuid | 索引uuid |
| pri | 索引主分片数 |
| rep | 索引副本分片数量 |
| docs.count | 索引中文档总数 |
| docs.deleted | 索引中删除状态的文档 |
| store.size | 主分片+副本分片的大小 |
| pri.store.size | 主分片的大小 |
全文搜索
如下命令搜索name包含Ayala的文档数据。
1GET index_name/_search
2{
3 "query": {
4 "match": {
5 "name": "Ayala"
6 }
7 }
8}搜索结果如下所示。
1{
2 "took" : 10,
3 "timed_out" : false,
4 "_shards" : {
5 "total" : 3,
6 "successful" : 3,
7 "skipped" : 0,
8 "failed" : 0
9 },
10 "hits" : {
11 "total" : {
12 "value" : 1,
13 "relation" : "eq"
14 },
15 "max_score" : 0.9808292,
16 "hits" : [
17 {
18 "_index" : "index_name",
19 "_type" : "_doc",
20 "_id" : "3",
21 "_score" : 0.9808292,
22 "_source" : {
23 "name" : "Virginia Ayala",
24 "age" : 12
25 }
26 }
27 ]
28 }
29}搜索结果各个字段的含义如下所示。
| 返回字段 | 含义 |
|---|---|
| took | 执行搜索耗时，单位为毫秒 |
| time_out | 搜索是否超时 |
| _shards | 多少分片被搜索，成功多少，跳过多少，失败多少 |
| hits | 搜索结果展示 |
| hits.total | 匹配条件的文档总数 |
| hits.max_score | 最大匹配得分 |
| hits._score | 返回文档的匹配得分（得分越高，匹配程度越高，越靠前） |
| hits.hits | 返回结果展示 |
按条件搜索
如下命令搜索age在20-30岁之间(闭区间)的文档数据。
1GET index_name/_search
2{
3 "query": {
4 "range": {
5 "age": {
6 "gte": 20,
7 "lte": 30
8 }
9 }
10 }
11}搜索结果如下所示。
1{
2 "took" : 18,
3 "timed_out" : false,
4 "_shards" : {
5 "total" : 3,
6 "successful" : 3,
7 "skipped" : 0,
8 "failed" : 0
9 },
10 "hits" : {
11 "total" : {
12 "value" : 1,
13 "relation" : "eq"
14 },
15 "max_score" : 1.0,
16 "hits" : [
17 {
18 "_index" : "index_name",
19 "_type" : "_doc",
20 "_id" : "4",
21 "_score" : 1.0,
22 "_source" : {
23 "name" : "Mcgee Mooney",
24 "age" : 23
25 }
26 }
27 ]
28 }
29}搜索结果各个字段的含义同上。