SpringBoot本地连接AWS Keyspace遇AllNodesFailedException问题求助

1. 核对AWS Keyspace端点 #

AWS Keyspace的端点格式固定为 cassandra.<区域ID>.amazonaws.com，比如美东1区就是cassandra.us-east-1.amazonaws.com，端口默认是9142（强制SSL端口）。务必保证你配置的端点和Keyspace所在区域完全匹配，别写错区域缩写。

2. 验证IAM用户权限与凭证 #

• 给对应的IAM用户附加至少包含所需操作的权限策略，比如AmazonKeyspacesFullAccess（POC阶段可以先用这个，正式环境再缩权限），至少要覆盖你业务需要的cassandra:Select、cassandra:Insert等动作。
• 确认使用的accessKey/secretKey属于这个有权限的IAM用户，且凭证没有过期、没有被禁用。

3. 检查依赖与配置兼容性 #

依赖版本要匹配 #

确保pom.xml（或build.gradle）里的Datastax驱动和AWS SDK版本兼容，示例依赖如下：

<!-- Datastax Cassandra Java驱动 -->
<dependency>
    <groupId>com.datastax.oss</groupId>
    <artifactId>java-driver-core</artifactId>
    <version>4.15.0</version>
</dependency>
<dependency>
    <groupId>com.datastax.oss</groupId>
    <artifactId>java-driver-query-builder</artifactId>
    <version>4.15.0</version>
</dependency>
<!-- AWS SDK 用于SigV4认证 -->
<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>auth</artifactId>
    <version>2.20.0</version>
</dependency>
<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>regions</artifactId>
    <version>2.20.0</version>
</dependency>

避免用太老旧的版本，容易出现认证或连接兼容问题。

application.properties配置要点 #

AWS Keyspace强制要求SSL连接，配置里必须开启：

spring.data.cassandra.contact-points=cassandra.<你的区域ID>.amazonaws.com
spring.data.cassandra.port=9142
spring.data.cassandra.keyspace-name=<你的Keyspace名称>
spring.data.cassandra.ssl=true
spring.data.cassandra.auth-provider-class-name=software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider

4. 测试网络连通性 #

本地桌面必须能访问AWS Keyspace的9142端口：

• 检查本地防火墙、杀毒软件有没有拦截出站的9142端口请求，临时关闭测试试试。
• 公司网络环境下，确认网关没有屏蔽AWS的这个服务地址，用命令telnet cassandra.<你的区域ID>.amazonaws.com 9142或者nc -zv cassandra.<你的区域ID>.amazonaws.com 9142测试连通性，连不通的话找网络团队开放权限。

5. 修正客户端认证配置 #

用IAM凭证连接时，不能直接用BasicAWSCredentials+AmazonKeyspaceClientBuilder的旧方式，推荐用Datastax的AwsSigV4AuthProvider构建CqlSession，示例代码：

@Bean
public CqlSession cqlSession() {
    AwsCredentialsProvider credentialsProvider = StaticCredentialsProvider.create(
            AwsBasicCredentials.create("你的accessKey", "你的secretKey")
    );

    return CqlSession.builder()
            .addContactPoint(new InetSocketAddress("cassandra.<你的区域ID>.amazonaws.com", 9142))
            .withSslContext(SslContextBuilder.forClient().build())
            .withAuthProvider(AwsSigV4AuthProvider.builder()
                    .withCredentialsProvider(credentialsProvider)
                    .withRegion(Region.of("<你的区域ID>"))
                    .build())
            .withLocalDatacenter("<你的区域ID>")
            .withKeyspace(CqlIdentifier.fromCql("<你的Keyspace名称>"))
            .build();
}

6. 开启DEBUG日志定位细节 #

在application.properties里添加日志配置，查看更详细的连接失败原因：

logging.level.com.datastax.oss.driver=DEBUG

日志会显示具体是SSL握手失败、认证错误还是节点不可达，能帮你快速定位问题。

内容的提问来源于stack exchange，提问作者newcoder