.net core 如何向elasticsearch中創建索引，插入數據---1

首先我們要建一個webapi工程，然后下載兩個插件：

 1，Nest        2，Elasticsearch.Net

 

 

 

 下載后，下面就上代碼了，首先是elasticsearchHelp幫助類

using Elasticsearch.Net;
using Nest;
using System;
namespace ESAPI.Common
{
    public static class ElasticSearchHelper
    {

        public static  readonly string url = "http://ip:9200/";//這個是elasticsearch遠程訪問ip
        public static  void insert(object t,string index)
        {
            //設置連接字符串，DefaultIndex中的表名要小寫
            var settings = new ConnectionSettings(new Uri(url)).DefaultIndex(index);
            var client = new ElasticClient(settings);
            var doc = t;
            //通過 IndexDocument() 方法插入數據
            var ndexResponse = client.IndexDocument(doc);
        }
        /// <summary>
        /// 單點鏈接到ElasticSearch
        /// </summary>
        /// <param name="url">ElasticSearch的ip地址</param>
        /// <returns></returns>
        public static ElasticClient OneConnectES(string url)
        {

            var node = new Uri(url);
            var settings = new ConnectionSettings(node);
            var client = new ElasticClient(settings);
            return client;
        }
        /// <summary>
        /// 指定多個節點使用連接池鏈接到Elasticsearch集群
        /// </summary>
        /// <param name="serverurl">鏈接ip數組</param>
        /// <returns></returns>
        public static ElasticClient ManyConnectES(string[] serverurl)
        {
            Uri[] nodes = new Uri[serverurl.Length];
            for (int i = 0; i < serverurl.Length; i++)
            {
                nodes[i] = new Uri(serverurl[i]);
            }
            var pool = new StaticConnectionPool(nodes);
            var settings = new ConnectionSettings(pool);
            var client = new ElasticClient(settings);
            return client;
        }
        /// <summary>
        /// 創建索引
        /// </summary>
        /// <param name="elasticClient"></param>
        public static CreateIndexResponse CreateIndex(this IElasticClient elasticClient, string indexName, int numberOfReplicas = 1, int numberOfShards = 5)
        {
            IIndexState indexState = new IndexState
            {
                Settings = new IndexSettings
                {
                    NumberOfReplicas = numberOfReplicas,
                    // [副本數量]
                    NumberOfShards = numberOfShards
                }
            };
            Func<CreateIndexDescriptor, ICreateIndexRequest> func = x => x.InitializeUsing(indexState).Map(m => m.AutoMap());
            CreateIndexResponse response = elasticClient.Indices.Create(indexName, func);
            return response;
        }
    }
}

控制器代碼：

using System;
using ESAPI.Common;
using Microsoft.AspNetCore.Mvc;
namespace ESAPI.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    public class ValuesController : ControllerBase
    {
         /// <summary>
         /// 刪除地址
         /// </summary>
         /// <param name="id"></param>
         [HttpGet("InsertLog")]
         public void InsertLog()
         {
          //插入200條數據
            for (int i = 0; i < 200; i++)
            {
                var d = new
                {
                    Time = DateTime.Now,
                    Num = 5,
                    Name = "12313",
                    info = "hello world!"
                };
                ElasticSearchHelper.insert(d, "demo");

            }
           
        }
        
    }
}

運行程序：

 

 查看elasticsearch可視化界面：

 

很顯然，插入成功了！既然是ELK，后續我還會對logstash，Kibana的安裝和使用也進行詳細的介紹，下一篇，會詳細介紹logstash的安裝和使用！