c# - 如何使用 NEST 6.1.0 实现建议完成？

Question

到目前为止，我有这个（用于索引）：

var createIndexResponse = await elasticClient.CreateIndexAsync(indexName, c => c
    .InitializeUsing(indexConfig)
    .Mappings(m => m
        .Map<ElasticsearchModel>(mm => mm
            .Properties(
            p => p
            .Completion(cp => cp
                .Name(elasticsearchModel => elasticsearchModel.StringTest)
                .Analyzer("simple")
                .SearchAnalyzer("simple")
            )
            .Text(t => t.Name(elasticsearchModel => elasticsearchModel.StringTest).Analyzer("customAnalyzerLowercaseSynonymAsciifolding"))
            )
        )
    )
);

我在这篇文章的帮助下得到了这个（但我不确定这是否正确，因为我认为我缺少一些属性来设置最小建议长度等）：https ://stackoverflow.com/a /33796953/7199922

现在我不知道如何查询它以获得建议结果。

我已经用谷歌搜索了 git reposearch suggest site:https://github.com/elastic/elasticsearch-net/并检查了文档，但找不到太多。

Answer 1

我最终得到了以下结果：

模型

public class ElasticsearchModel
{
  public int IntTest { get; set; }
  public string StringTest { get; set; }
  public CompletionField StringTestSuggest
  {
      get
      {
          return new CompletionField
          {
              Input = new[] { StringTest + " ThisIsTheStringTestSuggestField" }
          };
      }
  }
}

索引

var indexSettings = new IndexSettings
{
    NumberOfReplicas = 0, // If this is set to 1 or more, then the index becomes yellow.
    NumberOfShards = 5 
};

var indexConfig = new IndexState
{
    Settings = indexSettings
};

var createIndexResponse = elasticClient.CreateIndex(indexName, c => c
   .InitializeUsing(indexConfig)
   .Mappings(m => m
       .Map<ElasticsearchModel>(mm => mm
           .Properties(
           p => p
           .Completion(cp => cp
               .Name(elasticsearchModel => elasticsearchModel.StringTestSuggest)
               .Analyzer("customAnalyzerLowercaseSynonymAsciifolding")
               .SearchAnalyzer("customAnalyzerLowercaseSynonymAsciifolding")
           )
           .Text(t => t.Name(product => product.IntTest).Analyzer("keyword"))
           .Text(t => t.Name(elasticsearchModel => elasticsearchModel.StringTest).Analyzer("customAnalyzerLowercaseSynonymAsciifolding")) // You can use "standard" here or some other default analyzer.               
           )
       )
   )
);

elasticClient.Refresh(indexName);

查询

public List<ElasticsearchModel> Suggest(string indexName, string query)
{
    var elasticClient = ElasticsearchHelper.DatabaseConnection();

    var response = elasticClient.Search<ElasticsearchModel>(s => s
       .Index(indexName)
        .Suggest(su => su
            .Completion("StringTest", cs => cs
                .Field(f => f.StringTestSuggest)
                .Prefix(query)
                .Fuzzy(f => f
                    .Fuzziness(Fuzziness.Auto)
                )
                .Size(5)
            )
        )
     );

    var suggestions =
        from suggest in response.Suggest["StringTest"]
        from option in suggest.Options
        select new ElasticsearchModel
        {
            IntTest = option.Source.IntTest,
            StringTest = option.Source.StringTest
        };

    return suggestions.ToList();
}

其他事情（为了更容易理解方法）

public void Refresh(string indexName)
{
    var elasticClient = ElasticsearchHelper.DatabaseConnection();
    elasticClient.Refresh(indexName); // This should be called before every query or everytime documents get indexed! Else some results might be missing.
}

启动与 ES DB 的连接

public static class ElasticsearchHelper
{
    public static ElasticClient DatabaseConnection()
    {
        var node = new SingleNodeConnectionPool(new Uri("http://localhost:9200"));
        //var node = new Uri("http://localhost:9200");
        var settings = new ConnectionSettings(node)
            .PrettyJson()
            .DisableDirectStreaming() // Enable for API HTTP request/response debugging.
            .OnRequestCompleted(callDetails =>
            {
                // log out the request
                Console.ForegroundColor = ConsoleColor.Yellow;
                Console.WriteLine("REQUEST:");
                Console.ResetColor();

                if (callDetails.RequestBodyInBytes != null)
                {
                    Console.WriteLine(
                        $"{callDetails.HttpMethod} {callDetails.Uri} \n" +
                        $"{Encoding.UTF8.GetString(callDetails.RequestBodyInBytes)}");
                }
                else
                {
                    Console.WriteLine($"{callDetails.HttpMethod} {callDetails.Uri}");
                }

                // log out the response
                Console.ForegroundColor = ConsoleColor.Yellow;
                Console.WriteLine("RESPONSE:");
                Console.ResetColor();

                if (callDetails.ResponseBodyInBytes != null)
                {
                    Console.WriteLine($"Status: {callDetails.HttpStatusCode}\n" +
                             $"{Encoding.UTF8.GetString(callDetails.ResponseBodyInBytes)}\n" +
                             $"{new string('-', 30)}\n");
                }
                else
                {
                    Console.WriteLine($"Status: {callDetails.HttpStatusCode}\n" +
                             $"{new string('-', 30)}\n");
                }
            }) // For debugging...
        ; // Index name must be lowercase, cannot begin with an underscore, and cannot contain commas.
        var client = new ElasticClient(settings);

        return client;
    }






}

所有学分并感谢您的帮助Russ Cam。