版本PHP 操作 elasticsearch 的索引，文档php版本: 7.1.9ElasticSearch版本:7.8.1ElasticSearch-PHP根据 PHP 版本选择对应的 ElasticSearch-PHP 版本PHP 安装
PHP 操作 elasticsearch 的索引，文档
php版本: 7.1.9
ElasticSearch版本:7.8.1
根据 PHP 版本选择对应的 ElasticSearch-PHP 版本
compose 安装 ElasticSearch-PHP
composer require elasticsearch/elasticsearch创建 ElasticSearch 客户端
$params = [
'host' => "127.0.0.1:9200"
];
//设置主机，并设置重连次数
$client = ClientBuilder::create()->setHosts($params)->setRetries(2)->build();创建一个 users 索引，并添加字段映射
$params = [
'host' => "127.0.0.1:9200"
];
//设置主机，并设置重连次数
$client = ClientBuilder::create()->setHosts($params)->setRetries(2)->build();
$indexCreateParams = [
'index' => 'users', //定义索引名字
'body' => [
'settings' => [
'number_of_shards' => 3, //设置索引分片数量
'number_of_replicas' => 2 //设置索引副本数量
],
'mappings' => [
'properties' => [
'name' => [
'type' => 'keyWord',
'index' => true, //可以被索引
],
'age' => [
'type' => 'integer'
],
'mobile' => [
'type' => 'text',
'index' => 'true',
],
'email' => [
'type' => 'text',
'index' => 'true',
],
'address' => [
'type' => 'text',
'index' => true,
'analyzer' => 'ik_max_word' //使用ik分词器进行分词
],
'desc' => [
'type' => 'text',
'index' => true,
'analyzer' => 'ik_max_word'
]
]
]
]
];
$res = $client->indices()->create($indexCreateParams);
dd($res); //获取字段映射
$res = $client->indices()->getMapping([
'index' => 'users'
]);
dd($res);
------------------------------返回结果-----------------------------------
array:1 [
"users" => array:1 [
"mappings" => array:1 [
"properties" => array:6 [
"address" => array:2 [
"type" => "text"
"analyzer" => "ik_max_word"
]
"age" => array:1 [
"type" => "integer"
]
"desc" => array:2 [
"type" => "text"
"analyzer" => "ik_max_word"
]
"email" => array:1 [
"type" => "text"
]
"mobile" => array:1 [
"type" => "text"
]
"name" => array:1 [
"type" => "keyword"
]
]
]
]
]获取索引设置信息
//获取设置信息
$setting = $client->indices()->getSettings([
'index' => 'users'
]);
dd($setting);
---------------------------------返回结果------------------------------------
array:1 [
"users" => array:1 [
"settings" => array:1 [
"index" => array:6 [
"creation_date" => "1630484859730"
"number_of_shards" => "3"
"number_of_replicas" => "2"
"uuid" => "IbvJ_CgtT3monuB8IyEPTQ"
"version" => array:1 [
"created" => "7080199"
]
"provided_name" => "users"
]
]
]
] $params = [
'index' => 'users',
'body' => [
'settings' => [
'number_of_replicas' => 1,//更改索引的副本为 1
]
]
];
$res = $client->indices()->putSettings($params);
dd($res);ElasticSearch 是不支持索引字段类型变更的，原因是一个字段的类型进行修改之后，ES 会重新建立对这个字段的索引信息，影响到ES对该字段分词方式，相关度，TF/IDF倒排创建等
$param = [
'index' => 'users'
];
$res = $client->indices()->delete($param);
dd($res); $params = [
'index' => 'users',
'id' => 1, //指定文档生成的id,如果不指定，则 es 自动生成
'body' => [
'name' => '张三',
'age' => 21,
'mobile' => '16621111111',
'email' => "16621111111@qq.com",
'address' => '北京-西二旗',
'desc' => '一个技术宅男,强迫症，爱好美食，电影'
]
];
$res = $client->index($params);
dd($res);
-------------------------返回结果----------------------------
array:8 [
"_index" => "users"
"_type" => "_doc"
"_id" => "1"
"_version" => 1
"result" => "created"
"_shards" => array:3 [
"total" => 3
"successful" => 1
"failed" => 0
]
"_seq_no" => 0
"_primary_term" => 1
] $data = [
['name' => '李四', 'age' => '22', 'mobile' => '16622222222','email' => '16622222222@qq.com', 'address' => '上海-闵行', 'desc' => '运动，动漫，游戏，电影'],
['name' => '王五', 'age' => '22', 'mobile' => '16622222223','email' => '16622222223@qq.com', 'address' => '上海-浦东', 'desc' => '运动，日漫，电影，技术控'],
['name' => '赵六', 'age' => '20', 'mobile' => '16622222224','email' => '16622222224@qq.com', 'address' => '上海-长宁', 'desc' => '宅男，小说，游戏，睡觉'],
['name' => '李华', 'age' => '23', 'mobile' => '16622222225','email' => '16622222225@qq.com', 'address' => '上海-宝山', 'desc' => '运动，小说，睡觉'],
];
foreach ($data as $k => $document) {
$params['body'][] = [
'index' => [
'_index' => 'users',
'_id' => $k+1
]
];
$params['body'][] = $document;
}
$res = $client->bulk($params);
dd($res);Elasticsearch 提供实时获取文档的方法。这意味着只要文档被索引且客户端收到消息确认后，你就可以立即在任何的分片中检索文档。Get 操作通过 index/type/id 方式请求一个文档信息：
$params = [
'index' => 'users',
'id' => 1
];
$res = $client->get($params);
dd($res);
-------------------------------返回结果--------------------------------
array:8 [
"_index" => "users"
"_type" => "_doc"
"_id" => "1"
"_version" => 2
"_seq_no" => 1
"_primary_term" => 1
"found" => true
"_source" => array:6 [
"name" => "李四"
"age" => "22"
"mobile" => "16622222222"
"email" => "16622222222@qq.com"
"address" => "上海-闵行"
"desc" => "运动，动漫，游戏，电影"
]
]如果你要部分更新文档（如更改现存字段 或 添加新字段），你可以在 body 参数中指定一个 doc 参数。这样 doc 参数内的字段会与现存字段进行合并。
$params = [
'index' => 'users',
'id' => 1, //对id为1的记录修改
'body' => [
'doc' => [
'age' => 19, //修改年龄为19
'mobile' => '16633333334' //修改手机号
],
],
];
$res = $client->update($params);
dd($res);
----------------------------再次查询id=1记录--------------------------------
array:8 [
"_index" => "users"
"_type" => "_doc"
"_id" => "1"
"_version" => 4
"_seq_no" => 3
"_primary_term" => 1
"found" => true
"_source" => array:6 [
"name" => "李四"
"age" => 19
"mobile" => "16633333334"
"email" => "16622222222@qq.com"
"address" => "上海-闵行"
"desc" => "运动，动漫，游戏，电影"
]
]可以通过id进行删除
$params = [
'index' => 'users',
'id' => 1,
];
$res = $client->delete($params);
dd($res); $params = [
'index' => 'users',
];
$res = $client->search($params);
dd($res);
--------------------------------返回结果-------------------------------
array:4 [
"took" => 0 //查询花费时间，单位毫秒
"timed_out" => false //是否超时
"_shards" => array:4 [ //分片信息
"total" => 3 //分片总数
"successful" => 3 //成功
"skipped" => 0 //忽略
"failed" => 0 //失败
]
"hits" => array:3 [ //搜索命中结果
"total" => array:2 [ //搜索条件匹配的文档总数
"value" => 3 //总命中计数的值
"relation" => "eq" //计数规则 eq 标识计数准确，gte 标识计数不准确
]
"max_score" => 1.0 //匹配度分支
"hits" => array:3 [ //命中结果集合
0 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "2"
"_score" => 1.0
"_source" => array:6 [
"name" => "王五"
"age" => "22"
"mobile" => "16622222223"
"email" => "16622222223@qq.com"
"address" => "上海-浦东"
"desc" => "运动，日漫，电影，技术控"
]
]
1 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "3"
"_score" => 1.0
"_source" => array:6 [
"name" => "赵六"
"age" => "20"
"mobile" => "16622222224"
"email" => "16622222224@qq.com"
"address" => "上海-长宁"
"desc" => "宅男，小说，游戏，睡觉"
]
]
2 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "4"
"_score" => 1.0
"_source" => array:6 [
"name" => "李华"
"age" => "23"
"mobile" => "16622222225"
"email" => "16622222225@qq.com"
"address" => "上海-宝山"
"desc" => "运动，小说，睡觉"
]
]
]
]
]match 匹配类型查询，Es 先把查询条件进行分词，然后依据分词进行查询，多个词条之间是 or 的关系
$params = [
'index' => 'users',
'body' => [
'query' => [
//match 会先把查询条件进行分词
'match' => [
//desc 的类型是text,进行分词查询，所以查询的时候会先分词成 运动，电影，技术控等词组，然后依据词组进行匹配
'desc' => '运动，日漫，电影，技术控'
]
]
]
];
$res = $client->search($params);
dd($res);
--------------------------返回结果----------------------------
array:4 [
"took" => 3
"timed_out" => false
"_shards" => array:4 [
"total" => 3
"successful" => 3
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 2
"relation" => "eq"
]
"max_score" => 4.811739
"hits" => array:2 [
0 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "2"
"_score" => 4.811739
"_source" => array:6 [
"name" => "王五"
"age" => "22"
"mobile" => "16622222223"
"email" => "16622222223@qq.com"
"address" => "上海-浦东"
"desc" => "运动，日漫，电影，技术控" //es在存储的时候会进行分词，此次查询匹配上了运动这个词组
]
]
1 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "4"
"_score" => 0.5504225
"_source" => array:6 [
"name" => "李华"
"age" => "23"
"mobile" => "16622222225"
"email" => "16622222225@qq.com"
"address" => "上海-宝山"
"desc" => "运动，小说，睡觉"
]
]
]
]
]term 查询，精确的关键词匹配查询，不对查询条件进行分词
$params = [
'index' => 'users',
'body' => [
'query' => [
'term' => [
//不会对 运动 进行分词操作，而是直接使用 运动 进行匹配查找
'desc' => '运动'
]
]
]
];
$res = $client->search($params);
dd($res);
--------------------------------结果---------------------------------
array:4 [
"took" => 0
"timed_out" => false
"_shards" => array:4 [
"total" => 3
"successful" => 3
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 2
"relation" => "eq"
]
"max_score" => 0.5504225
"hits" => array:2 [
0 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "4"
"_score" => 0.5504225
"_source" => array:6 [
"name" => "李华"
"age" => "23"
"mobile" => "16622222225"
"email" => "16622222225@qq.com"
"address" => "上海-宝山"
"desc" => "运动，小说，睡觉" //es存储的倒排索引中有运动这个分词词组，所以可以匹配上
]
]
1 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "2"
"_score" => 0.42081726
"_source" => array:6 [
"name" => "王五"
"age" => "22"
"mobile" => "16622222223"
"email" => "16622222223@qq.com"
"address" => "上海-浦东"
"desc" => "运动，日漫，电影，技术控"
]
]
]
]
]多关键字精确查询terms 查询和 term 查询一样，但它允许你指定多值进行匹配。
如果这个字段包含了指定值中的任何一个值，那么这个文档满足条件，类似于 Mysql 的 in
$params = [
'index' => 'users',
'body' => [
'query' => [
'terms' => [
//不会对 运动 进行分词操作，而是直接使用 运动 进行匹配查找
'desc' => ['运动', '游戏']
]
]
]
];
$res = $client->search($params);
dd($res);
---------------------------------结果-----------------------------
array:4 [
"took" => 2
"timed_out" => false
"_shards" => array:4 [
"total" => 3
"successful" => 3
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 3
"relation" => "eq"
]
"max_score" => 1.0
"hits" => array:3 [
0 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "2"
"_score" => 1.0
"_source" => array:6 [
"name" => "王五"
"age" => "22"
"mobile" => "16622222223"
"email" => "16622222223@qq.com"
"address" => "上海-浦东"
"desc" => "运动，日漫，电影，技术控" //包含 运动
]
]
1 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "3"
"_score" => 1.0
"_source" => array:6 [
"name" => "赵六"
"age" => "20"
"mobile" => "16622222224"
"email" => "16622222224@qq.com"
"address" => "上海-长宁"
"desc" => "宅男，小说，游戏，睡觉" //包含 游戏
]
]
2 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "4"
"_score" => 1.0
"_source" => array:6 [
"name" => "李华"
"age" => "23"
"mobile" => "16622222225"
"email" => "16622222225@qq.com"
"address" => "上海-宝山"
"desc" => "运动，小说，睡觉" //包含 运动
]
]
]
]
]bool把各种其它查询通过must（必须 ）、must_not（必须不）、should（应该）的方式进行组合
| 语句 | 情况 |
|---|---|
| 多个 must | 查询 must 的交集 |
| must + should | 查询 must 交集，如果交集里面包含 should 的部分，则增加打分 |
| must + must_not | 查询 must 交集，但是会排除 must_not 条件 |
| 多个 should | 查询 should 的并集，也就是 a = 1 or a = 2 |
| should + must_not | should 的并集，并排除 must_not 的部分 |
| must + must_not + should | must 交集，并排除 must_not 部分，返回结果里面有 should 部分，会增加打分 |
//查询 desc 包含 小说，运动的词组，但是排除年龄是20的，排除之后的结果集中如果名字 = 李华，则增加 _score 分数
$params = [
'index' => 'users',
'body' => [
'query' => [
'bool' => [
'must' => [
[
'match' => [
'desc' => '小说'
]
],
[
'term' => [
'desc' => '运动'
]
]
],
'must_not' => [
[
'term' => [
'age' => '20'
]
]
],
'should' => [
[
'term' => [
'name' => '李华'
]
]
]
]
]
]
];
$res = $client->search($params);
dd($res);
------------------------------------返回结果---------------------------------
array:4 [
"took" => 8
"timed_out" => false
"_shards" => array:4 [
"total" => 3
"successful" => 3
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 1
"relation" => "eq"
]
"max_score" => 2.081674
"hits" => array:1 [
0 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "4"
"_score" => 2.081674 //没有加 should 的分数 = 1.100845，加完 should 分值直接提高 1
"_source" => array:6 [
"name" => "李华"
"age" => "23" //年龄不等于20
"mobile" => "16622222225"
"email" => "16622222225@qq.com"
"address" => "上海-宝山"
"desc" => "运动，小说，睡觉" //包含小说，运动 词组
]
]
]
]
]默认情况下，Elasticsearch 在搜索的结果中，会把文档中保存在 _source 的所有字段都返回。
如果我们只想获取其中的部分字段，我们可以添加_source 的过滤
$params = [
'index' => 'users',
'_source' => ['name', 'desc'], //只返回 _source 保存的 name,desc 字段
'body' => [
'query' => [
'terms' => [
//不会对 运动 进行分词操作，而是直接使用 运动 进行匹配查找
'desc' => ['运动', '游戏']
]
]
]
];
$res = $client->search($params);
dd($res);
------------------------------------结果-----------------------------------
array:4 [
"took" => 0
"timed_out" => false
"_shards" => array:4 [
"total" => 3
"successful" => 3
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 3
"relation" => "eq"
]
"max_score" => 1.0
"hits" => array:3 [
0 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "2"
"_score" => 1.0
"_source" => array:2 [
"name" => "王五"
"desc" => "运动，日漫，电影，技术控"
]
]
1 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "3"
"_score" => 1.0
"_source" => array:2 [
"name" => "赵六"
"desc" => "宅男，小说，游戏，睡觉"
]
]
2 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "4"
"_score" => 1.0
"_source" => array:2 [
"name" => "李华"
"desc" => "运动，小说，睡觉"
]
]
]
]
]range 查询找出那些落在指定区间内的数字或者时间。range 查询允许以下字符
| 符号 | 说明 |
|---|---|
| gt | > |
| gte | >= |
| lt | < |
| lte | <= |
//查询年龄大于20小于30的数据
$params = [
'index' => 'users',
'body' => [
'query' => [
'range' => [
'age' => [
'gt' => 20,
'lt' => 30
]
]
]
]
];
$res = $client->search($params);
dd($res);
----------------------------------结果---------------------------------
array:4 [
"took" => 0
"timed_out" => false
"_shards" => array:4 [
"total" => 3
"successful" => 3
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 2
"relation" => "eq"
]
"max_score" => 1.0
"hits" => array:2 [
0 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "2"
"_score" => 1.0
"_source" => array:6 [
"name" => "王五"
"age" => "22"
"mobile" => "16622222223"
"email" => "16622222223@qq.com"
"address" => "上海-浦东"
"desc" => "运动，日漫，电影，技术控"
]
]
1 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "4"
"_score" => 1.0
"_source" => array:6 [
"name" => "李华"
"age" => "23"
"mobile" => "16622222225"
"email" => "16622222225@qq.com"
"address" => "上海-宝山"
"desc" => "运动，小说，睡觉"
]
]
]
]
]sort 可以让我们按照不同的字段进行排序，并且通过 order 指定排序的方式。desc 降序，asc升序。
根据年龄进行排序
$params = [
'index' => 'users',
'body' => [
'query' => [
'match' => [
'desc' => '运动,小说'
]
],
'sort' => [
[
'age' => [
'order' => 'desc'
]
]
]
],
];
----------------------------------------结果--------------------------------
array:4 [
"took" => 9
"timed_out" => false
"_shards" => array:4 [
"total" => 3
"successful" => 3
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 3
"relation" => "eq"
]
"max_score" => null
"hits" => array:3 [
0 => array:6 [
"_index" => "users"
"_type" => "_doc"
"_id" => "4"
"_score" => null
"_source" => array:6 [
"name" => "李华"
"age" => "23"
"mobile" => "16622222225"
"email" => "16622222225@qq.com"
"address" => "上海-宝山"
"desc" => "运动，小说，睡觉"
]
"sort" => array:1 [
0 => 23
]
]
1 => array:6 [
"_index" => "users"
"_type" => "_doc"
"_id" => "2"
"_score" => null
"_source" => array:6 [
"name" => "王五"
"age" => "22"
"mobile" => "16622222223"
"email" => "16622222223@qq.com"
"address" => "上海-浦东"
"desc" => "运动，日漫，电影，技术控"
]
"sort" => array:1 [
0 => 22
]
]
2 => array:6 [
"_index" => "users"
"_type" => "_doc"
"_id" => "3"
"_score" => null
"_source" => array:6 [
"name" => "赵六"
"age" => "20"
"mobile" => "16622222224"
"email" => "16622222224@qq.com"
"address" => "上海-长宁"
"desc" => "宅男，小说，游戏，睡觉"
]
"sort" => array:1 [
0 => 20
]
]
]
]
]多个字段排序，先根据年龄进行排序，如果年龄相等，在根据 _score 分数排序
$params = [
'index' => 'users',
'body' => [
'query' => [
'match' => [
'desc' => '运动,小说'
]
],
'sort' => [
[
'age' => [
'order' => 'desc'
]
],
[
'_score' => [
'order' => "desc"
]
]
]
],
];
$res = $client->search($params);
dd($res);
--------------------------------结果-------------------------------------
array:4 [
"took" => 1
"timed_out" => false
"_shards" => array:4 [
"total" => 3
"successful" => 3
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 4
"relation" => "eq"
]
"max_score" => null
"hits" => array:4 [
0 => array:6 [
"_index" => "users"
"_type" => "_doc"
"_id" => "4"
"_score" => 1.100845
"_source" => array:6 [
"name" => "李华"
"age" => "23"
"mobile" => "16622222225"
"email" => "16622222225@qq.com"
"address" => "上海-宝山"
"desc" => "运动，小说，睡觉"
]
"sort" => array:2 [
0 => 23
1 => 1.100845
]
]
1 => array:6 [
"_index" => "users"
"_type" => "_doc"
"_id" => "2"
"_score" => 0.42081726 //和韩梅梅的年龄相等，依据 分数进行排序
"_source" => array:6 [
"name" => "王五"
"age" => "22"
"mobile" => "16622222223"
"email" => "16622222223@qq.com"
"address" => "上海-浦东"
"desc" => "运动，日漫，电影，技术控"
]
"sort" => array:2 [
0 => 22
1 => 0.42081726
]
]
2 => array:6 [
"_index" => "users"
"_type" => "_doc"
"_id" => "1"
"_score" => 0.2876821
"_source" => array:6 [
"name" => "韩梅梅"
"age" => "22"
"mobile" => "16622222278"
"email" => "16622222278@qq.com"
"address" => "上海-闵行"
"desc" => "运动，美食，游戏，电影"
]
"sort" => array:2 [
0 => 22
1 => 0.2876821
]
]
3 => array:6 [
"_index" => "users"
"_type" => "_doc"
"_id" => "3"
"_score" => 0.45665967
"_source" => array:6 [
"name" => "赵六"
"age" => "20"
"mobile" => "16622222224"
"email" => "16622222224@qq.com"
"address" => "上海-长宁"
"desc" => "宅男，小说，游戏，睡觉"
]
"sort" => array:2 [
0 => 20
1 => 0.45665967
]
]
]
]
]from：当前页的起始索引，默认从 0 开始。 from = (pageNum - 1) * size
size：每页显示多少条
$params = [
'index' => 'users',
'body' => [
'from' => 0, //从0开始
'size' => 1 //查询1条数据
],
];
$res = $client->search($params);
dd($res);
---------------------------结果---------------------------------------
array:4 [
"took" => 7
"timed_out" => false
"_shards" => array:4 [
"total" => 3
"successful" => 3
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 4
"relation" => "eq"
]
"max_score" => 1.0
"hits" => array:1 [
0 => array:5 [
"_index" => "users"
"_type" => "_doc"
"_id" => "2"
"_score" => 1.0
"_source" => array:6 [
"name" => "王五"
"age" => "22"
"mobile" => "16622222223"
"email" => "16622222223@qq.com"
"address" => "上海-浦东"
"desc" => "运动，日漫，电影，技术控"
]
]
]
]
]ElasticSearch除了致力于搜索之外，也提供了聚合实时分析数据的功能,它的实时性高,所有的计算结果都是即时返回。
聚合的两个主要的概念，分别是 桶 和 指标
桶(Buckets): 简单来说就是满足特定条件的文档的集合。类似sql中的GROUP BY语法
当聚合开始被执行，每个文档会决定符合哪个桶的条件，如果匹配到，文档将放入相应的桶并接着进行聚合操作
桶可以被嵌套在其他桶里面,像是北京能放在中国桶裡，而中国桶能放在亚洲桶裡
指标(Metrics) : 对桶内的文档进行统计计算(如计算最大值、最小值、平均值等等)
桶能让我们划分文档到有意义的集合， 但是最终我们需要的是对这些桶内的文档进行一些指标的计算
指标通常是简单的数学运算(像是min、max、avg、sum），而这些是通过当前桶中的文档的值来计算的，利用指标能让你计算像平均薪资、最高出售价格、95%的查询延迟这样的数据
PHP 中聚合的格式大致为:
$params = [
'index' => 'employees',
'body' => [
//查询 age 最大的是多少岁
'aggs' => [ //es 聚合操作关键字 aggs 或者 aggregations 都可以
'age_max' => [ //es 返回的字段名称,自己随意定义
"max" => [ // 聚合的类型，关键词
'field' => 'age' //对哪个字段进行聚合
]
]
],
],
];创建案列数据
创建 employees 索引
$indexCreateParams = [
'index' => 'employees', //创建一个员工表
'body' => [
'mappings' => [
'properties' => [
'name' => [
'type' => 'keyword'
],
'age' => [
'type' => 'integer'
],
'gender' => [
'type' => 'keyword'
],
'job' => [
'type' => 'text',
'fields' => [
//设置字段能关键词搜索及数据聚合.
'keyword' => [
'type' => 'keyword',
'ignore_above' => 50
]
]
],
'salary' => [
'type' => 'integer'
]
]
]
]
];
$res = $client->indices()->create($indexCreateParams);
dd($res);添加文档数据
$data = [
['name' => '张三', 'age' => 20, 'gender' => '男', 'job' => 'PHP', 'salary' => '1000'],
['name' => '李四', 'age' => 25, 'gender' => '男', 'job' => 'PHP', 'salary' => '2500'],
['name' => '王五', 'age' => 26, 'gender' => '男', 'job' => 'PHP', 'salary' => '2600'],
['name' => '赵六', 'age' => 29, 'gender' => '男', 'job' => 'PHP', 'salary' => '4500'],
['name' => '韩梅梅', 'age' => 24, 'gender' => '女', 'job' => 'UI', 'salary' => '3500'],
['name' => '李华', 'age' => 27, 'gender' => '男', 'job' => '产品', 'salary' => '3600'],
['name' => '李锐', 'age' => 25, 'gender' => '男', 'job' => '产品', 'salary' => '2800'],
['name' => '赵云', 'age' => 28, 'gender' => '男', 'job' => '产品', 'salary' => '5000'],
['name' => '李雷', 'age' => 27, 'gender' => '男', 'job' => '测试', 'salary' => '3600'],
['name' => '李想', 'age' => 23, 'gender' => '男', 'job' => '测试', 'salary' => '2500'],
['name' => '赵雷', 'age' => 30, 'gender' => '男', 'job' => 'PHP', 'salary' => '5500'],
['name' => '张宇', 'age' => 27, 'gender' => '男', 'job' => 'JAVA', 'salary' => '4600'],
['name' => '杨建', 'age' => 24, 'gender' => '男', 'job' => 'JAVA', 'salary' => '3500'],
];
foreach ($data as $k => $document) {
$params['body'][] = [
'index' => [
'_index' => 'employees',
'_id' => $k+1
]
];
$params['body'][] = $document;
}
$res = $client->bulk($params);
dd($res);计算员工的平均薪资
//查询员工平均工资
$params = [
'index' => 'employees',
'body' => [
'aggs' => [
'avg_salary' => [
'avg' => [
'field' => 'salary'
]
]
],
'size' => 0,
],
];
$res = $client->search($params);
dd($res);
----------------------------------返回结果-------------------------------
array:5 [
"took" => 14
"timed_out" => false
"_shards" => array:4 [
"total" => 1
"successful" => 1
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 13
"relation" => "eq"
]
"max_score" => null
"hits" => []
]
"aggregations" => array:1 [
"avg_salary" => array:1 [
"value" => 3476.9230769231
]
]
] //查询员工最高或最低的工资
$params = [
'index' => 'employees',
'body' => [
'aggs' => [
'max_salary' => [
'max' => [
'field' => 'salary'
]
]
],
'size' => 0,
],
];
$res = $client->search($params);
dd($res);
----------------------------------结果--------------------------------
array:5 [
"took" => 3
"timed_out" => false
"_shards" => array:4 [
"total" => 1
"successful" => 1
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 13
"relation" => "eq"
]
"max_score" => null
"hits" => []
]
"aggregations" => array:1 [
"max_salary" => array:1 [
"value" => 5500.0
]
]
] //查询员工总的薪资
$params = [
'index' => 'employees',
'body' => [
'aggs' => [
'sum_salary' => [
'sum' => [
'field' => 'salary'
]
]
],
'size' => 0,
],
];
----------------------------------结果---------------------------------
array:5 [
"took" => 2
"timed_out" => false
"_shards" => array:4 [
"total" => 1
"successful" => 1
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 13
"relation" => "eq"
]
"max_score" => null
"hits" => []
]
"aggregations" => array:1 [
"sum_salary" => array:1 [
"value" => 45200.0
]
]
]cardinality 计算不重复的字段有多少（相当于mysql中的distinct）
//cardinality 去重操作，然后在进行统计，统计工种数量
$params = [
'index' => 'employees',
'body' => [
'aggs' => [
'cardinality_info' => [
'cardinality' => [
'field' => 'job.keyword'
]
]
],
'size' => 0,
],
];
$res = $client->search($params);
dd($res);
------------------------------------结果---------------------------------
array:5 [
"took" => 1009
"timed_out" => false
"_shards" => array:4 [
"total" => 1
"successful" => 1
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 13
"relation" => "eq"
]
"max_score" => null
"hits" => []
]
"aggregations" => array:1 [
"cardinality_info" => array:1 [
"value" => 5
]
]
]通过 status，可以同时返回 count,max,min,sum,avg 的结果
//计算 salary 的总数，最小，最大，平均，总和
$params = [
'index' => 'employees',
'body' => [
'aggs' => [
'salary_stats' => [
'stats' => [
'field' => 'salary'
]
]
],
'size' => 0,
],
];
$res = $client->search($params);
dd($res);
-------------------------------------结果-----------------------------------
array:5 [
"took" => 1
"timed_out" => false
"_shards" => array:4 [
"total" => 1
"successful" => 1
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 13
"relation" => "eq"
]
"max_score" => null
"hits" => []
]
"aggregations" => array:1 [
"salary_stats" => array:5 [
"count" => 13
"min" => 1000.0
"max" => 5500.0
"avg" => 3476.9230769231
"sum" => 45200.0
]
]
]对指定字段的值按从小到大累计每个值对应的文档数的占比，返回 指定占比比例对应的值。
$params = [
'index' => 'employees',
'body' => [
'aggs' => [
'percentiles' => [
'percentiles' => [
'field' => 'salary'
]
]
],
'size' => 0,
],
];
$res = $client->search($params);
dd($res);
------------------------------结果--------------------------------------
array:5 [
"took" => 2
"timed_out" => false
"_shards" => array:4 [
"total" => 1
"successful" => 1
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 13
"relation" => "eq"
]
"max_score" => null
"hits" => []
]
"aggregations" => array:1 [
"percentiles" => array:1 [
"values" => array:7 [
"1.0" => 1000.0
"5.0" => 1225.0
"25.0" => 2575.0
"50.0" => 3500.0
"75.0" => 4525.0
"95.0" => 5425.0
"99.0" => 5500.0
]
]
]
]上面的查询可以理解为 1% 的人薪资在1000以下，5% 的人薪资在1225 以下……
| 薪资范围 | 占比 |
|---|---|
| 0 ~ 1000 | 1% |
| 0 ~ 1225.0 | 5% |
| 0 ~ 2575.0 | 25% |
| 0 ~ 3500.0 | 50% |
| 0 ~ 4525.0 | 75% |
| 0 ~ 5425.0 | 95% |
| 0 ~ 5500.0 | 99% |
默认返回的是 1，5,25,50,75,95,99 对应的文档的值，可以使用 percents 指定某一处的分值
$params = [
'index' => 'employees',
'body' => [
'aggs' => [
'percentiles' => [
'percentiles' => [
'field' => 'salary',
"percents" => [46, 70, 80] //获取占比 46 的薪资范围
]
]
],
'size' => 0,
],
];
$res = $client->search($params);
dd($res);
---------------------------结果------------------------------------
array:5 [
"took" => 10
"timed_out" => false
"_shards" => array:4 [
"total" => 1
"successful" => 1
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 13
"relation" => "eq"
]
"max_score" => null
"hits" => []
]
"aggregations" => array:1 [
"percentiles" => array:1 [
"values" => array:3 [
"46.0" => 3500.0
"70.0" => 4140.0
"80.0" => 4590.0
]
]
]
]使用 percentile_ranks 可以翻过来，计算某一值在总数中的占比
统计年龄小于25和年龄小于30的文档的占比
$params = [
'index' => 'employees',
'body' => [
'aggs' => [
'percentile_ranks_example' => [
'percentile_ranks' => [
'field' => 'age',
"values" => [22,25] //获取年龄小于22 岁，小于25岁的占比
]
]
],
'size' => 0,
],
];
$res = $client->search($params);
dd($res);
-------------------------------返回结果--------------------------------
array:5 [
"took" => 9
"timed_out" => false
"_shards" => array:4 [
"total" => 1
"successful" => 1
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 13
"relation" => "eq"
]
"max_score" => null
"hits" => []
]
"aggregations" => array:1 [
"percentile_ranks_example" => array:1 [
"values" => array:2 [
"22.0" => 9.6153846153846
"25.0" => 38.461538461538
]
]
]
]获取到每组前n条数据，相当于sql 中Top（group by 后取出前n条）。
//按照工作进行分组，在对分组后的文档按照年龄进行升序，然后通过top_hits取每组的第一条
$params = [
'index' => 'employees',
'body' => [
'aggs' => [
'job_info' => [ //自己随意起名
'terms' => [ //这里的 terms 表示对 job进行分组，相当于 (group by job)
'field' => 'job.keyword',
],
//对 job 的分组数据执行一下操作
'aggs' => [
'top_job' => [
'top_hits' => [
'sort' => [ //对分组数据进行年龄的升序
[
'age' => [
'order' => 'desc'
]
]
],
"size" => 1 //取每组的一条数据
]
]
]
],
],
'size' => 0,
],
];
$res = $client->search($params);
dd($res);
---------------------------------结果-------------------------------------
array:5 [
"took" => 15
"timed_out" => false
"_shards" => array:4 [
"total" => 1
"successful" => 1
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 13
"relation" => "eq"
]
"max_score" => null
"hits" => []
]
"aggregations" => array:1 [
"job_info" => array:3 [
"doc_count_error_upper_bound" => 0
"sum_other_doc_count" => 0
"buckets" => array:5 [
0 => array:3 [
"key" => "PHP"
"doc_count" => 5
"top_job" => array:1 [
"hits" => array:3 [
"total" => array:2 [
"value" => 5
"relation" => "eq"
]
"max_score" => null
"hits" => array:1 [
0 => array:6 [
"_index" => "employees"
"_type" => "_doc"
"_id" => "11"
"_score" => null
"_source" => array:5 [
"name" => "赵雷"
"age" => 30
"gender" => "男"
"job" => "PHP"
"salary" => "5500"
]
"sort" => array:1 [
0 => 30
]
]
]
]
]
]
1 => array:3 [
"key" => "产品"
"doc_count" => 3
"top_job" => array:1 [
"hits" => array:3 [
"total" => array:2 [
"value" => 3
"relation" => "eq"
]
"max_score" => null
"hits" => array:1 [
0 => array:6 [
"_index" => "employees"
"_type" => "_doc"
"_id" => "8"
"_score" => null
"_source" => array:5 [
"name" => "赵云"
"age" => 28
"gender" => "男"
"job" => "产品"
"salary" => "5000"
]
"sort" => array:1 [
0 => 28
]
]
]
]
]
]
2 => array:3 [
"key" => "JAVA"
"doc_count" => 2
"top_job" => array:1 [
"hits" => array:3 [
"total" => array:2 [
"value" => 2
"relation" => "eq"
]
"max_score" => null
"hits" => array:1 [
0 => array:6 [
"_index" => "employees"
"_type" => "_doc"
"_id" => "12"
"_score" => null
"_source" => array:5 [
"name" => "张宇"
"age" => 27
"gender" => "男"
"job" => "JAVA"
"salary" => "4600"
]
"sort" => array:1 [
0 => 27
]
]
]
]
]
]
3 => array:3 [
"key" => "测试"
"doc_count" => 2
"top_job" => array:1 [
"hits" => array:3 [
"total" => array:2 [
"value" => 2
"relation" => "eq"
]
"max_score" => null
"hits" => array:1 [
0 => array:6 [
"_index" => "employees"
"_type" => "_doc"
"_id" => "9"
"_score" => null
"_source" => array:5 [
"name" => "李雷"
"age" => 27
"gender" => "男"
"job" => "测试"
"salary" => "3600"
]
"sort" => array:1 [
0 => 27
]
]
]
]
]
]
4 => array:3 [
"key" => "UI"
"doc_count" => 1
"top_job" => array:1 [
"hits" => array:3 [
"total" => array:2 [
"value" => 1
"relation" => "eq"
]
"max_score" => null
"hits" => array:1 [
0 => array:6 [
"_index" => "employees"
"_type" => "_doc"
"_id" => "5"
"_score" => null
"_source" => array:5 [
"name" => "韩梅梅"
"age" => 24
"gender" => "女"
"job" => "UI"
"salary" => "3500"
]
"sort" => array:1 [
0 => 24
]
]
]
]
]
]
]
]
]
]terms 相当于 group by field
$params = [
'index' => 'employees',
'body' => [
'aggs' => [
'Gorup_by_age' => [
'terms' => [ //使用 terms 对age进行分桶操作 (group by age)
'field' => 'age'
]
]
],
'size' => 0,
],
];
$res = $client->search($params);
dd($res);
---------------------------------结果----------------------------------------
array:5 [
"took" => 23
"timed_out" => false
"_shards" => array:4 [
"total" => 1
"successful" => 1
"skipped" => 0
"failed" => 0
]
"hits" => array:3 [
"total" => array:2 [
"value" => 13
"relation" => "eq"
]
"max_score" => null
"hits" => []
]
"aggregations" => array:1 [
"gorup_by_age" => array:3 [
"doc_count_error_upper_bound" => 0
"sum_other_doc_count" => 0
"buckets" => array:9 [
0 => array:2 [
"key" => 27
"doc_count" => 3
]
1 => array:2 [
"key" => 24
"doc_count" => 2
]
2 => array:2 [
"key" => 25
"doc_count" => 2
]
3 => array:2 [
"key" => 20
"doc_count" => 1
]
4 => array:2 [
"key" => 23
"doc_count" => 1
]
5 => array:2 [
"key" => 26
"doc_count" => 1
]
6 => array:2 [
"key" => 28
"doc_count" => 1
]
7 => array:2 [
"key" => 29
"doc_count" => 1
]
8 => array:2 [
"key" => 30
"doc_count" => 1
]
]
]
]
]
--结束END--
本文标题: PHP操作ElasticSearch7.8.1 详细教程
本文链接: https://lsjlt.com/news/32978.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
官方手机版
微信公众号
商务合作
0