当使用 AWS Elasticsearch 时,如果出现 "返回无存活连接" 的错误,可能是由于以下原因之一导致的:
配置错误:检查您的 AWS Elasticsearch 配置是否正确。确保您的访问密钥和访问密钥 ID 是正确的,并且您有适当的权限来访问 Elasticsearch。
安全组设置错误:确保您的 Elasticsearch 集群的安全组配置允许来自您的应用程序服务器的流量。确保您的安全组配置允许出站流量到 Elasticsearch 集群的端口(默认为 443)。
VPC 设置错误:如果您的 Elasticsearch 集群位于私有子网中,则确保您的 VPC 配置正确。确保您的私有子网具有正确的路由表和网络访问控制列表(NACL)配置,以允许出站和入站流量。
以下是一个使用 AWS SDK for Java 的示例代码,用于连接 AWS Elasticsearch 并执行查询的示例:
import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.elasticsearch.ElasticsearchClient;
import software.amazon.awssdk.services.elasticsearch.model.DescribeElasticsearchDomainRequest;
import software.amazon.awssdk.services.elasticsearch.model.DescribeElasticsearchDomainResponse;
import software.amazon.awssdk.services.elasticsearch.model.ElasticsearchDomainStatus;
public class AWSElasticsearchExample {
public static void main(String[] args) {
// 设置您的 AWS 访问密钥和访问密钥 ID
String accessKeyId = "YOUR_ACCESS_KEY_ID";
String secretAccessKey = "YOUR_SECRET_ACCESS_KEY";
// 设置您的 Elasticsearch 配置
String region = "us-west-2";
String domainName = "your-elasticsearch-domain";
// 创建 AWS Elasticsearch 客户端
ElasticsearchClient client = ElasticsearchClient.builder()
.credentialsProvider(StaticCredentialsProvider.create(AwsBasicCredentials.create(accessKeyId, secretAccessKey)))
.region(Region.of(region))
.build();
// 执行一个查询示例
DescribeElasticsearchDomainRequest request = DescribeElasticsearchDomainRequest.builder()
.domainName(domainName)
.build();
DescribeElasticsearchDomainResponse response = client.describeElasticsearchDomain(request);
ElasticsearchDomainStatus domainStatus = response.domainStatus();
System.out.println("Domain: " + domainStatus.domainName());
System.out.println("ARN: " + domainStatus.arn());
System.out.println("Endpoint: " + domainStatus.endpoint());
}
}
请根据您的实际情况修改代码中的参数,并确保您已正确配置您的 AWS 访问密钥和访问密钥 ID。此示例代码将使用指定的访问密钥和访问密钥 ID 连接到指定的 AWS Elasticsearch 域,并输出域的一些属性信息。您可以根据您的需求修改代码以执行其他操作。