.NET 操作ES .net 操作influxdb2.0 封装

    public class Person
    {
        public int Id { get; set; }

        [Keyword]
        public string FirstName { get; set; }
        public string LastName { get; set; }
    }

            var settings = new ConnectionSettings(new Uri("http://127.0.0.1:9200"))
                            .DefaultIndex("people");
            var client = new ElasticClient(settings);

            List<Person> list = new();
            for (int i = 0; i < 10; i++)
            {
                Person person = new Person();
                person.Id = i;
                person.FirstName = "张三"+i; 
                list.Add(person);
            }
            client.IndexMany<Person>(list);

         var searchResponse = client.Search<Person>(s => s
                    .From(0)
                .Size(10)
                .Query(q => q
                         .Match(m => m
                            .Field(f => f.FirstName)
                            .Query("张三")
                         )
                    )
                );

            var people = searchResponse.Documents;
            Console.WriteLine("查询结果");
            foreach (var item in people)
            {
                Console.WriteLine($"id:{item.Id},firstname:{item.FirstName},lastname:{item.LastName}");
            }

      var ss = client.Search<Person>(s => s.Query(
                      m => m.Bool(
                          m => m.Must(
                              x => x.Match(m => m.Field(f => f.FirstName).Query("张三1")
                                           ), mm => mm.Range(xx => xx.Field(f => f.Id).GreaterThan(3))
                                     )
                               )

                      )
                ).Documents;

        public static string Post(QueryParam queryParam, string url = "http://127.0.0.1:9200/_xpack/sql?format=csv")
        {
            HttpWebRequest request = null;
            try
            {
                request = (HttpWebRequest)WebRequest.Create(url);
                var data = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(queryParam));
                //request.Accept = "application/json; charset=UTF-8"; // 设置响应数据的ContentType
                request.Method = "POST";
                request.ContentType = "application/json"; // 设置请求数据的ContentType
                request.ContentLength = data.Length;
                request.Timeout = 90000;
                // 设置入参
                using (var stream = request.GetRequestStream())
                {
                    stream.Write(data, 0, data.Length);
                }
                // 发送请求
                var response = (HttpWebResponse)request.GetResponse();
                // 读取出参
                using (var resStream = response.GetResponseStream())
                {
                    using (var reader = new StreamReader(resStream, Encoding.UTF8))
                    {
                        return reader.ReadToEnd();
                    }
                }
            }
            catch (Exception ex)
            {
                return null;
            }
            finally
            {
                // 释放连接
                if (request != null) request.Abort();
            }
        }
    public class QueryParam
    {
        public string query { get; set; }
    }