Elasticsearch Date Histogram聚合日期异常及空桶问题求助

你的查询核心问题是没有指定extended_bounds参数，导致Date Histogram聚合的桶范围由匹配到的文档数据决定，而非你设置的查询日期范围。

为什么会出现这种情况？ #

Elasticsearch 6.8中，min_doc_count:0的作用是在已有数据覆盖的时间区间内补全文档数为0的桶，但如果查询范围内没有任何匹配的文档（比如你第一次设置2023-01-01至2023-01-31时），聚合就不会生成任何桶；当只有部分日期有数据时（比如第二次扩展范围后），也只会返回有数据的桶，不会自动填充整个查询区间的所有日期桶。

要让聚合覆盖你指定的完整日期范围，必须通过extended_bounds明确指定聚合的起始和结束时间，结合min_doc_count:0就能生成每日的桶，包括文档数为0的情况。

修改后的查询语句 #

{
  "query": {
    "bool": {
      "filter": [
        {
          "terms": {
            "userId": ["123456", "654321"],
            "boost": 1.0
          }
        },
        {
          "range": {
            "created": {
              "from": 1672531200000,
              "to": 1675123200000,
              "include_lower": true,
              "include_upper": true,
              "boost": 1.0
            }
          }
        }
      ],
      "adjust_pure_negative": true,
      "boost": 1.0
    }
  },
  "aggregations": {
    "date_count": {
      "date_histogram": {
        "field": "created",
        "interval": "1d",
        "offset": 0,
        "order": {
          "_key": "asc"
        },
        "keyed": false,
        "min_doc_count": 0,
        "extended_bounds": {
          "min": 1672531200000,
          "max": 1675123200000
        }
      }
    }
  }
}

Java High Level REST Client 对应代码示例 #

如果你是用Java代码构建查询，需要在DateHistogramAggregationBuilder中添加extendedBounds：

import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.histogram.DateHistogramAggregationBuilder;
import org.elasticsearch.search.aggregations.bucket.histogram.DateHistogramInterval;
import org.elasticsearch.search.aggregations.bucket.histogram.ExtendedBounds;
import org.elasticsearch.search.aggregations.bucket.histogram.BucketOrder;

// 构建日期直方图聚合
DateHistogramAggregationBuilder dateHistogram = AggregationBuilders.dateHistogram("date_count")
        .field("created")
        .calendarInterval(DateHistogramInterval.DAY)
        .minDocCount(0)
        // 设置extended_bounds，与range查询的时间范围一致
        .extendedBounds(new ExtendedBounds(1672531200000L, 1675123200000L))
        .order(BucketOrder.key(true));

注意事项 #

• extended_bounds的min和max要和你range查询中的from、to保持一致，确保聚合范围和查询范围匹配。
• 你的created字段是Long类型（毫秒时间戳），extended_bounds直接传入数值型时间戳即可，无需转换格式。

内容的提问来源于stack exchange，提问作者roditoo