使用Lambda查询DynamoDB全局二级索引(GSI)报错排查

报错核心原因 #

• 你在Lambda中执行查询时没指定要使用的GSI索引名称，DynamoDB默认会去查主表的主键，但主表主键schema里没有testName字段，所以抛出这个错误。
• 次要可能：GSI定义有问题（比如分区键不是testName、CDK配置错误导致GSI没生效），或者查询条件里的字段名和GSI分区键名不匹配（大小写/拼写错误）。

分步解决与验证 #

1. 确认GSI的正确定义（CDK Kotlin代码） #

先检查你的CDK代码里GSI配置是否正确，确保testNameIndex的分区键是testName，示例代码如下：

// 主表定义示例
val table = Table(this, "TestTable", TableProps.builder()
    .partitionKey(Attribute.builder().name("id").type(AttributeType.STRING).build())
    .build())

// 正确创建GSI：指定分区键为testName，索引名testNameIndex
table.addGlobalSecondaryIndex(GlobalSecondaryIndexProps.builder()
    .indexName("testNameIndex")
    .partitionKey(Attribute.builder().name("testName").type(AttributeType.STRING).build())
    // 可选：需要排序的话添加排序键
    // .sortKey(Attribute.builder().name("createTime").type(AttributeType.NUMBER).build())
    .projectionType(ProjectionType.ALL) // 根据需求选投影类型，不用全量就选INCLUDE指定字段
    .build())

验证：去AWS控制台的DynamoDB表页面，看「索引」标签，确认testNameIndex存在且分区键是testName，状态为「活跃」。

2. Lambda查询时必须指定GSI #

Lambda里的查询代码一定要通过IndexName参数指定用这个GSI，不然DynamoDB默认查主表。给你两种常用的正确写法：

方式1：AWS SDK v2基础写法

import software.amazon.awssdk.services.dynamodb.DynamoDbClient
import software.amazon.awssdk.services.dynamodb.model.QueryRequest

val dynamoDbClient = DynamoDbClient.create()

val queryRequest = QueryRequest.builder()
    .tableName("TestTable")
    .indexName("testNameIndex") // 必须加这行指定GSI
    .keyConditionExpression("testName = :val")
    .expressionAttributeValues(mapOf(":val" to AttributeValue.builder().s("你要查的testName值").build()))
    .build()

val response = dynamoDbClient.query(queryRequest)

方式2：DynamoDB Enhanced Client（Kotlin推荐）

如果你的DynamoDbBean是Kotlin数据类，用这个更简洁，不用手动拼AttributeValue：

import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClient
import software.amazon.awssdk.enhanced.dynamodb.TableSchema
import software.amazon.awssdk.enhanced.dynamodb.model.QueryEnhancedRequest

// 你的DynamoDbBean定义示例，标记GSI分区键
data class DynamoDbBean(
    @get:DynamoDbPartitionKey
    val id: String,
    @get:DynamoDbSecondaryPartitionKey(indexNames = ["testNameIndex"])
    val testName: String,
    // 其他字段...
)

val enhancedClient = DynamoDbEnhancedClient.create()
val table = enhancedClient.table("TestTable", TableSchema.fromBean(DynamoDbBean::class.java))

val queryRequest = QueryEnhancedRequest.builder()
    .indexName("testNameIndex")
    .queryConditional(QueryConditional.keyEqualTo(Key.builder().partitionValue("你要查的testName值").build()))
    .build()

val results = table.query(queryRequest).items().toList()

3. 排查其他坑 #

• 检查查询条件里的字段名和GSI分区键名完全一致（DynamoDB大小写敏感）。
• 确认GSI已经创建完成（新GSI需要等几分钟同步数据，控制台显示「活跃」才可用）。

更优查询方案 #

1. 优先用Enhanced Client：对Kotlin开发者友好，数据类直接映射DynamoDB表，减少手动构造参数的错误。
2. 优化GSI投影类型：如果只需要查部分字段，别用ProjectionType.ALL，选INCLUDE指定需要的字段，减少数据传输量，提升查询速度。
3. 给GSI加排序键：如果要对同一testName下的数据排序或做范围查询（比如按时间筛选），给GSI加个排序键（比如时间戳），这样查询时可以用BETWEEN、>等条件。
4. 缓存高频查询结果：对于重复查的相同testName数据，用ElastiCache或Lambda本地缓存，减少DynamoDB调用次数，降本增效。

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