如何将Elasticsearch Spring Data AggregationsContainer内容映射到自定义模型？

Question

我正在使用Elsaticsearch Spring数据。我有一个自定义存储库，它使用基于文档示例的ElasticsearchOperations。我需要一些聚合查询结果，并且我成功地获得了预期的结果。但我需要将这些结果映射到一个模型。但目前我无法访问AggregationsContainer的内容。

 override fun getStats(startTime: Long, endTime: Long, pageable: Pageable): AggregationsContainer<*>? 
    {
        val query: Query = NativeSearchQueryBuilder()
            .withQuery(QueryBuilders.rangeQuery("time").from(startTime).to(endTime))
            .withAggregations(AggregationBuilders.sum("discount").field("discount"))
            .withAggregations(AggregationBuilders.sum("price").field("price"))
            .withPageable(pageable)
            .build()

        val searchHits: SearchHits<Product> = operations.search(query, Product::class.java)

        return searchHits.aggregations 

    }

我返回以下代码的结果：

    val stats = repository.getTotalStats(before, currentTime, pageable)?.aggregations()

结果是：

{
    "asMap": {
        "discount": {
            "name": "discount",
            "metadata": null,
            "value": 8000.0,
            "valueAsString": "8000.0",
            "type": "sum",
            "fragment": true
        },
        "price": {
            "name": "price",
            "metadata": null,
            "value": 9000.0,
            "valueAsString": "9000.0",
            "type": "sum",
            "fragment": true
        }
    },
    "fragment": true
}

如何将上述输出转换为如下所示的预期输出模型？在我测试时，无法访问聚合（）的内容，类型为Any：

{
    "priceSum":9000.0,
    "discountSum":8000
 }

Answer 1

Elasticsearch RestHighLevelClient类中没有用于聚合的数据模型，Spring数据Elasticsearch中也没有on。因此，原始的聚合对象将返回给调用者（包含在该聚合容器中，因为这将随着新的客户端实现而改变，然后容器将容纳不同的对象）。

你必须自己分析，我在另一个问题的答案中找到了一些东西(https://stackoverflow.com/a/63105356/4393565). 您感兴趣的是传递聚合的最后一个代码块。基本上，您必须迭代元素，将其转换为适当的类型并对其求值。