Elasticsearch如何按每日固定小时实现周维度分桶聚合

完全可以实现。原生date_histogram聚合是沿连续时间轴按固定间隔切分分桶，天然不支持跨自然周/自然月合并同星期、同时段的数据，换个聚合思路就能满足需求，下面是两种可直接落地的方案：

方案1：运行时字段 + Terms聚合（无索引改造成本，适合中等数据量场景） #

不需要修改原有索引结构，查询时临时生成聚合维度字段即可：

• 先通过range查询圈定你要统计的时间范围
• 定义运行时字段，从时间字段中提取小时值，过滤掉非目标时段的文档，再提取星期值拼接成你需要的桶名
• 对生成的运行时字段做terms聚合，固定返回7个分桶即可

参考查询DSL如下：

GET 你的业务索引名/_search
{
  "size": 0,
  "runtime_mappings": {
    "weekday_hour_bucket": {
      "type": "keyword",
      "script": {
        "source": """
          // 按业务时区取时间，避免时区偏移统计错误
          ZonedDateTime zonedTime = doc['你的时间字段名'].value.atZone(ZoneId.of("Asia/Shanghai"));
          int hour = zonedTime.getHour();
          // 非8点时段的文档直接跳过，不进入分桶
          if (hour != 8) {
            return;
          }
          // ES中DayOfWeek返回值1=周一、7=周日，对应映射成名称
          int weekdayVal = zonedTime.getDayOfWeek().getValue();
          String[] weekdayNames = ["MONDAY", "TUESDAY", "WEDNESDAY", "THURSDAY", "FRIDAY", "SATURDAY", "SUNDAY"];
          emit(weekdayNames[weekdayVal - 1] + " 8am");
        """
      }
    }
  },
  "query": {
    "range": {
      "你的时间字段名": {
        "gte": "统计起始时间，例如2024-05-01T00:00:00+08:00",
        "lte": "统计结束时间，例如2024-05-31T23:59:59+08:00"
      }
    }
  },
  "aggs": {
    "stat_buckets": {
      "terms": {
        "field": "weekday_hour_bucket",
        "size": 7,
        "order": { "_key": "asc" }
      },
      "aggs": {
        "bucket_ts": {
          "min": {
            "field": "你的时间字段名"
          }
        }
      }
    }
  }
}

返回结果中，每个分桶的key就是你要的MONDAY 8am格式字符串，bucket_ts.value可以作为示例中的时间戳key值，简单做一层结果格式转换就能完全匹配你需要的输出结构。

方案2：预索引聚合字段（适合大数据量、高频查询场景） #

如果你的单索引数据量在千万级以上、该聚合查询的调用频次很高，运行时脚本会有一定性能开销，建议在写入环节提前处理：
配置ingest写入管道，文档写入ES时就提前计算好「星期+目标小时」的keyword字段，查询时直接对该预生成字段做terms聚合即可，性能和普通聚合查询没有差异。

• 时区问题是这类统计最容易踩的坑，脚本里取小时、星期值时一定要显式指定业务时区，不要用ES默认时区，避免夏令时、UTC偏移导致统计的时段错位
• 如果需要统计多个固定时段，只要修改脚本里的小时判断逻辑即可，比如要统计8点、18点两个时段，就把判断条件改为if (hour != 8 && hour != 18) { return; }，emit时把对应小时值拼入桶名即可
• 不建议强行用date_histogram实现：即使通过offset参数把分桶起始时间对齐到8点，后续仍需要二次聚合把跨周的同星期分桶合并，性能比上述两种方案差很多

内容的提问来源于stack exchange，提问作者Joey Yi Zhao