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

问题描述 投票:0回答:1

我升级自:

  • 轮胎剪切2.0至6.6.1
  • ElasticSearch.Net Nuget包2.4.6到6.5.1
  • NEST NuGet包2.4.6至6.5.1

...和我的Nest查询做一个MatchPhrasePrefix停止返回结果。

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

我有一个mainQuery工作正常。如果用户提供urlStartstWith值,则mainQuerybool / MatchPhrasePrefix查询一起获得。

索引包含100到1000个文档。

我试过的东西不起作用:

  • 完全重建了新索引
  • 删除了.Operator(Operator.And),因为在此版本的NEST中不存在(导致编译错误)
  • 将“MaxExpansions”提升到各种值,最高可达5000
  • URL编码urlStartstWith
  • 删除.MinimumShouldMatch(1)线

如果我针对旧的ElasticSearch版本2.0服务器运行使用新NEST库构建的此查询,则它可以正常工作。所以我认为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实例。你可以通过以下方式在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, "StackOverflowSampleJson.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://stackoverflow.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; }
    }
}
  • 创建一个名为StackOverflowSampleJson.json的新文件并粘贴此示例JSON的内容:https://pastebin.com/s5rcHysp
  • 设置StackOverflowSampleJson.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以查看包含该额外查询会使结果计数为零。
c# elasticsearch nest
1个回答
0
投票

好吧,我真的不明白为什么旧的查询适用于elasticsearch 2.0而不是elasticsearch 6.6,但是将内部查询更改为此已经使它适用于ES2和ES6:

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

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

    mainQuery = mainQuery && urlStartWithFilter;
}
© www.soinside.com 2019 - 2024. All rights reserved.