.Net 6 WebAPI - Intro to ElasticSearch - Step by Step #aspnetcore

In this article we will explore how to utilise Elastic Search into our .Net 6 API.

You can watch the full video on YouTube

Starting Source code:
https://github.com/mohamadlawand087/Net6-ELK

Finished Project
https://github.com/mohamadlawand087/ELS-Dotnet6

DotNet SDK:
https://dotnet.microsoft.com/download

Visual Studio Code:
https://code.visualstudio.com/](https://code.visualstudio.com/

Docker
https://www.docker.com/products/docker-desktop

We will start by adding ELS nuget package

dotnet add package NEST --version 7.17.0

Once our package is installed we can verify it inside our csproj file. The next step is to create our Model which will represent the data which will be using to save in ELS

public class Product
    {
        public int Id { get; set; }
        public string Title { get; set; }
        public string Description { get; set; }
        public int Quantity { get; set; }
    }

Then we need to update our configuration, inside our appsettings.json we need to change it to the following

{
  "Serilog": {
    "MinimumLevel": {
      "Default": "Information",
      "Override": {
        "Microsoft": "Information",
        "System": "Warning"
      }
    }
  },
  "ELKConfiguration": {
    "Uri": "http://localhost:9200",
    "index": "products",
  },
  "AllowedHosts": "*"
}

Inside the root folder of our application, create a new folder called extensions. Then create a class called ElasticSearchExtensions which is our ELS extension method which will be used to initialise ELS when our application starts

public static class ElasticSearchExtensions
    {
        public static void AddElasticsearch(
            this IServiceCollection services, IConfiguration configuration)
        {
            var url = configuration["ELKConfiguration:url"];
            var defaultIndex = configuration["ELKConfiguration:index"];

            var settings = new ConnectionSettings(new Uri(url)).BasicAuthentication(userName, pass)
                .PrettyJson()
                .DefaultIndex(defaultIndex);

            AddDefaultMappings(settings);

            var client = new ElasticClient(settings);

            services.AddSingleton<IElasticClient>(client);

            CreateIndex(client, defaultIndex);
        }

        private static void AddDefaultMappings(ConnectionSettings settings)
        {
            settings
                .DefaultMappingFor<Product>(m => m
                    .Ignore(p => p.Price)
                    .Ignore(p => p.Measurement)
                );
        }

        private static void CreateIndex(IElasticClient client, string indexName)
        {
            var createIndexResponse = client.Indices.Create(indexName,
                index => index.Map<Product>(x => x.AutoMap())
            );
        }
    }

Now that our extension method has been added, its time to add it to our program.cs so it will be injected into our application startup

builder.Services.AddElasticsearch(builder.Configuration);

Now that our application knows about ELS we need to create our controller ProductsController so we can interact with our ELS.

public class ProductsController : ControllerBase
{
    private readonly IElasticClient _elasticClient;
    private readonly ILogger<ProductsController> _logger;

    public ProductsController(
                        IElasticClient elasticClient,
                        ILogger<ProductsController> logger)
    {
        _logger = logger;
        _elasticClient = elasticClient;
    }

    [HttpGet(Name = "GetAllProducts")]
    public async Task<IActionResult> Get(string keyword)
    {
       var result = await _elasticClient.SearchAsync<Product>(
                        s => s.Query(
                            q => q.QueryString(
                                d => d.Query('*' + keyword + '*')
                            )).Size(5000));

        _logger.LogInformation("ProductsController Get - ", DateTime.UtcNow);
       return Ok(result.Documents.ToList());
    }

    [HttpPost(Name = "AddProduct")]
    public async Task<IActionResult> Post(Product product)
    {
        // Add product to ELS index
        var product1 = new Product 
        {
            Description = "Product 1",
            Id = 1,
            Price = 200,
            Measurement = "2",
            Quantity = 90,
            ShowPrice = true,
            Title = "Nike Shoes",
            Unit = "10"
        };

        // Index product dto
        await _elasticClient.IndexDocumentAsync(product);

        _logger.LogInformation("ProductsController Get - ", DateTime.UtcNow);
       return Ok();
    }
}

Please add your question below and follow me here and subscribe to my YouTube Channel.

Blog

.Net 6 WebAPI - Intro to ElasticSearch - Step by Step #aspnetcore

Mohamad Lawand

Join Our Newsletter. No Spam, Only the good stuff.

Related