0

我正在尝试访问存在于不同 AWS 账户中的 AWS 开放式搜索集群（假设账户 A 中存在 ES 集群，我们正在尝试从账户 B 访问它）。我已执行以下步骤来访问它

  1. 在 ES 终端节点服务选项中的 AWS 账户 A 中将委托人 AWS 账户 B 列入白名单。

  2. 使用账户 A 的 vpc 服务名称在账户 B 中创建 vpc 端点。账户 A 收到的 vpc 配对请求

  3. 接受 AWS 账户 A 中的 vpc 配对请求。

  4. VPC 终端节点状态在 AWS 账户 B 中从待处理更改为可用。

  5. AWS 账户 A ES 可通过 HTTP 80 端口访问，因此在 ECS 服务安全组中添加了 Http 80 端口入站规则。从同一个 ECS 服务调用 ES 连接代码。

以下是 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: Operation timed out exception on restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT); 称呼。

详细日志

[java] java.util.concurrent.ExecutionException: java.net.ConnectException: Operation timed out [java] at 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] at 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] 在 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 ] 在 org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(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] at 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] at com.amazon.atvomniaservice.GenericQueryDriver.run（GenericQueryDriver.java:60）~[ATVOmniaService-1.0.jar:?] [java ] at com.amazon.atvomniaservice.activity.GetSessionsActivity.lambda$enact$0(GetSessionsActivity.java:78) ~[ATVOmniaService-1.0.jar:?] [java] at 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.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] at 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] 在 org.apache.http.impl.nio.reactor。DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148) ~[httpcore-nio-4.4.12.jar:4.4.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] 发生意外错误：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] 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] 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] 发生意外错误：80]]已经在黑名单中[java]发生意外错误：80]]已经在黑名单中[java]发生意外错误：

4

0 回答 0