3. 聚合查询基础：Elasticsearch 聚合框架概述、度量聚合、桶聚合、管道聚合

在领域建模驱动的搜索索引设计中，聚合查询是连接领域分析维度与索引存储结构的核心桥梁。Elasticsearch 聚合框架允许我们在搜索命中的文档集上实时计算统计指标、构建分类桶、并对聚合结果进行二次加工。本章将系统阐述聚合框架的三大支柱：度量聚合、桶聚合与管道聚合，并给出领域建模视角下的参数配置建议。

3.1 聚合框架整体架构

Elasticsearch 聚合（Aggregation）基于 doc_values 或 fielddata 在内存中构建列式数据结构，避免对原始文档的逐一遍历。聚合请求与搜索请求共享同一个 query 上下文，所有聚合计算仅在匹配文档集上执行。

3.2 度量聚合（Metrics Aggregation）

度量聚合对匹配文档集的某个数值字段计算统计值，返回单一标量结果。根据计算方式分为单值度量与多值度量两类。

// 度量聚合示例：计算订单金额的统计信息
GET /orders/_search
{
  "size": 0,
  "aggs": {
    "amount_stats": {
      "stats": {
        "field": "total_amount"
      }
    }
  }
}

// 响应示例
{
  "aggregations": {
    "amount_stats": {
      "count": 12500,
      "min": 9.9,
      "max": 8999.0,
      "avg": 342.15,
      "sum": 4276875.0
    }
  }
}

3.3 桶聚合（Bucket Aggregation）

桶聚合将文档集划分为多个互斥的桶（Bucket），每个桶代表一个分组条件。桶聚合是领域驱动维度下钻的核心工具，支持嵌套组合形成多级分析树。

3.3.1 常用桶聚合类型

3.3.2 桶聚合的边界参数陷阱

// 桶聚合嵌套示例：按品类分组，再按日期直方图下钻
GET /orders/_search
{
  "size": 0,
  "aggs": {
    "by_category": {
      "terms": {
        "field": "category_id",
        "size": 10,
        "shard_size": 50
      },
      "aggs": {
        "daily_sales": {
          "date_histogram": {
            "field": "order_date",
            "interval": "day",
            "format": "yyyy-MM-dd"
          },
          "aggs": {
            "revenue": {
              "sum": {
                "field": "total_amount"
              }
            }
          }
        }
      }
    }
  }
}

3.4 管道聚合（Pipeline Aggregation）

管道聚合不直接对文档集计算，而是以其他聚合的输出作为输入，执行二次加工。管道聚合分为父级管道（Parent）和兄弟管道（Sibling）两类。

3.4.1 管道聚合分类

3.4.2 管道聚合的领域建模约束

• 顺序依赖：管道聚合必须在被引用的聚合之后定义，且引用路径使用 buckets_path 参数指定。
• 数据排序：父级管道（如 derivative）要求输入桶按时间或数值升序排列，否则结果无意义。
• 空桶处理：管道聚合遇到空桶时默认返回 null，可通过 gap_policy 参数配置为 skip（跳过）或 insert_zeros（补零）。

// 管道聚合示例：计算每日销售额的环比变化
GET /orders/_search
{
  "size": 0,
  "aggs": {
    "sales_over_time": {
      "date_histogram": {
        "field": "order_date",
        "interval": "day",
        "format": "yyyy-MM-dd",
        "order": { "_key": "asc" }
      },
      "aggs": {
        "daily_revenue": {
          "sum": { "field": "total_amount" }
        },
        "revenue_derivative": {
          "derivative": {
            "buckets_path": "daily_revenue"
          }
        }
      }
    }
  }
}

// 响应片段
"buckets": [
  { "key_as_string": "2025-03-01", "daily_revenue": { "value": 12000 } },
  { "key_as_string": "2025-03-02", "daily_revenue": { "value": 13500 },
    "revenue_derivative": { "value": 1500 } },
  { "key_as_string": "2025-03-03", "daily_revenue": { "value": 12800 },
    "revenue_derivative": { "value": -700 } }
]

3.5 聚合查询的边界参数配置清单

在领域建模阶段，以下参数直接影响聚合结果的准确性与性能，建议在索引模板或查询模板中显式配置。

3.6 本章小结

• 度量聚合提供标量统计值，是领域指标计算的基础单元。
• 桶聚合实现维度分组与下钻，支持多层嵌套形成分析树。
• 管道聚合对聚合结果进行二次加工，适用于环比、累计、移动平均等时序分析。
• 边界参数（size、shard_size、gap_policy 等）必须在领域建模阶段根据业务精度要求显式配置，避免默认值导致的精度损失或性能退化。