amazon-web-services - AWS Elastic Search ConnectException: 操作がタイムアウトしました

Question

別の AWS アカウントに存在する AWS オープン検索クラスターにアクセスしようとしています (アカウント A に存在する ES クラスターをアカウント B からアクセスしようとしているとしましょう)。アクセスするために次の手順を実行しました

1. ES エンドポイント サービス オプション内の AWS アカウント A のプリンシパル AWS アカウント B を許可リストに登録します。

2. アカウント A の vpc サービス名を使用して、アカウント B に vpc エンドポイントを作成しました。 アカウント A が受信した vpc ペアリング要求

3. AWS アカウント A で vpc ペアリング リクエストを受け入れます。

4. AWS アカウント B で、VPC エンドポイントのステータスが保留中から使用可能に変わりました。

5. AWS アカウント ES は HTTP、ポート 80 でアクセスできるため、ECS サービス セキュリティ グループに Http、ポート 80 インバウンド ルールが追加されました。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] at org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84) ~[httpcore-4.4.14.jar:4.4.14] [java] at 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] at org.elasticsearch.client.RestClient.performRequest(RestClient.java:235) ~[elasticsearch-rest-client-7.7. 1.jar:7.7.1] [java] at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1609) ~[elasticsearch-rest-high-level-client-7.7.1.jar:7.7.1] [java] at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1579) ~[elasticsearch-rest-high-level-client-7.7.1.jar:7.7.1] [java ] at org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:1549) ~[elasticsearch-rest-high-level-client-7.7.1.jar:7.7.1] [java] at 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] at com.amazon.atvomniaservice.elastic.ElasticSearchQueryRunner.submit(ElasticSearchQueryRunner.java:33) ~[ATVOmniaService-1.0.jar:?] [java] at com.amazon.atvomniaservice.elastic.ElasticSearchQueryRunner.送信 (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.java:40) ~[ATVOmniaService-1.0.jar:?] [java] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?] [java] at java.util.concurrent.Executors java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?] [java] at com.amazon.metrics.executor.MetricsClearingRunnable.run(MetricsClearingRunnable.java:58) ~[DeclarativeCoralMetrics-2.1. jar:?] [java] com.amazon.coral.metrics で。MetricReportingThreadPoolExecutor$MeasuringRunnable.run(MetricReportingThreadPoolExecutor.java:210) ~[MetricReportingExecutors-1.0.jar:?] [Java] java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) で ~[?:?] [java ] java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) で ~[?:?] [java] java.lang.Thread.run(Thread.java:829) で [?:?] [ java] 原因: java.net.ConnectException: Operation timed out [java] at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[?:?] [java] at sun.nio.ch.SocketChannelImpl.finishConnect (SocketChannelImpl.java:777) ~[?:?] [java] at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174) ~[httpcore-nio-4.4.12.jar :4.4.12] [java] at 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] at org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221) ~[httpasyncclient-4.1. 4.jar:4.1.4] [java] at 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]予期せぬエラーが発生した：12] [java] at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351) ~[httpcore-nio-4.4.12.jar:4.4.12] [java] at org. apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221) ~[httpasyncclient-4.1.4.jar:4.1.4] [java] at 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] 予期しないエラーが発生しました:12] [java] at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351) ~[httpcore-nio-4.4.12.jar:4.4.12] [java] at org. apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221) ~[httpasyncclient-4.1.4.jar:4.1.4] [java] at 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.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.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] 予期しないエラーが発生しました:80]] すでにブラックリストに登録されています [java] 予期しないエラーが発生しました:80]] すでにブラックリストに登録されています [java] 予期しないエラーが発生しました: