Elasticsearch-嵌套对象列表上的脚本筛选器

Question

我正试图找出如何解决这两个问题，我有我的ES 5.6索引。

"mappings": {
    "my_test": {
        "properties": {
            "Employee": {
                "type": "nested",
                "properties": {
                    "Name": {
                        "type": "keyword",
                        "normalizer": "lowercase_normalizer"
                    },
                    "Surname": {
                        "type": "keyword",
                        "normalizer": "lowercase_normalizer"
                    }
                }
            }
        }
    }
}

我需要创建两个单独的脚本过滤器：

1-筛选employee数组大小==3的文档

2-筛选数组第一个元素为“name”==“John”的文档

我试图做一些第一步，但我无法迭代列表。我总是有一个空指针异常错误。

{
  "bool": {
    "must": {
      "nested": {
        "path": "Employee",
        "query": {
          "bool": {
            "filter": [
              {
                "script": {
                  "script" :     """

                   int array_length = 0; 
                   for(int i = 0; i < params._source['Employee'].length; i++) 
                   {                              
                    array_length +=1; 
                   } 
                   if(array_length == 3)
                   {
                     return true
                   } else 
                   {
                     return false
                   }

                     """
                }
              }
            ]
          }
        }
      }
    }
  }
}

Answer 1

正如Val所注意到的，在ElasticSearch的最新版本中，您不能在脚本查询中访问文档的_source。但是elasticsearch允许您在“Score上下文”中访问这个_source。

因此，一个可能的解决方案（但您需要注意性能）是在查询中使用脚本score和min_score组合。

通过elasticsearch中嵌套字段值的总和，可以在堆栈溢出post查询文档中找到这种行为的示例。

在您的例子中，类似这样的查询可以完成以下工作：

POST <your_index>/_search
{
  "min_score": 0.1,
  "query": {
    "function_score": {
      "query": {
        "match_all": {}
      },
      "functions": [
        {
          "script_score": {
            "script": {
              "source": """
              if (params["_source"]["Employee"].length === params.nbEmployee) {
                def firstEmployee = params._source["Employee"].get(0);
                if (firstEmployee.Name == params.name) {
                  return 1;
                } else {
                  return 0;
                }
              } else {
                return 0;
              }
""",
              "params": {
                "nbEmployee": 3,
                "name": "John"
              }
            }
          }
        }
      ]
    }
  }
}

应该在params中设置Employee的数量和名字，以避免该脚本的每个用例都重新编译脚本。