AWS Elastic Search ConnectException: время ожидания истекло
Я пытаюсь получить доступ к кластеру открытого поиска AWS, присутствующему в другой учетной записи AWS (допустим, кластер ES присутствует в учетной записи A, и мы пытаемся получить к нему доступ из учетной записи B). Я выполнил следующие шаги, чтобы получить к нему доступ
Разрешить основной аккаунт AWS B в аккаунте AWS A внутри опции сервиса конечной точки ES.
Создана конечная точка vpc в учетной записи B с использованием имени службы vpc учетной записи A. Запрос на сопряжение vpc, полученный учетной записью A
Примите запрос на сопряжение vpc в аккаунте A AWS.
Статус конечной точки VPC изменен с ожидающего на доступный в аккаунте B.
Учетная запись AWS A ES доступна по протоколу HTTP, порт 80, поэтому добавлено правило для входящего трафика Http, порт 80 в группе безопасности службы ECS. Код подключения ES вызывается из той же службы ECS.
Ниже приведен фрагмент кода для сборщика клиентов ES:
final RestClientBuilder restClientBuilder = RestClient.builder(new
HttpHost("vpc-endpoint-present-in-account-B", 80, "http"))
.setRequestConfigCallback(rcb -> rcb.setConnectTimeout(300_000).setSocketTimeout(300_000));
Я получаю [java] java.util.concurrent.ExecutionException: java.net.ConnectException: исключение истечения времени ожидания операции на restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT); вызов
Подробные журналы
[java] java.util.concurrent.ExecutionException: java.net.ConnectException: время операции истекло [java] в org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71) ~[httpcore-4.4.14. jar: 4.4.14] [java] в org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84) ~[httpcore-4.4.14.jar:4.4.14] [java] в org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70) ~[httpasyncclient-4.1.4.jar:4.1.4] [java] в org.elasticsearch.client.RestClient.performRequest(RestClient.java:244) ~[elasticsearch-rest-client-7.7.1.jar:7.7.1] [java] в org.elasticsearch.client.RestClient.performRequest(RestClient.java:235) ~[elasticsearch-rest-client-7.7. 1.jar: 7.7.1] [java] в org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1609) ~[elasticsearch-rest-high-level-client-7.7.1.jar:7.7.1] [java] в орг.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1579) ~[elasticsearch-rest-high-level-client-7.7.1.jar:7.7.1] [java] в org.elasticsearch.client.RestHighLevelClient.performRequestAndity(RestHighLevelClient.java:1549) ~[elasticsearch-rest-high-level-client-7.7.1.jar:7.7.1] [java] в org.elasticsearch.client.RestHighLevelClient.search(RestHighLevelClient.java:1065) ~ [ elasticsearch-rest-high-level-client-7.7.1.jar:7.7.1] [java] в com.amazon.atvomniaservice.elastic.ElasticSearchClient.search(ElasticSearchClient.java:62) ~[ATVOmniaService-1.0.jar:?] [java] в com.amazon.atvomniaservice.elastic.ElasticSearchQueryRunner.submit(ElasticSearchQueryRunner.java:33) ~[ATVOmniaService-1.0.jar:?] [java] на com.amazon.atvomniaservice.elastic.elastic. ElasticSearchQueryRunner.java:19) ~[ATVOmniaService-1.0.jar:?] [java] в com.amazon.atvomniaservice.GenericQueryDriver.run(GenericQueryDriver.java:60) ~[ATVOmniaService-1.0.jar:?] [java] в com.amazon.atvomniaservice.activity.GetSessionsActivity.lambda$ enact $0(GetSessionsActivity.java:78) ~[ATVOmniaService-1.0.jar:?] [java] в com.amazon.atvomniaservice.activity.ContinuationRunner.lambda$runInContinuation$0(ContinuationRunner.lambda $ runInContinuation $ 0 (Continuation 40) ~[ATVOmniaService-1.0.jar:?] [java] в java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?] [Java] в java.util.concurrent. FutureTask.run(FutureTask.java:264) ~[?:?] [Java] в com.amazon.metrics.executor.MetricsClearingRunnable.run(MetricsClearingRunnable.java:58) ~[DeclarativeCoralMetrics-2.1.jar:?] [java ] по адресу com.amazon.coral.metrics.MetricReportingThreadPoolExecutor$MeasuringRunnable.запустить (MetricReportingThreadPoolExecutor.java:210) ~[MetricReportingExecutors-1.0.jar:?] [java] в java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~ [Java. util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?] [java] в java.lang.Thread.run(Thread.java:829) [?:?] [java] Вызвано : java.net.ConnectException: истекло время операции [java] в sun.nio.ch.SocketChannelImpl.checkConnect(собственный метод) ~[?:?] [java] в sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java : 777) ~[?:?] [Java] в org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174) ~[httpcore-nio-4.4.12.jar:4.4.12 ] [java] в org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148) ~[httpcore-nio-4.4.12.jar:4.4.12] [java] в org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351) ~[httpcore-nio-4.4.12.jar:4.4.12] [java ] в org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221) ~[httpasyncclient-4.1.4.jar:4.1.4] [java] в org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$ 1.run (CloseableHttpAsyncClientBase.java:64) ~[httpasyncclient-4.1.4.jar:4.1.4] [java] ... еще 1 [java] обновлен [[host = http: // vpce -XXXXX.vpce-svc-XXXX.us-east-1.vpce.amazonaws.com:80]] уже в черном списке [java] Произошла непредвиденная ошибка:PoolingNHttpClientConnectionManager.execute (PoolingNHttpClientConnectionManager.java:221) ~ [httpasyncclient-4.1.4.jar: 4.1.4] [java] в org.apache.http.impl.nio.client.CloseableHttpAsyncClient.AsyncClientBaseCloseableHttpAsyncClientBaseBaseableHttpAsyncClientBaseableHttpAsyncClientBaseableBaseableHttpAsyncClientBaseable $ 1. ) ~ [httpasyncclient-4.1.4.jar: 4.1.4] [java] ... еще 1 [java] обновлен [[host = http: //vpce-XXXXX.vpce-svc-XXXX.us-east-1 .vpce.amazonaws.com: 80]] уже в черном списке [java] Произошла непредвиденная ошибка:PoolingNHttpClientConnectionManager.execute (PoolingNHttpClientConnectionManager.java:221) ~ [httpasyncclient-4.1.4.jar: 4.1.4] [java] в org.apache.http.impl.nio.client.CloseableHttpAsyncClient.AsyncClientBaseCloseableHttpAsyncClientBaseBaseableHttpAsyncClientBaseableHttpAsyncClientBaseableBaseableHttpAsyncClientBaseable $ 1. ) ~ [httpasyncclient-4.1.4.jar: 4.1.4] [java] ... еще 1 [java] обновлен [[host = http: //vpce-XXXXX.vpce-svc-XXXX.us-east-1 .vpce.amazonaws.com: 80]] уже в черном списке [java] Произошла непредвиденная ошибка:80]] уже в черном списке [java] Произошла непредвиденная ошибка:80]] уже в черном списке [java] Произошла непредвиденная ошибка: