掌握 Elasticsearch 聚合：从基础到进阶

2023-11-05 02:19:07

揭秘 Elasticsearch 的聚合功能：分组和汇总海量数据

概述

Elasticsearch 的聚合功能是一项强大的工具，允许您对文档集合进行分组和汇总，从而从数据中提取有价值的信息。本文将深入探讨聚合的基础知识，涵盖 DSL 语法和 Java 中的实现，帮助您充分利用 Elasticsearch 的聚合功能。

什么是聚合？

聚合是一种在数据集合上执行分组和汇总操作的技术。通过聚合，您可以将文档按特定字段进行分组，并对每个组计算统计值（例如计数、平均值或最大值）。

聚合类型

Elasticsearch 提供多种聚合类型，满足不同的需求：

1. 桶聚合：

将文档按指定字段分组为桶。
常用的桶聚合类型包括：
- Terms 聚合： 按特定字段对文档进行分组，并计算每个组的文档数。
- Range 聚合： 将文档分组到指定范围内的桶中。
- Date Histogram 聚合： 按时间间隔将文档分组到桶中。

2. 度量聚合：

对文档集合进行数学计算。
常用的度量聚合类型包括：
- Sum 聚合： 计算文档集中字段值的总和。
- Avg 聚合： 计算文档集中字段值的平均值。
- Max 聚合： 识别文档集中字段值的最大值。

DSL 语法

DSL（领域特定语言）用于定义聚合查询。以下是常用的子句：

1. 桶聚合

order 子句： 按桶聚合结果进行排序。
range 子句： 限定桶聚合的范围。

2. 度量聚合

度量聚合不需要额外的子句。

Java 中的聚合实现

使用 RestClient 在 Java 中实现聚合查询：

import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;

public class AggregationExample {

    public static void main(String[] args) throws IOException {
        RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200)));

        TermsAggregationBuilder termsAggregation = AggregationBuilders.terms("categories").field("category");
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder().aggregation(termsAggregation);

        // 执行查询
        SearchResponse response = client.search(new SearchRequest("products"), sourceBuilder);

        // 解析结果
        Terms terms = response.getAggregations().get("categories");
        for (Terms.Bucket bucket : terms.getBuckets()) {
            System.out.println(bucket.getKeyAsString() + ": " + bucket.getDocCount());
        }

        client.close();
    }
}