Elasticsearch：通過應用程式串連叢集

注意事項

為確保相容性，建議用戶端使用的 Java、Python 或 Go 語言版本與ES叢集底層運行時的版本保持一致。

串連叢集

Java

1. 安裝Java JDK，JDK版本為1.8及以上。

2. 配置pom依賴。

   重要

   請將version設定為正確的ES版本號碼，只有當version設定正確時才能拉取相關依賴，本樣本ES版本為8.17.0。

   <dependency>
       <groupId>co.elastic.clients</groupId>
       <artifactId>elasticsearch-java</artifactId>
       <version>8.17.0</version>
   </dependency>
   <dependency>
       <groupId>com.fasterxml.jackson.core</groupId>
       <artifactId>jackson-databind</artifactId>
       <version>2.12.3</version>
   </dependency>

3. 串連ES叢集並建立名為hr_test的索引。

   需配置YML參數，開啟自動建立索引：action.auto_create_index: true。

   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) {
           // Elasticsearch叢集需要basic auth驗證。
           final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
           //訪問使用者名稱和密碼為您建立Elasticsearch執行個體時設定的使用者名稱和密碼，也是Kibana控制台的登入使用者名稱和密碼。
           credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("{UserName}", "{YourPassword}"));
           // 通過builder建立rest client，配置http client的HttpClientConfigCallback。
           // 單擊所建立的Elasticsearch執行個體ID，在基本資料頁面擷取公網地址，即為ES叢集地址。
           RestClient restClient = RestClient.builder(new HttpHost("{YourEsHost}", 9200, "https"))
                   .setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
                       @Override
                       public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
                           return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
                       }
                   }).build();
   
           // 使用 Jackson 映射器建立傳輸
           ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
           // 建立 API 用戶端
           ElasticsearchClient elasticsearchClient = new ElasticsearchClient(transport);
           // 建立了一個名為 "foo" 的別名，並將其設定為寫入別名 (write index)，這意味著所有寫入操作（例如索引、更新、刪除文檔）將自動路由到這個別名所對應的索引上。
           try {
               //建立索引
               CreateIndexResponse indexRequest = elasticsearchClient.indices().create(createIndexBuilder -> createIndexBuilder
                       .index("hr_test")
                       .aliases("foo", aliasBuilder -> aliasBuilder
                               .isWriteIndex(true)
                       )
               );
               //檢查“indexRequest”請求的操作是否已被Elasticsearch叢集確認
               boolean acknowledged = indexRequest.acknowledged();
               System.out.println("Index document successfully! " + acknowledged);
   
               //查看所有索引資訊（health status index uuid pri rep）
               IndicesResponse indicesResponse = elasticsearchClient.cat().indices();
               indicesResponse.valueBody().forEach(info -> System.out.println(info.health() + "\t"+  info.status() + "\t" + info.index() + "\t" + info.uuid() +"\t" + info.pri() + "\t" + info.rep()));
   
   
               transport.close();
               restClient.close();
           } catch (IOException ioException) {
               // 異常處理。
           }
       }
   }
   

   成功執行後返回以下資訊：

   

Python

以下代碼以ES 8.17.0版本為例，請根據實際ES版本替換版本號碼。

# 安裝指定版本的依賴
pip install elasticsearch==8.17.0
from elasticsearch import Elasticsearch

# 串連叢集
es = Elasticsearch(
    hosts=['http://<YourEsHost>:9200'],
    basic_auth=('<UserName>', '<YourPassword>'),
)
# 擷取並列印叢集資訊
res = es.info() 
print(res)

Go

以下以ES 8.x版本為例介紹如何通過Go串連ES，更多Go API Client的使用特性，請參見Elasticsearch Go Client。

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{
			"http://<YourEsHost>:9200",
		},
		Username: "<UserName>",
		Password: "<YourPassword>",
	}

	es, err := elasticsearch.NewClient(cfg)
	if err != nil {
		log.Fatalf("Error creating the client: %s", err)
	}

	res, err := es.Info()
	if err != nil {
		log.Fatalf("Error getting response: %s", err)
	}

	defer res.Body.Close()
	log.Println(res)
}

參數說明