Reo.Core.Elastic 10.0.210

Reo.Core.Elastic

Описание пакета

Reo.Core.Elastic — это библиотека для интеграции с Elasticsearch в .NET-приложениях. Пакет предоставляет инструменты для работы с большими объемами данных, реализации проверок состояния (health checks), сортировки, пагинации и других операций, связанных с Elasticsearch. Он решает задачи эффективного взаимодействия с Elasticsearch, обеспечивая масштабируемость, устойчивость и удобство использования.

Основные функции:

• Пагинация и чанковая обработка данных (Bulk Search) для работы с большими индексами.
• Сортировка результатов по произвольным полям.
• Проверка состояния (Health Check) Elasticsearch-кластера.
• Поддержка аутентификации и настройки подключения через конфигурацию.

Основные компоненты

1. IElasticBulkSearchDescriptor<TModel>

Интерфейс для поиска данных в Elasticsearch чанками. Позволяет получать результаты по частям, обрабатывая большие наборы данных без перегрузки памяти.

2. ElasticsearchHealthCheck

Сервис для проверки работоспособности Elasticsearch-кластера. Используется в ASP.NET Core для мониторинга состояния Elasticsearch.

3. SortingOptions

Класс для настройки параметров сортировки (поле, направление). Используется в методах поиска для упорядочивания результатов.

4. ElasticBulkSearchExtensions

Расширения для построения дескриптора поиска чанками. Обеспечивает интеграцию с Elasticsearch через IElasticBulkSearchDescriptor<TModel>.

Требования

Совместимость с .NET

• .NET 6.0 и выше

Зависимости

• Elasticsearch .NET Client
• Microsoft.Extensions.DependencyInjection

Установка

NuGet Package Manager

Install-Package Reo.Core.Elastic

.NET CLI

dotnet add package Reo.Core.Elastic

Настройка

Регистрация в ASP.NET Core

Добавьте сервисы в Startup.cs или Program.cs:

services.AddElasticsearchCluster(options =>
{
 options.Uris = new[] { "http://localhost:9200" };
 options.UserName = "admin";
 options.Password = "password";
});

Конфигурационные параметры

• Uris: Список URI Elasticsearch-кластеров.
• UserName / Password: Данные для аутентификации (если требуется).
• IsHealthCheckEnabled: Флаг для включения/отключения проверки состояния.

Использование

Пример 1: Проверка состояния Elasticsearch

var healthCheckResult = await services.GetService<IElasticsearchHealthCheck>().CheckHealthAsync();
Console.WriteLine($"Elasticsearch status: {healthCheckResult.Status}");

Пример 2: Поиск чанками с пагинацией

var bulkSearchDescriptor = await elasticClient.BuildBulkSearchDescriptorAsync(new BulkSearchRequest
{
 IndexName = "my_index",
 ChunkSize = 100
});

while (bulkSearchDescriptor.HasMoreResults)
{
 var chunk = await bulkSearchDescriptor.GetNextChunkAsync();
 foreach (var item in chunk)
 {
 Console.WriteLine(item);
 }
}

Пример 3: Сортировка результатов

var sortedResults = await elasticClient.SearchAsync<MyModel>(s =>
 s.SetSorting(new SortingOptions
 {
 SortField = "created_at",
 SortDirection = SortDirection.Descending
 }));

Лицензия

Данный пакет распространяется под лицензией MIT.