Elasticsearch使用date_histogram聚合时如何避免数值向下取整获取精确平均值

问题结论 #

可以获取到精确的平均值结果，你遇到的精度丢失问题和date_histogram聚合本身无关，核心是字段映射配置错误导致。

根因分析 #

Elasticsearch的聚合计算读取的是索引中存储的字段值，而非_source里展示的原始值：

• 你的索引中value字段的映射类型被错误设置为了整数类型（如integer、long）
• 数据写入时，ES会自动将_source里的浮点数强制截断为整数存入索引列
• 平均值聚合基于索引中已经被截断的整数计算，自然出现先取整再求平均的问题

你提供的示例刚好可以验证该逻辑：DN3的两个value原始值是2.8333333、3.3，取整后为2、3，平均值刚好是2.5，和聚合返回结果完全一致；LI9的两个值0.36666667、0.13333334取整后都是0，平均值就是0，也和返回结果匹配。

验证方法 #

执行以下查询确认索引的字段映射：

GET /originals-20210915/_mapping

如果返回结果中value字段的type为整数类，即可确认问题。

解决办法 #

方案一：重建索引（推荐，性能最优） #

1. 新建索引，将value字段类型设置为浮点类（精度要求高可以选double，常规场景float足够）：

PUT /originals-fixed-20210915
{
  "mappings": {
    "properties": {
      "value": {
        "type": "float"
      },
      "timestamp": {
        "type": "date"
      },
      "instanceName": {
        "type": "keyword"
      },
      "metric": {
        "type": "keyword"
      }
      // 其余字段映射保持和原索引一致即可
    }
  }
}

2. 将旧索引数据迁移到新索引：

POST _reindex
{
  "source": {
    "index": "originals-20210915"
  },
  "dest": {
    "index": "originals-fixed-20210915"
  }
}

3. 针对新索引执行你原来的聚合查询，即可得到精确的浮点平均值。

方案二：脚本聚合（临时方案，不适合大数据量场景） #

如果暂时无法重建索引，可以通过脚本直接读取_source里的原始值计算，性能比正常聚合低一个数量级：

{
    "aggregations": {
        "timestamp": {
            "date_histogram": {
                "field": "timestamp",
                "interval": "300s",
                "offset": 0,
                "order": {
                    "_key": "asc"
                },
                "keyed": false,
                "min_doc_count": 0
            },
            "aggregations": {
                "myAgg": {
                    "avg": {
                        "script": {
                            "source": "params._source.value"
                        }
                    }
                }
            }
        }
    }
}

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