Java RestHighLevelClient с AWS ElasticSearch

Мне было интересно, использовал ли кто-нибудь здесь RestHighLevelClient для подключения к AWS ElasticSearch. Не уверен, что AWS ElasticSearch поддерживает это. В настоящее время я получаю ConnectionClosedException каждый раз, когда пытаюсь подключиться.

Вот что у меня есть:

public SearchResponse getQuery(){
    RestHighLevelClient client = new RestHighLevelClient(
            RestClient.builder(new HttpHost("localhost", 4430, "http")));
    SearchRequest searchRequest = new SearchRequest("msglog-dev-2018.05.21");
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
    searchSourceBuilder.query(QueryBuilders.matchAllQuery());
    searchRequest.source(searchSourceBuilder);
    SearchResponse searchResponse = null;
    try{
        searchResponse =client.search(searchRequest);
    }catch(IOException e){
        e.printStackTrace();
    }
    return searchResponse;
}

и я получаю ошибку

org.apache.http.ConnectionClosedException: Connection closed
at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.endOfInput(HttpAsyncRequestExecutor.java:347)
at org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:261)
at org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)
at org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)                                                             
                                                                   ...........

Но вы подключаетесь к экземпляру localhost в своем коде ?!

— 14.07.2018 06:38

Да, мой ElasticSearch в настоящее время туннелируется к этому порту.

— 17.07.2018 16:01

java amazon-web-services spring-boot elasticsearch

13.07.2018 18:48

Пользовательский скаляр GraphQL

Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...

Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами

В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...

Поднятие тревоги для долго выполняющихся методов в Spring Boot

Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...

Принятие принципов SOLID в Spring Boot: Создание обслуживаемых и масштабируемых приложений

Коллекции (ArrayList , HashSet , HashMap)

Полный курс Java для разработчиков веб-сайтов и приложений

Получите сертификат Java Web и Application Developer, используя наш курс.

2 481

Ответы 1

Да, мы используем RHLC с AWS. Вот пример, который поможет вам двигаться в правильном направлении. Это демонстрирует прямой вызов (который, вероятно, актуален для большего числа читателей), но его можно легко адаптировать к вашим потребностям в туннелировании, изменив настройки параметров соединения (хост, порт, протокол).

private static final String HOST = "your-es-endpoint.es.amazonaws.com";
private static final int PORT = 443;
private static final String PROTOCOL = "https";

private static final RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost(HOST, PORT, PROTOCOL)));

public static void getESDocs() {
    try {
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.query(QueryBuilders.matchAllQuery());   // adjust search logic here
        SearchRequest searchRequest = new SearchRequest("your-index-here");
        searchRequest.source(sourceBuilder);
        final SearchResponse searchResponse = client.search(searchRequest);

        /* process results here... */

        }
    } catch (Exception e) {
         /* handle connection/proc error here */
    } finally {
         client.close();    // example to release driver resource (see doc link)
    }
}

Этот пример действует для версии 6.3.x (YMMV): Документация по API

полезно, просто добавьте RequestOptions.DEFAULT в client.search (searchRequest, RequestOptions.DEFAULT); для версии 6.7.x n выше

— 23.07.2020 13:32

Куда поместить логин и пароль Elasticsearch на aws

— 22.05.2021 07:30

06.08.2018 07:04