Connecting to Elasticsearch with C#

For Legacy Support Purposes Only

1. Install NEST package

Go to a package manager on visual studio and install NEST

Or you can use the library with NuGet like so:

Install-Package NEST

1	Install-Package NEST

2. Connecting to cluster

var cert = new X509Certificate("/path/to/cluster-ca-certificate.pem");

var uris = new Uri[]
{
    new Uri("https://xxx.xxx.xxx.xxx:9200"),
    new Uri("https://xxx.xxx.xxx.xxx:9200"),
    new Uri("https://xxx.xxx.xxx.xxx:9200")
};

var connectionPool = new SniffingConnectionPool(uris);
var settings = new ConnectionSettings(connectionPool)
    .BasicAuthentication("icelasticsearch", "<Password>")
    .ServerCertificateValidationCallback(
    CertificateValidations.AuthorityIsRoot(cert)
    )
    .DefaultMappingFor<Testing>(i => i.IndexName("testing"));

				
					
				1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

						var cert = new X509Certificate("/path/to/cluster-ca-certificate.pem");
 
var uris = new Uri[]
{
    new Uri("https://xxx.xxx.xxx.xxx:9200"),
    new Uri("https://xxx.xxx.xxx.xxx:9200"),
    new Uri("https://xxx.xxx.xxx.xxx:9200")
};
 
var connectionPool = new SniffingConnectionPool(uris);
var settings = new ConnectionSettings(connectionPool)
    .BasicAuthentication("icelasticsearch", "<Password>")
    .ServerCertificateValidationCallback(
    CertificateValidations.AuthorityIsRoot(cert)
    )
    .DefaultMappingFor<Testing>(i => i.IndexName("testing"));

					

			

3. Indexing

var client = new ElasticClient(settings);
var document = new Testing("this is a test", DateTime.Now);
var indexResponse = client.Index(new IndexRequest<Testing>(document, IndexName.From<Testing>(), 1));
if (!indexResponse.IsValid)
{
    Console.Write("Failed to index document. ");
    if (indexResponse.ServerError != null)
    {
        Console.WriteLine(indexResponse.ServerError);
    }
    else if (indexResponse.OriginalException != null)
    {
        Console.WriteLine(indexResponse.OriginalException);
    }
    else
    {
        Console.WriteLine("Error code: " + indexResponse.ApiCall.HttpStatusCode);
    }
}
else
{
    Console.WriteLine($"Indexed document to index \"testing\" with id 1");
}

				
					
				1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

						var client = new ElasticClient(settings);
var document = new Testing("this is a test", DateTime.Now);
var indexResponse = client.Index(new IndexRequest<Testing>(document, IndexName.From<Testing>(), 1));
if (!indexResponse.IsValid)
{
    Console.Write("Failed to index document. ");
    if (indexResponse.ServerError != null)
    {
        Console.WriteLine(indexResponse.ServerError);
    }
    else if (indexResponse.OriginalException != null)
    {
        Console.WriteLine(indexResponse.OriginalException);
    }
    else
    {
        Console.WriteLine("Error code: " + indexResponse.ApiCall.HttpStatusCode);
    }
}
else
{
    Console.WriteLine($"Indexed document to index \"testing\" with id 1");
}

					

			

4. Getting a document

var getResponse = client.Get<Testing>(new GetRequest<Testing>(1));
if (getResponse.OriginalException != null)
{
    throw getResponse.OriginalException;
}

if (!getResponse.IsValid)
{
    Console.Write("Failed to retrieve document. ");
    if (getResponse.ServerError != null)
        {
            Console.WriteLine(getResponse.ServerError);
        }
        else if (getResponse.OriginalException != null)
        {
            Console.WriteLine(getResponse.OriginalException);
        }
        else
        {
            Console.WriteLine("Error code: " + getResponse.ApiCall.HttpStatusCode);
        }
}
else
{
    Console.WriteLine($"Retrieved document: " +
        $"{{Id: {getResponse.Id}, " +
        $"Description: {getResponse.Source.Description}, " +
        $"Timestamp: {getResponse.Source.Timestamp}}}");
}

				
					
				1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

						var getResponse = client.Get<Testing>(new GetRequest<Testing>(1));
if (getResponse.OriginalException != null)
{
    throw getResponse.OriginalException;
}
 
if (!getResponse.IsValid)
{
    Console.Write("Failed to retrieve document. ");
    if (getResponse.ServerError != null)
        {
            Console.WriteLine(getResponse.ServerError);
        }
        else if (getResponse.OriginalException != null)
        {
            Console.WriteLine(getResponse.OriginalException);
        }
        else
        {
            Console.WriteLine("Error code: " + getResponse.ApiCall.HttpStatusCode);
        }
}
else
{
    Console.WriteLine($"Retrieved document: " +
        $"{{Id: {getResponse.Id}, " +
        $"Description: {getResponse.Source.Description}, " +
        $"Timestamp: {getResponse.Source.Timestamp}}}");
}

					

			

Full sample code

using System;
using Elasticsearch.Net;
using Nest;
using System.Security.Cryptography.X509Certificates;

namespace elasticsearch_client_example
{
    public class Testing
    {
        public string Description;
        public DateTime Timestamp;

        public Testing(string Description, DateTime Timestamp)
        {
            this.Description = Description;
            this.Timestamp = Timestamp;
        }
    }

