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數組，無需額外路徑處理。

通過此方法，可以有效地根據數組元素個數進行條件篩選，避免了原始腳本查詢中的路徑問題。