Elasticsearch：如何按匹配的嵌套文档数量过滤？

问题分析 #

你之前的脚本错误在于遍历嵌套文档的方式：doc['activities'].values无法直接获取完整的嵌套文档对象，Elasticsearch的脚本中，嵌套字段是以多值数组的形式存储的（比如doc['activities.queue']是所有activities的queue值数组，doc['activities.status']是所有status值数组），需要通过索引对应匹配每个activity的所有条件。

方法一：修正后的脚本过滤（推荐） #

使用bool.filter中的script直接过滤，而非script_score，逻辑更清晰，且能正确计数符合条件的嵌套文档：

{
  "_source": false,
  "from": 0,
  "size": 50,
  "track_total_hits": true,
  "query": {
    "bool": {
      "must": [
        {
          "bool": {
            "must_not": {
              "exists": { "field": "deleted" }
            }
          }
        }
      ],
      "filter": [
        // 先确保存在至少一个符合条件的activity（可选，减少脚本计算量）
        {
          "nested": {
            "path": "activities",
            "query": {
              "bool": {
                "must": [
                  { "match": { "activities.queue": "669820d5-f08a-4624-a18d-278f8d3ad70e" } },
                  { "bool": { "must_not": { "exists": { "field": "activities.assignee" } } } },
                  { "match": { "activities.status": "PENDING" } },
                  { "bool": { "must_not": { "exists": { "field": "activities.deleted" } } } }
                ]
              }
            }
          }
        },
        // 脚本计数恰好为2的情况
        {
          "script": {
            "source": """
              int count = 0;
              def queues = doc['activities.queue'].values;
              def statuses = doc['activities.status'].values;

              for (int i = 0; i < queues.length; i++) {
                // 检查当前索引的activity是否符合所有条件
                boolean queueMatch = queues[i] == params.queue;
                boolean statusMatch = statuses[i] == params.status;
                boolean noAssignee = !doc.containsKey('activities.assignee') || !doc['activities.assignee'][i].exists;
                boolean noDeleted = !doc.containsKey('activities.deleted') || !doc['activities.deleted'][i].exists;

                if (queueMatch && statusMatch && noAssignee && noDeleted) {
                  count++;
                }
              }
              return count == 2;
            """,
            "params": {
              "queue": "669820d5-f08a-4624-a18d-278f8d3ad70e",
              "status": "PENDING"
            }
          }
        }
      ]
    }
  }
}

关键修正点： #

• 分别获取每个嵌套字段的多值数组，通过索引对应每个activity的属性
• 正确判断单个activity是否存在assignee/deleted字段
• 直接返回布尔值作为过滤条件，无需计算分数

方法二：无脚本的Hack实现（不推荐复杂场景） #

通过组合多个nested查询，利用minimum_should_match控制匹配数量：

{
  "_source": false,
  "from": 0,
  "size": 50,
  "track_total_hits": true,
  "query": {
    "bool": {
      "must": [
        {
          "bool": {
            "must_not": { "exists": { "field": "deleted" } }
          }
        },
        // 必须至少匹配2个符合条件的activity
        {
          "bool": {
            "should": [
              {
                "nested": {
                  "path": "activities",
                  "query": {
                    "bool": {
                      "must": [
                        { "match": { "activities.queue": "669820d5-f08a-4624-a18d-278f8d3ad70e" } },
                        { "bool": { "must_not": { "exists": { "field": "activities.assignee" } } } },
                        { "match": { "activities.status": "PENDING" } },
                        { "bool": { "must_not": { "exists": { "field": "activities.deleted" } } } }
                      ]
                    }
                  }
                }
              },
              {
                "nested": {
                  "path": "activities",
                  "query": {
                    "bool": {
                      "must": [
                        { "match": { "activities.queue": "669820d5-f08a-4624-a18d-278f8d3ad70e" } },
                        { "bool": { "must_not": { "exists": { "field": "activities.assignee" } } } },
                        { "match": { "activities.status": "PENDING" } },
                        { "bool": { "must_not": { "exists": { "field": "activities.deleted" } } } }
                      ]
                    }
                  }
                }
              }
            ],
            "minimum_should_match": 2
          }
        }
      ],
      "must_not": [
        // 排除匹配至少3个符合条件的activity的情况
        {
          "bool": {
            "should": [
              {
                "nested": {
                  "path": "activities",
                  "query": {
                    "bool": {
                      "must": [
                        { "match": { "activities.queue": "669820d5-f08a-4624-a18d-278f8d3ad70e" } },
                        { "bool": { "must_not": { "exists": { "field": "activities.assignee" } } } },
                        { "match": { "activities.status": "PENDING" } },
                        { "bool": { "must_not": { "exists": { "field": "activities.deleted" } } } }
                      ]
                    }
                  }
                }
              },
              {
                "nested": {
                  "path": "activities",
                  "query": {
                    "bool": {
                      "must": [
                        { "match": { "activities.queue": "669820d5-f08a-4624-a18d-278f8d3ad70e" } },
                        { "bool": { "must_not": { "exists": { "field": "activities.assignee" } } } },
                        { "match": { "activities.status": "PENDING" } },
                        { "bool": { "must_not": { "exists": { "field": "activities.deleted" } } } }
                      ]
                    }
                  }
                }
              },
              {
                "nested": {
                  "path": "activities",
                  "query": {
                    "bool": {
                      "must": [
                        { "match": { "activities.queue": "669820d5-f08a-4624-a18d-278f8d3ad70e" } },
                        { "bool": { "must_not": { "exists": { "field": "activities.assignee" } } } },
                        { "match": { "activities.status": "PENDING" } },
                        { "bool": { "must_not": { "exists": { "field": "activities.deleted" } } } }
                      ]
                    }
                  }
                }
              }
            ],
            "minimum_should_match": 3
          }
        }
      ]
    }
  }
}

优缺点： #

• ✅ 无需编写脚本
• ❌ 条件重复维护成本高，过滤条件变更时需修改多处
• ❌ 极端场景可能误判（比如同一个嵌套文档被多次匹配）

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