Laravel ES嵌套聚合查询多层级汇总统计结果-php教程-PHP中文网

ES nested字段必须先定义映射才能聚合，否则嵌套聚合失效；已有索引需reindex；Laravel中须手拼DSL并用Http::post发送，注意path、嵌套层级、size限制及结果解包。

laravel es嵌套聚合查询多层级汇总统计结果

ES nested 字段必须先定义映射才能聚合

没在 mapping 里把字段设为 nested 类型，后续所有嵌套聚合都会失效——它会把数组对象当成普通 object 处理，导致内层字段无法独立过滤或分组。比如评论数组 comments，如果 mapping 中只是 "type": "object"，那按 comments.user 聚合时，所有评论的 user 会被扁平化混在一起，结果完全失真。

正确做法是在创建索引时显式声明：

PUT /products
{
  "mappings": {
    "properties": {
      "comments": {
        "type": "nested",
        "properties": {
          "user": { "type": "keyword" },
          "rating": { "type": "integer" }
        }
      }
    }
  }
}

已有数据的索引不能直接改 nested 类型，必须 reindex。别跳过这步，否则后面怎么写 DSL 都白搭。

Laravel 中调用 ES 嵌套聚合得绕过 Eloquent 直接发 DSL

Laravel 自带的 Scout 或简单 HTTP 客户端都不支持嵌套聚合语法透传，search() 方法只处理 query 层，aggs 是纯 DSL 结构，必须手拼 JSON 并用 Http::post() 或 Client::search() 发送。

常见错误包括：

把 nested 聚合写在顶层 aggs 里，漏掉 path 参数 → 返回空桶
子聚合（如 terms）没包在 nested 的 aggs 内 → 聚合作用域错乱
用 match 过滤 nested 文档时没加 inner_hits → 看不到命中的具体子项

示例：统计每个用户在所有商品下的平均评分

Laravel Cloud

Laravel Cloud（cloud.laravel.com）。此技能用于处理所有 Laravel Cloud 请求，包括搜索和读取数据。只要任务涉及 Laravel Cloud，即使用此技能。

下载

{
  "size": 0,
  "aggs": {
    "by_user": {
      "nested": {
        "path": "comments"
      },
      "aggs": {
        "user_terms": {
          "terms": { "field": "comments.user" },
          "aggs": {
            "avg_rating": { "avg": { "field": "comments.rating" } }
          }
        }
      }
    }
  }
}

多级下钻聚合容易内存溢出，必须设 size 限制

嵌套聚合是深度递归操作，尤其当第一级 terms 桶数量大（比如上万用户），再对每个桶做二级 terms 或 date_histogram，ES 会为每个组合分配内存，极易触发 circuit breaker。

关键控制点：

所有 terms 聚合必须加 "size": 100（默认是 10，太小；设太大直接 OOM）
避免三级及以上嵌套，超过两级优先考虑客户端二次聚合
用 composite 聚合替代深层 terms，支持分页和低内存消耗
测试阶段加 "track_total_hits": false 和 "timeout": "30s"

Laravel + ES 聚合结果需手动解包 nested 结构

ES 返回的嵌套聚合结果是深度嵌套的数组结构，比如 aggregations.by_user.user_terms.buckets，而 Laravel Collection 的 pluck()、map() 无法自动识别这种路径，直接链式调用会报错或返回 null。

安全解法是用 data_get() 或逐层判空：

$result = Http::post('http://es:9200/products/_search', $dsl);
$buckets = data_get($result, 'aggregations.by_user.user_terms.buckets', []);

collect($buckets)->map(function ($bucket) {
    return [
        'user' => $bucket['key'],
        'avg_rating' => round(data_get($bucket, 'avg_rating.value', 0), 2),
        'count' => $bucket['doc_count']
    ];
});

注意：data_get() 比 Arr::get() 更稳，能容忍中间层级为 null；别用 $bucket['avg_rating']['value'] 这种裸访问，ES 某些条件下可能不返回 value 字段（比如无数据时只有 value_as_string）。

嵌套聚合真正难的不是写 DSL，而是预估数据规模与内存边界——一个没设 size 的 terms 在千万级 nested 文档上，可能让节点直接被熔断器踢出集群。