Поддерживает ли Elasticsearch Nest обновление по запросу - PullRequest
Новая
       7

Поддерживает ли Elasticsearch Nest обновление по запросу

0 голосов
/ 27 апреля 2018

Я хочу использовать метод UpdateByQuery на клиенте высокого уровня, но не могу найти документацию для Nest. У них есть отличная документация, если я хочу сделать запрос CURL, но ничего для NEST. https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update-by-query.html Если у кого-то есть пример использования этого файла или он может поделиться найденной документацией, это было бы здорово!

1 Ответ

0 голосов
/ 28 апреля 2018

Обновление по API запросов поддерживается в NEST. Вот пример адаптированный из интеграционных тестов . Документация NEST для API индексов и обновлений планируется:) 

private static void Main()
{
    var pool = new SingleNodeConnectionPool(new Uri("http://localhost:9200"));

    var settings = new ConnectionSettings(pool)
        .DefaultMappingFor<Test>(m => m
            .IndexName("tests")
            .TypeName("test")
        );

    var client = new ElasticClient(settings);
    var index = IndexName.From<Test>();

    if (client.IndexExists(index).Exists)
        client.DeleteIndex(index);

    client.CreateIndex(index, c => c
        .Mappings(m => m
            .Map<Test>(map => map
                .Properties(props => props
                    .Text(s => s.Name(p => p.Text))
                    .Keyword(s => s.Name(p => p.Flag))
                )
            )
        )
    );

    client.Bulk(b => b
        .IndexMany(new[] {
            new Test { Text = "words words", Flag = "bar" },
            new Test { Text = "words words", Flag = "foo" }
        })
        .Refresh(Refresh.WaitFor)
    );

    client.Count<Test>(s => s
        .Query(q => q
            .Match(m => m
                .Field(p => p.Flag)
                .Query("foo")
            )
        )
    );

    client.UpdateByQuery<Test>(u => u
        .Query(q => q
            .Term(f => f.Flag, "bar")
        )
        .Script("ctx._source.flag = 'foo'")
        .Conflicts(Conflicts.Proceed)
        .Refresh(true)
    );

    client.Count<Test>(s => s
        .Query(q => q
            .Match(m => m
                .Field(p => p.Flag)
                .Query("foo")
            )
        )
    );
}

public class Test
{
    public string Text { get; set; }
    public string Flag { get; set; }
}

Обратите внимание, что счетчик из первого вызова API Count равен 1, а во втором вызове API Count после вызова API Update By Query - 2.

...