Elasticsearch:Hubungkan ke kluster dari aplikasi

Sebelum Anda mulai

Dapatkan titik akhir kluster

Anda dapat menghubungkan ke kluster Elasticsearch melalui titik akhir internal melalui jaringan pribadi VPC atau titik akhir publik.

• Titik akhir internal: Menyediakan koneksi berlatensi rendah dan stabilitas tinggi ke kluster Elasticsearch Anda. Titik akhir ini diaktifkan secara default saat pembuatan kluster.

• Titik akhir publik: Memungkinkan Anda menghubungkan ke kluster Elasticsearch melalui internet. Anda harus mengaktifkan titik akhir ini secara manual.

Aktifkan akses publik

1. Masuk ke Konsol Elasticsearch dan buka halaman Basic Information instans Anda.

2. Pada panel navigasi, pilih Configuration and Management > Security Settings, lalu aktifkan akses publik. Akses publik diaktifkan setelah status kluster berubah dari Initializing menjadi Valid.

   Setelah akses publik diaktifkan, titik akhir publik memiliki format es-cn-<instance_ID>.public.elasticsearch.aliyuncs.com. Daftar putih IP publik kosong secara default dan harus dikonfigurasi.

   Penting

   Penggunaan titik akhir publik dapat membahayakan keamanan kluster Elasticsearch Anda. Jika menggunakan titik akhir publik, pastikan untuk mengonfigurasi daftar putih IP dan menonaktifkan akses publik setelah selesai.

Konfigurasikan daftar putih IP

Untuk mengamankan kluster Anda, tambahkan alamat IP perangkat yang akan digunakan untuk mengakses ke daftar putih jaringan pribadi VPC atau daftar putih IP publik kluster Elasticsearch. Hanya perangkat dengan alamat IP dalam daftar putih yang dapat mengakses kluster.

1. Dapatkan alamat IP perangkat yang akan digunakan untuk akses.

   Tabel berikut menjelaskan cara mendapatkan alamat IP untuk berbagai skenario.

   Skenario	Alamat IP	Metode
   Hubungkan ke kluster Elasticsearch dari perangkat lokal	Alamat IP publik perangkat lokal Anda. Jika perangkat lokal Anda berada dalam jaringan area lokal (LAN), seperti jaringan rumah atau perusahaan, tambahkan alamat IP publik gerbang LAN ke daftar putih IP publik kluster.	Jalankan perintah curl ipinfo.io/ip untuk menemukan IP publik perangkat lokal Anda.
   Hubungkan ke kluster Elasticsearch dari Instance ECS di VPC berbeda	IP publik Instance ECS tersebut.	Masuk ke Konsol ECS untuk melihatnya dalam daftar instans.
   Hubungkan ke kluster Elasticsearch dari Instance ECS di VPC yang sama	IP privat Instance ECS tersebut.	Masuk ke Konsol ECS untuk melihatnya dalam daftar instans.

2. Tambahkan alamat IP tersebut ke grup daftar putih.

   1. Masuk ke Konsol Elasticsearch. Pada halaman Basic Information instans Anda, pilih Configuration and Management > Security Settings di panel navigasi, lalu klik Modify untuk mengonfigurasi jaringan pribadi VPC atau daftar putih IP publik.

   2. Klik Configure di sebelah kanan grup default. Pada kotak dialog yang muncul, tambahkan alamat IP ke daftar putih jaringan pribadi VPC atau IP publik. Anda dapat menambahkan hingga 300 alamat IP atau Blok CIDR ke kluster. Pisahkan beberapa entri dengan koma (,) tanpa spasi di sekitarnya.

      • Anda juga dapat mengklik Add IP address whitelist Group untuk membuat grup kustom.

      • Grup daftar putih hanya digunakan untuk manajemen alamat IP dan tidak memengaruhi izin akses. Semua alamat IP di seluruh grup memiliki izin yang sama.

      Jenis konfigurasi	Format dan contoh	Catatan penting
      Format alamat IPv4	IP tunggal: 192.168.0.1 Blok CIDR: 192.168.0.0/24	Tolak semua akses: 127.0.0.1 Izinkan semua akses: 0.0.0.0/0 Penting Ini menimbulkan risiko keamanan tinggi. Kami sangat menyarankan agar Anda tidak mengonfigurasi 0.0.0.0/0. Beberapa versi kluster (seperti 7.16 dan 8.5) dan wilayah tidak mendukung 0.0.0.0/0. Lihat UI konsol atau pesan error untuk detailnya.
      Format alamat IPv6 (Didukung hanya untuk kluster arsitektur penerapan v2 di wilayah Tiongkok (Hangzhou))	IP tunggal: 2401:XXXX:1000:24::5 Blok CIDR: 2401:XXXX:1000::/48	Tolak semua akses: ::1 Izinkan semua akses: ::/0 Penting Ini menimbulkan risiko keamanan tinggi. Kami sangat menyarankan agar Anda tidak mengonfigurasi ::/0. Beberapa versi kluster tidak mendukung ::/0. Lihat petunjuk UI konsol atau konfigurasi untuk detailnya.

   3. Klik OK.

Contoh koneksi dasar

Berlaku untuk koneksi HTTPS publik atau HTTP privat:

