Elasticsearch中的多字段聚合

Question

我在elasticsearch中有一个文档索引，每个文档有480个字段。我试图做的是搜索一个词（例如“Apple”），并获得所有其值与搜索词匹配的唯一字段名。所以如果我的文档是：

{
  "field1": "123",
  "field2": "apple stock",
  "field3": "red apple",
},
{
  "field1": "apple",
  "field2": "apple stock",
  "field3": "green apple",
}

作为查询的结果，我希望得到如下所示的聚合：

{
  "field1": ["apple"],
  "field2": ["apple stock"],
  "field3": ["red apple", "green apple"]
}

由于每个文档都有480个字段，所以我更喜欢执行multi_match查询，而不是使用包含所有字段的筛选器：

"query": {
        "multi_match": {
            "query": "apple",
            "type": "phrase"
        }
    }

这个查询在ElasticSearch中可能吗？

Answer 1

由于您“不知道您不知道什么”，您可能不得不求助于脚本化的度量聚合：

POST myindex/_search
{
  "size": 0,
  "query": {
    "multi_match": {
      "query": "apple",
      "type": "phrase"
    }
  },
  "aggs": {
    "fields_breakdown": {
      "scripted_metric": {
        "params": {
          "phrase": "apple"
        }, 
        "init_script": "state.key_map = [:];",
        "map_script": """
          for (def pair : params._source.entrySet()) {
            def val = pair.getValue();
            
            if (!(val instanceof String) || !val.toLowerCase().contains(params.phrase.toLowerCase())) {
              continue;
            }
            
            def key = pair.getKey();
            
            if (!state.key_map.containsKey(key)) {
              state.key_map[key] = [val];
            } else if (!state.key_map[key].contains(val)) {
              state.key_map[key].add(val);
            }
          }
        """,
        "combine_script": "return state",
        "reduce_script": "return states"
      }
    }
  }
}

这段代码不能很好地伸缩（取决于您的索引大小），所以要小心使用它，也许可以分批使用（使用更严格的查询，或者限制一次聚合的字段数）。

顺便说一句，我之前提出了一个在类术语聚合中过滤子字符串的解决方案--它可能与这里的您相关。