ElasticSearch / Nest MatchPhrasePrefix 在版本升级后停止工作

Question

我升级自：

ElasticSearch 2.0 到 6.6.1
ElasticSearch.Net Nuget 包 2.4.6 到 6.5.1
NEST NuGet 包 2.4.6 到 6.5.1

...我的 Nest 查询执行 MatchPhrasePrefix 时停止返回结果。

该软件是网页的搜索引擎，其中一项功能应该是让您将结果限制为以特定路径开头的 URL，例如 http://example.com/blog 以查看搜索结果中只有博文。

我有一个 mainQuery 可以正常工作。如果用户提供 urlStartstWith 值，则 mainQuery 会与 bool / MatchPhrasePrefix 查询一起进行运算。

索引包含 100 到 1000 个文档。

我尝试过但无效的方法：

完全重建新索引
删除了 .Operator(Operator.And) 因为它在这个版本的 NEST 中不存在（导致编译错误）
将 "MaxExpansions" 提高到各种值，最高可达 5000
URL-编码urlStartstWith
删除 .MinimumShouldMatch(1) 行

如果我运行使用新的 NEST 库针对旧的 ElasticSearch 2.0 版服务器构建此查询，它就可以工作。所以我认为 ElasticSearch 本身已经发生了一些变化。

查询

var urlStartWithFilter = esQuery.Bool(b =>
    b.Filter(m =>
        m.MatchPhrasePrefix(pre =>
            pre
                //.MaxExpansions(5000) //did nothing
                //.Operator(Operator.And) //does not exist in new version of NEST
                .Query(urlStartsWith)
                .Field(f => f.Url))
        )
        .MinimumShouldMatch(1)
    );

mainQuery = mainQuery && urlStartWithFilter;

按要求 - 从头到尾示例

这是一个说明问题的示例，与我查询实际项目的网页索引的方式非常接近。

获取 ElasticSearch 6.6.1 实例运行ning。您可以通过以下方式在 docker 中执行此操作：

docker pull docker.elastic.co/elasticsearch/elasticsearch:6.6.1
docker network create esnetwork --driver=bridge
docker run -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" --name elasticsearch -d --network esnetwork docker.elastic.co/elasticsearch/elasticsearch:6.6.1

创建一个新的 .Net Framework 4.6.1 控制台应用程序。将以下内容粘贴到 Program.cs

using Nest;
using System;
using System.Collections.Generic;

namespace Loader
{
    class Program
    {

        const string ELASTIC_SERVER = "http://localhost:9200";
        const string DEFAULT_INDEX = "stack_overflow_api";

        private static Uri es_node = new Uri(ELASTIC_SERVER);
        private static ConnectionSettings settings = new ConnectionSettings(es_node).DefaultIndex(DEFAULT_INDEX);
        private static ElasticClient client = new ElasticClient(settings);

        private static bool include_starts_with = true;

        static void Main(string[] args)
        {
            WriteMainMenu();
        }


        static void WriteMainMenu()
        {
            //Console.Clear();
            Console.WriteLine("");
            Console.WriteLine("");
            Console.WriteLine("What to do?");
            Console.WriteLine("1 - Load Sample Data into ES");
            Console.WriteLine("2 - Run a query WITHOUT StartsWith");
            Console.WriteLine("3 - Run a query WITH StartsWith");
            Console.WriteLine("[Enter] to exit.");
            Console.WriteLine("");
            Console.WriteLine("");

            var option = Console.ReadLine();

            if (option == "1")
            {
                LoadSampleData();
            }
            else if (option == "2")
            {
                include_starts_with = false;
                RunStartsWithQuery();
            }
            else if (option == "3")
            {
                include_starts_with = true;
                RunStartsWithQuery();
            }

            //- exit
        }

        private static void LoadSampleData()
        {
            var existsResponse = client.IndexExists(DEFAULT_INDEX);
            if (existsResponse.Exists) //delete existing mapping (and data)
            {
                client.DeleteIndex(DEFAULT_INDEX);
            }

            var rebuildResponse = client.CreateIndex(DEFAULT_INDEX, c => c.Settings(s => s.NumberOfReplicas(1).NumberOfShards(5)));
            var response2 = client.Map<Item>(m => m.AutoMap());

            var data = GetSearchResultData();

            Console.WriteLine($"Indexing {data.Count} items...");
            var response = client.IndexMany<Item>(data);
            client.Refresh(DEFAULT_INDEX);

            WriteMainMenu();
        }