    public class Client
    {
        static void Main(string[] args)
        {
            var cert = new X509Certificate("/path/to/cluster-ca-certificate.pem");
            
            var uris = new Uri[]
            {
                new Uri("https://xxx.xxx.xxx.xxx:9200"),
                new Uri("https://xxx.xxx.xxx.xxx:9200"),
                new Uri("https://xxx.xxx.xxx.xxx:9200")
            };

            
            var connectionPool = new SniffingConnectionPool(uris);
            var settings = new ConnectionSettings(connectionPool)
                .BasicAuthentication("icelasticsearch", "<Password>")
                .ServerCertificateValidationCallback(
                    CertificateValidations.AuthorityIsRoot(cert)
                )
                .DefaultMappingFor<Testing>(i => i.IndexName("testing"));

            var client = new ElasticClient(settings);

            var document = new Testing("this is a test", DateTime.Now);

            var indexResponse = client.Index(new IndexRequest<Testing>(document, IndexName.From<Testing>(), 1));
            if (!indexResponse.IsValid)
            {
                Console.Write("Failed to index document. ");
                if (indexResponse.ServerError != null)
                {
                    Console.WriteLine(indexResponse.ServerError);
                }
                else if (indexResponse.OriginalException != null)
                {
                    Console.WriteLine(indexResponse.OriginalException);
                }
                else
                {
                    Console.WriteLine("Error code: " + indexResponse.ApiCall.HttpStatusCode);
                }
            }
            else
            {
                Console.WriteLine($"Indexed document to index \"testing\" with id 1");
            }


            var getResponse = client.Get<Testing>(new GetRequest<Testing>(1));
            if (getResponse.OriginalException != null)
            {
                throw getResponse.OriginalException;
            }

            if (!getResponse.IsValid)
            {
                Console.Write("Failed to retrieve document. ");
                if (getResponse.ServerError != null)
                {
                    Console.WriteLine(getResponse.ServerError);
                }
                else if (getResponse.OriginalException != null)
                {
                    Console.WriteLine(getResponse.OriginalException);
                }
                else
                {
                    Console.WriteLine("Error code: " + getResponse.ApiCall.HttpStatusCode);
                }
            }
            else
            {
                Console.WriteLine($"Retrieved document: " +
                    $"{{Id: {getResponse.Id}, " +
                    $"Description: {getResponse.Source.Description}, " +
                    $"Timestamp: {getResponse.Source.Timestamp}}}");
            }
        }
    }
}

				
					
				1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

						using System;
using Elasticsearch.Net;
using Nest;
using System.Security.Cryptography.X509Certificates;
 
namespace elasticsearch_client_example
{
    public class Testing
    {
        public string Description;
        public DateTime Timestamp;
 
        public Testing(string Description, DateTime Timestamp)
        {
            this.Description = Description;
            this.Timestamp = Timestamp;
        }
    }
 
    public class Client
    {
        static void Main(string[] args)
        {
            var cert = new X509Certificate("/path/to/cluster-ca-certificate.pem");
            
            var uris = new Uri[]
            {
                new Uri("https://xxx.xxx.xxx.xxx:9200"),
                new Uri("https://xxx.xxx.xxx.xxx:9200"),
                new Uri("https://xxx.xxx.xxx.xxx:9200")
            };
 
            
            var connectionPool = new SniffingConnectionPool(uris);
            var settings = new ConnectionSettings(connectionPool)
                .BasicAuthentication("icelasticsearch", "<Password>")
                .ServerCertificateValidationCallback(
                    CertificateValidations.AuthorityIsRoot(cert)
                )
                .DefaultMappingFor<Testing>(i => i.IndexName("testing"));
 
            var client = new ElasticClient(settings);
 
            var document = new Testing("this is a test", DateTime.Now);
 
            var indexResponse = client.Index(new IndexRequest<Testing>(document, IndexName.From<Testing>(), 1));
            if (!indexResponse.IsValid)
            {
                Console.Write("Failed to index document. ");
                if (indexResponse.ServerError != null)
                {
                    Console.WriteLine(indexResponse.ServerError);
                }
                else if (indexResponse.OriginalException != null)
                {
                    Console.WriteLine(indexResponse.OriginalException);
                }
                else
                {
                    Console.WriteLine("Error code: " + indexResponse.ApiCall.HttpStatusCode);
                }
            }
            else
            {
                Console.WriteLine($"Indexed document to index \"testing\" with id 1");
            }
 
 
            var getResponse = client.Get<Testing>(new GetRequest<Testing>(1));
            if (getResponse.OriginalException != null)
            {
                throw getResponse.OriginalException;
            }
 
            if (!getResponse.IsValid)
            {
                Console.Write("Failed to retrieve document. ");
                if (getResponse.ServerError != null)
                {
                    Console.WriteLine(getResponse.ServerError);
                }
                else if (getResponse.OriginalException != null)
                {
                    Console.WriteLine(getResponse.OriginalException);
                }
                else
                {
                    Console.WriteLine("Error code: " + getResponse.ApiCall.HttpStatusCode);
                }
            }
            else
            {
                Console.WriteLine($"Retrieved document: " +
                    $"{{Id: {getResponse.Id}, " +
                    $"Description: {getResponse.Source.Description}, " +
                    $"Timestamp: {getResponse.Source.Timestamp}}}");
            }
        }
    }
}

					

			

Connecting to Elasticsearch Using cURL

Connecting to Elasticsearch with Java

Learn about our
Managed platform

Schedule your 1:1 session with one of our open source experts

Schedule a demo