AWS DynamoDB过滤查询异常：仅返回单条数据而非多条匹配项

核心问题 #

你当前的实现逻辑存在本质错误：

• DynamoDB的Query操作是先基于索引的分区键筛选数据，再对结果应用FilterExpression做后置过滤。
• 你现在用organizationId作为Query的分区键条件，会先仅查出属于该organizationId的1条数据，再过滤accountId，最终自然只返回1条结果。
• 你的需求是获取相同accountId的所有组织，应该直接基于accountId作为分区键执行Query，而非用organizationId查询后再过滤。

必要前提 #

确保organization表存在一个全局二级索引（GSI），该索引的分区键为accountId（索引名称比如设为AccountIdIndex，需替换为你实际的索引名）。若没有该索引，必须先创建，否则无法高效实现按accountId批量查询的需求。

代码修正 #

1. 调整调用代码 #

将Query条件改为基于accountId，并指定对应的GSI名称：

val organization = organizationTable.getData(request.packageId)
// 直接用accountId作为Query的分区键条件
val accountIdKey = Key.builder().partitionValue(organization.accountId).build()
val query = QueryConditional.keyEqualTo(accountIdKey)

// 无需FilterExpression，Query已直接筛选accountId对应的所有条目
val organizationsByAccount = organizationTable.queryIndexWithFilter(
    query,
    "AccountIdIndex", // 替换为你的accountId分区键GSI实际名称
    null,
    10,
    10,
    Expression.builder().build() // 传入空表达式，或根据方法定义调整参数
)

2. 可选：优化查询方法 #

如果不需要FilterExpression，可以简化方法去掉该参数：

@Throws(GrpcInternalException::class, GrpcNotFoundException::class)
suspend inline fun <reified T> DynamoDbTable<T>.queryIndex(
    request: QueryConditional,
    index: String,
    startIndex: Map<String, AttributeValue>?,
    pageLimit: Int,
    streamLimit: Long,
): Stream<Page<T>> {
    val result = runCatching {
        val queryRequest = QueryEnhancedRequest.builder()
            .limit(pageLimit)
            .exclusiveStartKey(startIndex)
            .queryConditional(request)
            .scanIndexForward(false)
            .build()
        this.index(index).query(queryRequest).stream().limit(streamLimit)
    }.onFailure {
        Error.logAsync(it) { "EREX: ${it.message}" }
        throw GrpcInternalException(
            "Error querying items from table ${T::class.simpleName} with partition value QueryConditional.",
            coroutineContext.sendAll(),
            it,
        )
    }.getOrThrow()
    return result
}

调用时简化为：

val organizationsByAccount = organizationTable.queryIndex(
    query,
    "AccountIdIndex",
    null,
    10,
    10
)

额外注意事项 #

• 若streamLimit设为10，最多仅返回10条数据；若需要获取所有符合条件的条目，需将该值设为足够大（比如Long.MAX_VALUE），并通过exclusiveStartKey循环处理分页，直到没有更多数据。
• 确认GSI的投影设置：如果需要返回组织的所有属性，GSI需配置为投影所有属性，否则仅会返回索引键和指定投影的属性。

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