        private static List<Item> GetSearchResultData()
        {
            var jsonPath = System.IO.Path.Combine(Environment.CurrentDirectory, "WhosebugSampleJson.json");
            var jsondata = System.IO.File.ReadAllText(jsonPath);
            var searchResult = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Item>>(jsondata);
            return searchResult;
        }

        private static void RunStartsWithQuery()
        {
            Console.WriteLine("Enter a search query and press enter, or just press enter to search for the default of 'Perl'.");
            var search = Console.ReadLine().ToLower();

            if (string.IsNullOrWhiteSpace(search))
            {
                search = "Perl";
            }   

            Console.WriteLine($"Searching for {search}...");

            var result = client.Search<Item>(s => s
                .Query(esQuery => {


                    var titleQuery = esQuery.Match(m => m
                            .Field(p => p.title)
                            .Boost(1)
                            .Query(search)
                        );

                    var closedReasonQuery = esQuery.Match(m => m
                        .Field(p => p.closed_reason)
                        .Boost(1)
                        .Query(search)
                    );

                    // search across a couple fields
                    var mainQuery = titleQuery || closedReasonQuery;

                    if (include_starts_with)
                    {
                        var urlStartsWith = "https://whosebug.com/questions/";

                        var urlStartWithFilter = esQuery.Bool(b =>
                            b.Filter(m =>
                                m.MatchPhrasePrefix(pre =>
                                    pre
                                        //.MaxExpansions(5000) //did nothing
                                        //.Operator(Operator.And) //does not exist in new version of NEST
                                        .Query(urlStartsWith)
                                        .Field(f => f.link))
                                )
                                .MinimumShouldMatch(1)
                            );

                        mainQuery = mainQuery && urlStartWithFilter;
                    }

                    return mainQuery;
                })
            );

            if (result.IsValid == false)
            {
                Console.WriteLine("ES Query had an error");
            }
            else if (result.Hits.Count > 0)
            {
                Console.ForegroundColor = ConsoleColor.DarkGreen;
                Console.WriteLine($"Found {result.Hits.Count} results:");

                foreach (var item in result.Hits)
                {
                    Console.WriteLine($"    {item.Source.title}");
                }
                Console.ForegroundColor = ConsoleColor.White;
            }
            else
            {
                Console.ForegroundColor = ConsoleColor.DarkRed;
                Console.WriteLine($"Found 0 results");
                Console.ForegroundColor = ConsoleColor.White;
            }

            WriteMainMenu();

        }
    }


    public class Item
    {
        public List<string> tags { get; set; }
        //public Owner owner { get; set; }
        public bool is_answered { get; set; }
        public int view_count { get; set; }
        public int answer_count { get; set; }
        public int score { get; set; }
        public int last_activity_date { get; set; }
        public int creation_date { get; set; }
        public int last_edit_date { get; set; }
        public int question_id { get; set; }
        public string link { get; set; }
        public string title { get; set; }
        public int? accepted_answer_id { get; set; }
        public int? closed_date { get; set; }
        public string closed_reason { get; set; }
        public int? community_owned_date { get; set; }
    }
}

创建一个名为 WhosebugSampleJson.json 的新文件并粘贴此示例的内容 JSON：https://pastebin.com/s5rcHysp
设置 WhosebugSampleJson.json 输出到构建目录，方法是右键单击它，选择属性，然后将 Copy to Output Directory 更改为 Always
运行应用程序。
选择1 - Load Sample Data into ES填充索引
选择 2 - Run a query WITHOUT StartsWith 到运行没有 StartsWith / MatchPhrasePrefix 的查询以查看正常查询是否有效
选择 3 - Run a query WITH StartsWith 以查看包含该额外查询会使结果计数为零。

Answer 1

好的，我真的不明白为什么旧查询适用于 elasticsearch 2.0 而不适用于 elasticsearch 6.6，但是将内部查询更改为这样可以使其适用于 ES2 和 ES6：

if (include_starts_with)
{
    var urlStartsWith = "https://whosebug.com/questions/";

    var urlStartWithFilter = esQuery.MatchPhrasePrefix(pre => pre
        .Query(urlStartsWith)
        .Field(f => f.link)
    );

    mainQuery = mainQuery && urlStartWithFilter;
}

ElasticSearch / Nest MatchPhrasePrefix 在版本升级后停止工作

ElasticSearch / Nest MatchPhrasePrefix Stopped Working After Version Upgrade

c#

elasticsearch

nest