如何使用Spring JdbcTemplate类操作DynamoDB？是否有等价于queryForStream的API？

DynamoDB 提供了多种支持流式返回查询/扫描结果的机制，效果类似 RDBMS 中 JDBCTemplate.queryForStream，核心是通过懒加载分页的方式避免一次性加载全量数据到内存，适配从仓储层到控制层的流式传输需求。以下是不同场景下的实现方式：

1. AWS Java SDK v2（官方推荐） #

SDK v2 原生支持迭代式和反应式两种流式处理方式：

• 迭代式懒加载：使用 query() 或 scan() 方法返回的 QueryIterable/ScanIterable，它会自动处理分页（通过 LastEvaluatedKey），迭代时才会请求下一页数据：

  // 构建查询请求
  QueryRequest queryRequest = QueryRequest.builder()
          .tableName("your-table")
          .keyConditionExpression("partitionKey = :pk")
          .expressionAttributeValues(Map.of(":pk", AttributeValue.builder().s("value").build()))
          .build();
  
  // 获取可迭代结果，流式遍历
  try (DynamoDbClient client = DynamoDbClient.create()) {
      QueryIterable<Map<String, AttributeValue>> results = client.queryPaginator(queryRequest);
      for (Map<String, AttributeValue> item : results) {
          // 逐个处理数据，流式返回给上层
          processItem(item);
      }
  }
  

• 反应式流式处理：如果用反应式编程模型，可调用 queryPaginator() 返回 SdkPublisher，配合 Reactor 的 Flux 实现全流式处理：

  Flux.from(client.queryPaginator(queryRequest))
      .flatMap(page -> Flux.fromIterable(page.items()))
      .subscribe(item -> processItem(item));
  

2. AWS Java SDK v1 #

SDK v1 中可以通过 PaginatedQueryList/PaginatedScanList 实现懒加载流式遍历，它会在迭代到当前页末尾时自动请求下一页：

AmazonDynamoDB client = AmazonDynamoDBClientBuilder.defaultClient();
QueryRequest queryRequest = new QueryRequest()
        .withTableName("your-table")
        .withKeyConditionExpression("partitionKey = :pk")
        .withExpressionAttributeValues(Map.of(":pk", new AttributeValue("value")));

PaginatedQueryList<Map<String, AttributeValue>> results = client.query(queryRequest);
for (Map<String, AttributeValue> item : results) {
    processItem(item);
}

3. Spring Data DynamoDB #

如果使用 Spring 生态，可以通过自定义 Repository 方法直接返回 Stream<T> 或 Flux<T>，框架底层会自动封装 DynamoDB 的分页逻辑实现流式返回：

public interface YourEntityRepository extends CrudRepository<YourEntity, String> {
    // 返回 Stream 实现流式遍历
    Stream<YourEntity> findByPartitionKey(String partitionKey);
    
    // 反应式场景返回 Flux
    Flux<YourEntity> findByPartitionKeyReactive(String partitionKey);
}

这些方案都能实现类似 JDBCTemplate.queryForStream 的效果：逐步获取数据、低内存占用，适配从仓储层到控制层的流式传输需求。

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