在 Go 应用程序中如何执行 Elasticsearch 中的嵌套聚合操作？

Golang小白一枚，正在不断学习积累知识，现将学习到的知识记录一下，也是将我的所得分享给大家！而今天这篇文章《在 Go 应用程序中如何执行 Elasticsearch 中的嵌套聚合操作？》带大家来了解一下##content_title##，希望对大家的知识积累有所帮助，从而弥补自己的不足，助力实战开发！

我正在开发一个用 Go 编写的应用程序，该应用程序需要随着时间的推移提取一些统计信息。我想从我们拥有的监控索引中提取一些数据，并首先按时间对其进行分组，然后按监视器在给定时间点可以返回的不同状态进行分组。

例如，对于在访问特定 URL 时记录响应代码的内容，我希望首先按时间片获取聚合，然后获取 200、400、403 等状态代码的摘要计数。

如何使用 Elastic 包做到这一点？

解决方案

这里有一些事情需要了解。首先，我发现通过查看包中的测试代码来了解包的工作原理是最简单的。这就是我找到所需的两个聚合的方式：newautodatehistogramaggregation 和 newtermsaggregation。

对于嵌套聚合，您可以通过将子聚合链接到第一个聚合来实现。

我们首先创建 statusagg 对象（子聚合），然后在根据时间设置父聚合时将其链接起来。请注意，将 statusagg 传递到链接到日期直方图聚合的 subaggregation。

然后，为了执行聚合，只有父聚合实际上被传递到搜索上下文，并且返回的结果如您所期望的那样嵌套。

statusAgg := elastic.NewTermsAggregation().Field("statuscode")
timeAgg := elastic.NewAutoDateHistogramAggregation().
    Field("@timestamp").
    SubAggregation("status", statusAgg)

result, err := es.Search().
    Index(index).
    Query(boolQuery).
    Aggregation("time", timeAgg).
    Size(0).
    Pretty(true).
    Do(ctx)

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。