Elasticsearch:Low Level REST Client (5.x)

Inisialisasi client

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.RestClient;
import org.elasticsearch.client.RestClientBuilder;

// Konfigurasikan kredensial
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY,
        new UsernamePasswordCredentials("<username>", "<password>"));

// Bangun client. Ganti <host> dengan titik akhir publik atau internal
// dari halaman Informasi Dasar kluster Anda.
RestClient restClient = RestClient.builder(new HttpHost("<host>", 9200))
        .setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
            @Override
            public HttpAsyncClientBuilder customizeHttpClient(
                    HttpAsyncClientBuilder httpClientBuilder) {
                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
            }
        }).build();

Indeks dan ambil dokumen

Contoh berikut mengindeks sebuah dokumen lalu mengambilnya kembali:

import org.apache.http.HttpEntity;
import org.apache.http.entity.ContentType;
import org.apache.http.nio.entity.NStringEntity;
import org.apache.http.util.EntityUtils;
import org.elasticsearch.client.Response;
import java.io.IOException;
import java.util.Collections;

public class RestClientTest55 {
    public static void main(String[] args) {

        // (Inisialisasi restClient seperti yang ditunjukkan di atas)

        try {
            // Indeks dokumen dengan PUT /index_name/type_name/doc_id
            HttpEntity entity = new NStringEntity(
                    "{\n\"field_01\" : \"value_01\"\n,\n\"field_02\" : \"value_02\"\n}",
                    ContentType.APPLICATION_JSON);
            Response indexResponse = restClient.performRequest(
                    "PUT",
                    "/index_name/type_name/doc_id",
                    Collections.<String, String>emptyMap(),
                    entity);

            // Ambil dokumen dengan GET /index_name/type_name/doc_id
            Response response = restClient.performRequest(
                    "GET",
                    "/index_name/type_name/doc_id",
                    Collections.singletonMap("pretty", "true"));

            // Cetak badan respons
            System.out.println(EntityUtils.toString(response.getEntity()));

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Ganti placeholder berikut dengan nilai aktual Anda: