Elasticsearch高效筛选：基于数组元素个数的条件查询
本文介绍如何在Elasticsearch中根据数组字段元素个数进行高效筛选，尤其是在需要统计数组中满足特定条件的元素数量时。 问题：我们需要查询change_records数组中，change_time字段值位于指定年份范围内的元素个数不小于n的文档。
直接使用脚本查询可能因路径问题导致失败，例如报错“no field found for [change_records] in mapping with types []”。 exists查询只能验证字段存在性，无法满足条件筛选需求。
解决方案：利用script_score查询和Painless脚本
最佳方案是使用script_score查询结合自定义Painless脚本实现。 此方法的核心在于：
-
Painless脚本统计: 编写Painless脚本遍历
change_records数组，统计change_time在指定年份范围内的元素个数。 - 评分机制: 根据统计结果返回分数：满足条件的文档分数大于0，否则为0。
-
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数组，无需额外路径处理。
通过此方法，可以有效地根据数组元素个数进行条件筛选，避免了原始脚本查询中的路径问题。
