gpt4 book ai didi

java - Elasticsearch 中的聚合解析

转载 作者:行者123 更新时间:2023-12-02 12:25:41 26 4
gpt4 key购买 nike

我有一个有效的 elasticsearch 查询,但我不知道如何使用 java API 解析返回值。似乎无论我以哪种方式配置它,我都会遇到空值。

elasticsearch 中的查询是:

GET user_profile/active_time/_search
{
"size" : 0,
"aggregations" : {
"agg1" : {
"filter" : {
"range" : {
"timestamp" : {
"from" : 0,
"to" : 1501786179177,
"include_lower" : true,
"include_upper" : true
}
}
},
"aggregations" : {
"agg2" : {
"terms" : {
"field" : "userId",
"size" : 0
}
}
}
}
}
}

它产生返回值:

{
"took": 2,
"timed_out": false,
"_shards": {
"total": 5,
"successful": 5,
"failed": 0
},
"hits": {
"total": 55,
"max_score": 0,
"hits": []
},
"aggregations": {
"agg1": {
"doc_count": 55,
"agg2": {
"doc_count_error_upper_bound": 0,
"sum_other_doc_count": 0,
"buckets": [
{
"key": 0,
"doc_count": 34
},
{
"key": 295,
"doc_count": 12
},
{
"key": 59,
"doc_count": 3
},
{
"key": 764,
"doc_count": 3
},
{
"key": 788,
"doc_count": 3
}
]
}
}
}
}

我想知道如何正确地将存储桶从聚合 2 中取出。在之前的迭代中,我能够使用访问它

Terms terms = sr.getProperty("agg2");

但是在这种情况下过滤器不起作用。我应该重新格式化我的查询还是有某种方法可以解析它?谢谢。

最佳答案

通过将范围过滤器移出聚合并进入正常搜索,我能够使用这些行解析值。

Terms terms = sr.getAggregations().get("agg");
Collection<Terms.Bucket> buckets = terms.getBuckets();
for (Terms.Bucket x : buckets) {
System.out.println("Key: " + x.getKey() + " Count: " + x.getDocCount());
}

这是新的查询:

GET user_profile/active_time/_search
{
"size" : 0,
"query": {
"range": {
"timestamp": {
"gte": 0,
"lte": 1501786179177
}
}
},
"aggregations" : {
"agg1" : {
"terms" : {
"field" : "userId",
"size" : 0
}
}
}
}

关于java - Elasticsearch 中的聚合解析,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45492692/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com