ElasticSearch动态字段搜索排序：按匹配颜色百分比聚合排序查询构建

根据你提供的索引映射（colors_array.colors下是动态生成的十六进制颜色字段，存储百分比数值），我分两种常见场景给出对应的查询方案，满足你“传入指定颜色后求和聚合并排序”的需求：

场景1：筛选含指定颜色的文档，按文档内该颜色总百分比排序 #

如果你需要找出所有包含目标颜色的文档，计算每个文档中该颜色的百分比总和，再按这个总和对文档排序，可以用脚本字段计算总和并排序：

GET /your_index_name/_search
{
  "query": {
    "exists": {
      "field": "colors_array.colors.#dc143c" // 替换成你要查询的颜色
    }
  },
  "script_fields": {
    "total_color_percent": {
      "script": {
        "source": """
          long sum = 0;
          // 遍历colors_array中的每个对象
          for (def item : params._source.colors_array) {
            if (item.colors.containsKey('#dc143c')) {
              sum += item.colors['#dc143c'];
            }
          }
          return sum;
        """
      }
    }
  },
  "sort": [
    {
      "total_color_percent": {
        "order": "desc" // 降序排序，改成asc就是升序
      }
    }
  ]
}

关键说明 #

• exists查询：确保只返回包含目标颜色的文档，避免无效计算
• 脚本字段：手动遍历colors_array数组，累加每个元素中目标颜色的数值，得到当前文档的总百分比
• 排序规则：直接基于计算出的总百分比字段对文档排序

场景2：统计多个指定颜色的全局总百分比，按总和排序颜色 #

如果需要同时统计多个颜色的全局总占比，再按总和从高到低排序这些颜色，就需要用到嵌套聚合（因为colors_array是嵌套数组类型）：

GET /your_index_name/_search
{
  "size": 0, // 不需要返回原始文档，只看聚合结果
  "aggs": {
    "traverse_color_array": {
      "nested": {
        "path": "colors_array" // 开启嵌套聚合，遍历数组每个元素
      },
      "aggs": {
        "group_by_target_colors": {
          "terms": {
            "script": {
              "source": """
                // 这里替换成你要统计的颜色列表
                def target_colors = ['#dc143c', '#808080', '#2f4f4f'];
                def matched = [];
                for (def color : target_colors) {
                  if (doc['colors_array.colors.' + color].size() > 0) {
                    matched.add(color);
                  }
                }
                return matched;
              """
            },
            "size": 10, // 显示前10个颜色
            "order": {
              "total_percent": "desc" // 按总百分比降序排序
            }
          },
          "aggs": {
            "total_percent": {
              "sum": {
                "script": {
                  "source": """
                    def color = params.key;
                    return doc['colors_array.colors.' + color].size() > 0 ? doc['colors_array.colors.' + color].value : 0;
                  """
                }
              }
            }
          }
        }
      }
    }
  }
}

关键说明 #

• nested聚合：必须用这个聚合才能正确遍历colors_array中的每个嵌套对象，否则会导致聚合结果不准确
• terms聚合：通过脚本匹配指定的颜色列表，将每个颜色作为分组依据
• sum子聚合：计算每个颜色在所有文档中的总百分比
• 排序规则：直接基于总百分比对颜色分组排序

实用提示 #

• 性能优化：如果经常需要做这类颜色统计，建议调整文档结构，把颜色和百分比存储为键值对数组（比如[{"hex": "#dc143c", "percent": 30}]），这样聚合时不需要用复杂脚本，性能会更好
• 脚本权限：如果是生产环境，建议使用存储脚本（而非inline脚本），避免安全风险，同时提升复用性
• 动态字段引用：在脚本中引用动态颜色字段时，要注意用字符串拼接的方式（比如doc['colors_array.colors.' + color]），确保能正确访问到动态生成的字段

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