Connexion avec un pilote de langage

Toutes les informations dont un pilote a besoin pour se connecter à votre déploiement se trouvent dans la section "https" d'un justificatif d'identité créé sur la page Certificats d'identité du service. Le tableau ci-après est fourni à titre de référence.

• 0... indique qu'il peut y avoir une ou plusieurs de ces entrées dans un tableau.

De nombreux pilotes Elasticsearch peuvent établir une connexion avec votre déploiement lorsqu'ils disposent de la chaîne de connexion au format URI qui se trouve dans la zone "composed" des informations de connexion. Voir l'exemple suivant :

https://admin:$PASSWORD@d5eeee66-5bc4-498a-b73b-1307848f1eac.8f7bfd8f3faa4218aec56e069eb46187.databases.appdomain.cloud:31821

L'exemple suivant utilise Java pour se connecter.

import io.searchbox.client.JestClientFactory;
import io.searchbox.client.JestResult;
import io.searchbox.client.config.HttpClientConfig;
import io.searchbox.client.JestClient;
import io.searchbox.cluster.Health;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.ssl.SSLContextBuilder;

import javax.net.ssl.SSLContext;
import java.io.File;
import java.security.*;
import java.security.cert.CertificateException;


import java.io.IOException;


public class ESConnect {

    public static void main(String[] args) {

        // Add CA cert to truststore using something like:
        //  keytool -import -alias mycert -file /path/to/cert -keystore ./mycert -storetype pkcs12 -storepass mysecret
        // and use the path of the keystore below
        File truststore = new File("/Users/code/java-example/icdcerts");

        try {
            // use your secret and add the variable containing the truststore that you created above with the secret as a CharArray
            SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(truststore, "mysecret".toCharArray()).build();

            SSLConnectionSocketFactory sslSocketFactory = new SSLConnectionSocketFactory(sslContext);

            // set up a Jest factory
            JestClientFactory factory = new JestClientFactory();

            //configure and build Jest HTTP client with IBM Cloud Databases for Elasticsearch connection strings
            factory.setHttpClientConfig(
                    // add the Elasticsearch host and port
                    new HttpClientConfig.Builder("https://60d1b41b-2478-4767-9fc0-d99b1d00b6d1.bkvfu0nd0m8k95k94ujg.databases.appdomain.cloud:31347")
                            .multiThreaded(true)
                            // Add the credentials username and password
                            .defaultCredentials("admin", "mypassword")
                            .sslSocketFactory(sslSocketFactory)
                            .build());

            // create a JestClient
            JestClient client = factory.getObject();
            // create the call for the cluster health
            Health health = new Health.Builder().build();
            // get the cluster health as a JestResult
            JestResult result = client.execute(health);
            // print out the cluster's health
            System.out.printf("\n\n<------ CLUSTER HEALTH ------>\n%s\n\n", result.getJsonObject());
            // shutdown the connection
            client.close();

        } catch (IOException | KeyStoreException | NoSuchAlgorithmException | KeyManagementException | CertificateException e) {
            e.printStackTrace();
        }

    }

}

L'exemple suivant utilise la bibliothèque Python elasticsearch-py pour se connecter.

from elasticsearch import Elasticsearch
from ssl import create_default_context


context = create_default_context(cafile="path/to/cert.pem")

es = Elasticsearch(
    ['60d1b41b-2478-4767-9fc0-d99b1d00b6d1.bkvfu0nd0m8k95k94ujg.databases.appdomain.cloud'],
    http_auth=('admin', 'password'),
    port='31347',
    ssl_context=context
)

health = es.cluster.health()
print(health)

Prise en charge du certificat TLS du pilote et du certificat propriétaire du service

TLS 1.2 est activé pour toutes les connexions à Databases for Elasticsearch, par conséquent, le pilote que vous utilisez pour la connexion doit pouvoir prendre en charge le chiffrement. Votre déploiement est également accompagné d'un certificat propriétaire de service afin que le pilote puisse vérifier le serveur lors de la connexion.

Pour plus d'informations, voir la foire aux questions sur les certificatsCloud Databases.

Autres pilotes

Elasticsearch possède un large éventail de pilotes de langage. Le tableau en répertorie quelques-uns des plus courants.