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}}}");
            }
        }
    }
}

By Instaclustr Support

Previous Article Connecting to Elasticsearch Using cURL Next Article Connecting to Elasticsearch with Java

Need Support?

Learn More

Experiencing difficulties on the website or console?

Status page for known incidents

Already have an account?

Need help with your cluster?

Contact Support

Why sign up?

To experience the ease of creating and managing clusters via the Instaclustr Console

Spin up a cluster in minutes

Free Trial