package org.example;
import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.elasticsearch.cat.IndicesResponse;
import co.elastic.clients.elasticsearch.indices.*;
import co.elastic.clients.json.jackson.JacksonJsonpMapper;
import co.elastic.clients.transport.ElasticsearchTransport;
import co.elastic.clients.transport.rest_client.RestClientTransport;
import org.apache.http.HttpHost;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
import org.elasticsearch.client.*;
import java.io.IOException;
public class RestClientTest {
    public static void main(String[] args) {
        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("{UserName}", "{YourPassword}"));
        // Gunakan "https" untuk akses HTTPS publik atau "http" untuk akses HTTP privat.
        RestClient restClient = RestClient.builder(new HttpHost("{YourEsHost}", 9200, "https"))
                .setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
                    @Override
                    public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
                        return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
                    }
                }).build();

        ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
        ElasticsearchClient elasticsearchClient = new ElasticsearchClient(transport);
        try {
            CreateIndexResponse indexRequest = elasticsearchClient.indices().create(createIndexBuilder -> createIndexBuilder
                    .index("hr_test")
                    .aliases("foo", aliasBuilder -> aliasBuilder.isWriteIndex(true))
            );
            System.out.println("Dokumen indeks berhasil dibuat! " + indexRequest.acknowledged());
            transport.close();
            restClient.close();
        } catch (IOException ioException) {
            // Tangani pengecualian.
        }
    }
}

Contoh koneksi HTTPS privat

Untuk HTTPS privat, lewati verifikasi sertifikat:

package org.example;
import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.json.jackson.JacksonJsonpMapper;
import co.elastic.clients.transport.ElasticsearchTransport;
import co.elastic.clients.transport.rest_client.RestClientTransport;
import org.apache.http.HttpHost;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.conn.ssl.NoopHostnameVerifier;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
import org.apache.http.ssl.SSLContexts;
import org.elasticsearch.client.*;
import javax.net.ssl.SSLContext;

public class RestClientTestPrivateHttps {
    public static void main(String[] args) throws Exception {
        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("{UserName}", "{YourPassword}"));
        // Buat SSLContext yang mempercayai semua sertifikat.
        SSLContext sslContext = SSLContexts.custom()
          .loadTrustMaterial(null, (chain, authType) -> true)  // Percaya semua sertifikat.
          .build();
        RestClient restClient = RestClient.builder(new HttpHost("{YourEsHost}", 9200, "https"))
                .setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
                    @Override
                    public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
                        return httpClientBuilder
                            .setDefaultCredentialsProvider(credentialsProvider)
                            .setSSLContext(sslContext)                          // Atur SSLContext.
                            .setSSLHostnameVerifier(NoopHostnameVerifier.INSTANCE);  // Lewati verifikasi hostname.
                    }
                }).build();

        ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
        ElasticsearchClient elasticsearchClient = new ElasticsearchClient(transport);
        
        // Lakukan operasi.
        System.out.println(elasticsearchClient.info());
        
        transport.close();
        restClient.close();
    }
}

Python

Contoh-contoh ini menggunakan ES 8.17.0. Ganti dengan versi kluster Anda.

pip install elasticsearch==8.17.0from elasticsearch import Elasticsearch
es = Elasticsearch(
    hosts=['https://<YourEsHost>:9200'],  # Gunakan 'https://' untuk akses HTTPS publik atau 'http://' untuk akses HTTP privat.
    basic_auth=('<UserName>', '<YourPassword>'),
)
print(es.info())

from elasticsearch import Elasticsearch
import urllib3
urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)  # Nonaktifkan peringatan SSL (opsional).

es = Elasticsearch(
    hosts=['https://<YourEsHost>:9200'],
    basic_auth=('<UserName>', '<YourPassword>'),
    verify_certs=False,           # Lewati verifikasi sertifikat.
    ssl_show_warn=False,          # Nonaktifkan peringatan SSL.
)
print(es.info())

Go

Contoh-contoh ini menggunakan Elasticsearch Go Client untuk kluster ES 8.x.

go get github.com/elastic/go-elasticsearch/v8
package main

import (
    "github.com/elastic/go-elasticsearch/v8""log"
)

func main() {
    cfg := elasticsearch.Config{
        Addresses: []string{"https://<YourEsHost>:9200"},  // Gunakan "https://" untuk akses HTTPS publik atau "http://" untuk akses HTTP privat.
        Username:  "<UserName>",
        Password:  "<YourPassword>",
    }
    es, _ := elasticsearch.NewClient(cfg)
    res, _ := es.Info()
    defer res.Body.Close()
    log.Println(res)
}

package main

import (
    "crypto/tls""net/http""github.com/elastic/go-elasticsearch/v8""log"
)

func main() {
    cfg := elasticsearch.Config{
        Addresses: []string{"https://<YourEsHost>:9200"},
        Username:  "<UserName>",
        Password:  "<YourPassword>",
        Transport: &http.Transport{
            TLSClientConfig: &tls.Config{InsecureSkipVerify: true},  // Lewati verifikasi sertifikat.
        },
    }
    es, _ := elasticsearch.NewClient(cfg)
    res, _ := es.Info()
    defer res.Body.Close()
    log.Println(res)
}

FAQ

Jika status kluster sehat tetapi klien tidak dapat terhubung, lakukan troubleshooting menggunakan metode berikut.

route -n

curl -u {UserName}:{YourPassword} https://{YourEsHost}:9200

RestClient restClient = RestClient.builder(new HttpHost("{YourEsHost}", 9200, "https"))
    .setRequestConfigCallback(builder -> builder
        .setConnectTimeout(10000)
        .setSocketTimeout(30000))
    .setHttpClientConfigCallback(httpClientBuilder ->
        httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider))
    .build();