depathange＆＃x2B; top_hits聚合（作为subggregation）使用Elasticsearch Java API客户端7.17.x

Question

我已经过了一天了，我不太了解我是怎么做到的！这是我想使用新的Java API客户端“重新创建”的查询（使用Spring Boot），

{
  "aggs": {
    "range": {
      "date_range": {
        "field": "timestamp",
        "ranges": [
          { "to": "now-2d" } 
        ]
      }
    }
  ,
  "aggs": {
      "top_hits": {
        "_source": {
              "includes": [ "Id", "timestamp" ]
            }
      }
  }
}
}

我尝试使用daterangeaggregation.of ，但我似乎无法获得正确的结果或键入。这是我

SearchResponse<MyDto> response = client.search(b -> b
                .index("test-index")
                .size(0) 
                .aggregations("range",a->a.dateRange(DateRangeAggregation.of(d->d
                  .field("timestamp").ranges(r->r.to(t->t.expr("now-2d")))))),
                    .aggregations("hits", a -> a
                        .topHits(h->h.source(SourceConfig.of(c->c.filter(f->f.includes(Arrays.asList("Id", "timestamp"))))))),
                MyDto.class 
            );

也尝试删除subggregation和查询目前的方法，但是我似乎没有正确的轨道无法获得doc_count的数量。来自水桶。我有点不知道如何在此处使用depaterange（）。

编辑：我玩了一点，至少能够获得doc_count的数量，我不太确定这是否是这样做的好方法？

Aggregation agg = Aggregation.of(a -> a
            .dateRange(d->d.field("timestamp").ranges(r->r.to(FieldDateMath.of(v->v.expr("now-2d"))))));
        
SearchResponse<MyDto> response = client.search(b -> b
               .index("test-index")
               .size(0) 
               .aggregations("range", agg),
                MyDto.class 
            );

return response.aggregations().get("range").dateRange().buckets().array().get(0).docCount();

我还修复了上面的查询，它具有不必要的额外查询，从而打破了结果。

Answer 1

我的思考过程是错误的。我想要一段时间以来汇总的文件，但我误解了，并认为Tophits会给我提供给我，但这不是它的工作方式！我做了一个单独的范围查询，实际上是查询了我需要的文档。