Elasticsearch中如何基于数组元素个数进行条件筛选？

elasticsearch高效筛选：基于数组元素个数的条件查询

本文介绍如何在Elasticsearch中根据数组字段元素个数进行高效筛选，尤其是在需要统计数组中满足特定条件的元素数量时。 问题：我们需要查询change_records数组中，change_time字段值位于指定年份范围内的元素个数不小于n的文档。

直接使用脚本查询可能因路径问题导致失败，例如报错“no field found for [change_records] in mapping with types []”。 exists查询只能验证字段存在性，无法满足条件筛选需求。

解决方案：利用script_score查询和Painless脚本

最佳方案是使用script_score查询结合自定义Painless脚本实现。 此方法的核心在于：

1. Painless脚本统计: 编写Painless脚本遍历change_records数组，统计change_time在指定年份范围内的元素个数。
2. 评分机制: 根据统计结果返回分数：满足条件的文档分数大于0，否则为0。
3. script_score筛选: 使用script_score查询，设置query部分为基础查询条件（例如match_all或其他更具体的查询），script部分为自定义评分脚本，并设置min_score为1，从而筛选出满足条件的文档。

具体实现：

基础查询条件可以根据实际需求调整。script_score查询的script部分使用Painless脚本，示例如下：

{   "query": {     "script_score": {       "query": {         "match_all": {}  // 可替换为其他查询条件       },       "script": {         "source": """           int matches = 0;           for (item in doc['change_records']) {             if (item.change_time >= params.start && item.change_time <= params.end) {               matches++;             }           }           return matches >= params.n ? 1 : 0;         """,         "params": {           "start": 1609459200000, // 2021年1月1日00:00:00 (毫秒时间戳)           "end": 1672531200000,  // 2022年12月31日23:59:59 (毫秒时间戳)           "n": 1                // 至少满足1个条件         }       }     }   } }

参数params.start和params.end代表change_time的起始和结束时间戳（毫秒），params.n为所需最小元素个数。 脚本遍历数组，统计满足条件的元素，并返回一个分数（1或0），决定文档是否包含在结果中。 请替换时间戳为实际值。 此脚本直接操作change_records数组，无需额外路径处理。

通过此方法，可以有效地根据数组元素个数进行条件筛选，避免了原始脚本查询中的路径问题。