3

我正在使用带有 Nest C# 客户端的 2.1 版和 2.0 (alpha) 客户端...我正在尝试批量插入一些记录，但是，服务器返回错误。我正在使用与 Linux 服务器通信的 Windows 客户端上的客户端（但我认为这无关紧要）。 

    public static void AddQuestionsToElasticSearch()
    {
        var es = new ElasticsearchClient(new ConnectionConfiguration(
            new Uri("http://elasticserver:9200"))
        );

        var foobars = new FooBar().Parse();
        var descriptor = new BulkDescriptor();

        descriptor.CreateMany<FooBar>(foobars, (bd, q) => bd.Id(q.Id.ToString()).Index("foobars"));

        Console.WriteLine($"Inserting foobars into ES...");
        var sw = new Stopwatch();
        sw.Start();

        var result = es.Bulk<FooBar>(descriptor);

        sw.Stop();
        Console.WriteLine($"Finished inserting foobars {GetTimeTaken(sw.Elapsed)}");
    }

更新 - 错误信息

我得到的错误是在 Bulk() 方法返回的响应中......返回的 BulkResponse 的两个属性是：

OriginalException：“远程服务器返回错误：（400）错误请求”

ServerError.Error：“验证失败：1：未添加请求”

4

1 回答 1

5

您犯了一个简单的错误 - 您使用ElasticsearchClientElasticsearch.Net 中的低级别发出请求，但向它发送来自 NEST 的强类型批量请求。纠正很简单，你只需要使用ElasticClientfrom NEST

public static void AddQuestionsToElasticSearch()
{
    var es = new ElasticClient(new Uri("http://elasticserver:9200"));

    var foobars = new FooBar().Parse();
    var descriptor = new BulkDescriptor();

    descriptor.CreateMany<FooBar>(foobars, (bd, q) => bd.Id(q.Id.ToString()).Index("foobars"));

    Console.WriteLine($"Inserting foobars into ES...");
    var sw = new Stopwatch();
    sw.Start();

    var result = es.Bulk(descriptor);

    sw.Stop();
    Console.WriteLine($"Finished inserting foobars {GetTimeTaken(sw.Elapsed)}");
}

ElasticClient来自 NEST 是高级客户端，并在幕后使用ElasticsearchClientElasticsearch.Net。

于 2016-01-12T21:56:25.060 回答