Elasticsearch不同时区数据按本地相同小时聚合错误如何解决

问题原因 #

ES的date类型会自动把带时区的时间字符串转成UTC时间戳存储，默认的date_histogram聚合也会基于UTC时间计算分组，因此不同时区的同一当地时间会被划分到不同桶中，和你的预期不符。

解决方案 #

方案1：临时查询用脚本聚合 #

直接从原始存储的带时区时间字符串中提取小时数做分组，查询语句如下：

POST /test_index/_search?size=0
{
  "aggs": {
    "group_by_local_hour": {
      "terms": {
        "script": {
          "source": """
            String rawTime = params._source.my_time;
            String hourPart = rawTime.split('T')[1].substring(0, 2);
            return Integer.parseInt(hourPart);
          """,
          "lang": "painless"
        },
        "size": 24
      }
    }
  }
}

执行后8点分组的doc_count会返回2，完全匹配你的需求。

方案2：预存字段提升性能 #

如果该统计是高频需求，建议在数据写入阶段提前提取当地时间的小时数，存为独立的local_hour整数字段，后续直接聚合该字段即可，查询性能远高于脚本聚合：

// 新增字段后的聚合语句
POST /test_index/_search?size=0
{
  "aggs": {
    "group_by_local_hour": {
      "terms": {
        "field": "local_hour",
        "size": 24
      }
    }
  }
}

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