Elasticsearch中基于平均价格字段的Histogram聚合实现咨询

要实现按市场平均价格划分区间并统计对应市场数量，你需要通过「分组计算单市场均价 + 管道聚合分桶统计」的方式完成，具体查询示例及说明如下：

完整查询语句 #

{
  "size": 0,
  "query": {
    "bool": {
      "must_not": {
        "term": {
          "price": 0
        }
      }
    }
  },
  "aggs": {
    // 第一步：按市场分组，计算每个市场的平均价格
    "markets": {
      "terms": {
        "field": "market.id",
        "size": 10000 // 根据实际市场总数调整，确保覆盖所有市场
      },
      "aggs": {
        "avg_price": {
          "avg": {
            "field": "price"
          }
        }
      }
    },
    // 第二步：管道聚合，基于单市场均价做区间分桶，统计每个区间的市场数
    "price_range_market_count": {
      "histogram_bucket": {
        "buckets_path": "markets>avg_price",
        "interval": 0.5,
        "min_doc_count": 0,
        "extended_bounds": {
          "min": 0,
          "max": 45
        }
      },
      "aggs": {
        "market_count": {
          "bucket_script": {
            "buckets_path": {
              "count": "_count"
            },
            "script": "params.count"
          }
        }
      }
    }
  }
}

关键部分说明 #

• markets聚合：先按market.id对所有文档分组，每个分组下通过avg_price聚合计算该市场所有产品的平均价格。注意terms的size参数要设置得足够大，避免因上限限制遗漏部分市场。
• price_range_market_count管道聚合：这是核心的转换步骤，通过histogram_bucket读取每个市场的平均价格，按照你指定的0.5间隔划分区间，同时用extended_bounds强制生成0到45的全区间（即使区间内没有对应市场）。
• market_count聚合：通过bucket_script直接输出每个价格区间内的市场数量，也就是该区间包含的markets分组的总数。

与原查询的差异 #

你的原查询是直接对单个产品的price字段做区间分桶，统计的是「某个价格区间内出现过的不同市场数」，而不是「平均价格落在该区间的市场数」，逻辑完全不符，必须通过先分组计算均价再分桶的方式才能实现需求。

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