如何从每个索引中获取搜索结果

Question

我在 Node Js 中使用 Elastic Search 来查询多个索引，如何从每个索引中获取结果：

var esClient = new elasticsearch.Client({host: config.elasticsearch.host});

esClient.search({
    index: ["abc", "xyz"],
    type: ["abc", "xyz"],
    body: {
        query: {
            multi_match: {
                query: q,
                type: "cross_fields",
                analyzer: "ac_search_analyzer",
                operator: op,
                fields: ["a^4", "b^4", "c^2", "d", "e"]
            }
        }
    },
    _sourceInclude: ["a", "b", "c"],
    size: 10
}).then(function (resp) {
    //do something
}

现在我只从 abc 获得所有 10 个结果，而没有来自 xyz 的结果。我应该怎么做才能得到来自abc 的 5 个结果和来自xyz 的 5 个结果。

Answer 1

您可以使用msearch 在一次往返中从每个索引中查询 5 个结果。

例子：

client.msearch({
        body: [
            { _index: "abc", type: "abc"},
            {
                query : { 
                    multi_match: {
                        query: q,
                        type: "cross_fields",
                        analyzer: "ac_search_analyzer",
                        operator: op,
                        fields: ["a^4", "b^4", "c^2", "d", "e"]
                    }
                }, 
                size : 5,
                _source : ["a", "b", "c"]
            },
            { _index: "xyz", type: "xyz"},
            {
                query : { 
                    multi_match: {
                        query: q,
                        type: "cross_fields",
                        analyzer: "ac_search_analyzer",
                        operator: op,
                        fields: ["a^4", "b^4", "c^2", "d", "e"]
                    }
                }, 
                size : 5,
                _source : ["a", "b", "c"]
            }
        ],
}).then(function (resp) {
  console.log(resp);
});

更新示例 2

msearch_query ={
                query : { 
                    multi_match: {
                        query: q,
                        type: "cross_fields",
                        analyzer: "ac_search_analyzer",
                        operator: op,
                        fields: ["a^4", "b^4", "c^2", "d", "e"]
                    }
                }, 
                size : 5,
                _source : ["a", "b", "c"]
            };
client.msearch({
        body: [
            { _index: "test", type: "test"},
            msearch_query,
            { _index: "new", type: "new"},
            msearch_query
        ],
}).then(function (resp) {
  console.log(resp);
});