PHP 操作 ElasticSearch7.8.1

PHP技术
578
0
0
2022-06-21
Paypal授权登录流程及实现
上一篇
PHP7.2+ 版本，DEC-CBC加解密
下一篇
标签   Elasticsearch

版本

PHP 操作 ElasticSearch 的索引，文档

根据 PHP 版本选择对应的 ElasticSearch-PHP 版本

ElasticSearch7.8.1 Docker 安装，介绍与PHP操作

PHP 安装 ElasticSearch-PHP

  1. compose 安装 ElasticSearch-PHP
 composer require elasticsearch/elasticsearch
  1. 创建 ElasticSearch 客户端
     $params = [
         'host' => "127.0.0.1:9200"
     ];
     //设置主机，并设置重连次数 
     $client = ClientBuilder::create()->setHosts($params)->setRetries(2)->build();

使用

PHP 操作索引(增删改查)

创建索引

创建一个 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);

PHP 操作文档

创建一条数据的文档

        $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
]

创建多条数据的文档（bulk）

        $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" => "运动，小说，睡觉"
        ]
      ]
    ]
  ]
]
精准查找
  1. 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" => "运动，日漫，电影，技术控"
        ]
      ]
    ]
  ]
]
  1. 多关键字精确查询
  2. terms 查询和 term 查询一样，但它允许你指定多值进行匹配。
  3. 如果这个字段包含了指定值中的任何一个值，那么这个文档满足条件，类似于 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升序。

  1. 根据年龄进行排序
        $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
        ]
      ]
    ]
  ]
]
  1. 多个字段排序，先根据年龄进行排序，如果年龄相等，在根据 _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" => "运动，日漫，电影，技术控"
        ]
      ]
    ]
  ]
]

PHP 聚合操作

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' //对哪个字段进行聚合
                        ]
                    ]
                ],
            ],
        ];

创建案列数据

  1. 创建 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);
  1. 添加文档数据
     $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);

avg 平均值

计算员工的平均薪资

        //查询员工平均工资
        $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
    ]
  ]
]

min,max 最大，最小

        //查询员工最高或最低的工资
        $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
    ]
  ]
]

sum 求和

        //查询员工总的薪资
        $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 去重

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 计算各种聚合

通过 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
    ]
  ]
]

percentiles 百分比统计

对指定字段的值按从小到大累计每个值对应的文档数的占比，返回 指定占比比例对应的值。

        $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

使用 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
      ]
    ]
  ]
]

top_hits 取分桶后的前n条

获取到每组前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

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
        ]
      ]
    ]
  ]
]
Paypal授权登录流程及实现
上一篇
PHP7.2+ 版本，DEC-CBC加解密
下一篇