Elasticsearch数组内时间范围筛选：如何高效查找change_records数组中指定时间范围内元素个数达到N的文档？

高效筛选elasticsearch数组内时间范围数据

本文介绍如何高效地从Elasticsearch文档中筛选出change_records数组内，change_time字段值位于特定时间范围且元素个数达到指定数量的文档。 我们面临的挑战是如何在不引发no field found错误的情况下，对数组内元素进行时间范围筛选和计数。

问题：我们需要查询change_records数组中，change_time字段值在指定时间范围（例如，一年）内，元素个数不少于指定数量（例如，10个）的文档。直接使用脚本查询会导致字段未找到的错误。

解决方案：采用script_score查询，结合自定义Painless脚本实现高效筛选。此方法避免了在Filter中直接使用脚本带来的字段访问问题。

查询结构：

{   "query": {     "script_score": {       "query": {         "match_all": {}  // 可根据实际需求添加其他查询条件       },       "script": {         "source": """           int count = 0;           for (Map record : doc['change_records']) {             long changeTime = record['change_time'];             if (changeTime >= params.start && changeTime <= params.end) {               count++;             }           }           return count >= params.n ? 1 : 0;         """,         "lang": "painless",         "params": {           "start": 1609459200000, // 2021年1月1日0时0分0秒的毫秒数           "end": 1704067200000,   // 2024年1月1日0时0分0秒的毫秒数           "n": 10                // 至少需要10个change_time在指定时间范围内         }       }     }   } }

代码解释：

• script_score：使用脚本评分来筛选文档。
• query：可以添加其他查询条件，此处使用match_all匹配所有文档。
• script：Painless脚本，遍历change_records数组。
  • count：计数器，统计满足时间范围条件的元素个数。
  • 循环体：获取每个change_record的change_time，并判断是否在指定范围内。
  • return：如果count大于等于n，返回1（匹配），否则返回0（不匹配）。
• params：脚本参数，包含时间范围的起始和结束时间戳（毫秒），以及所需的最小匹配数量n。

此方法通过脚本评分，有效地解决了直接使用脚本查询时遇到的字段访问问题，并实现了对数组内元素的时间范围筛选和计数功能，从而高效地查找满足条件的文档。 请确保您的change_records字段映射正确，并且change_time字段为数值类型（例如long）。