从 dynamodb 流中读取数据

Question

我为我的发电机表设置了流。我正在按照文档中的示例程序从流中读取数据（http://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.LowLevel.Walkthrough.CompleteProgram.html）。但是我有一个问题- 在遍历分片时，似乎检查分片迭代器是否为空并不是退出循环的充分条件。我的代码进入无限循环。在示例程序中，计算更改次数并用于退出循环-->

while (nextItr != null && numChanges > 0) {

   // Use the iterator to read the data records from the shard

  GetRecordsResult getRecordsResult = 
          streamsClient.getRecords(new GetRecordsRequest().
          withShardIterator(nextItr));
   List<Record> records = getRecordsResult.getRecords();
   System.out.println("Getting records...");
   for (Record record : records) {
           System.out.println(record);
            numChanges--;
    }
    nextItr = getRecordsResult.getNextShardIterator();
}

但在真实环境中，我确信维护更改列表是不切实际的。设计是否意味着无限循环？为什么 shardIterator 不会变成 null？

Answer 1

我在这里重复你在AWS Forums 上发布的相同问题的答案：

只要分片打开并且正在积极接收未来可能的更新，nextIterator 就不会变为 null。一旦分片关闭并遍历了最后一条记录，您的循环可能会退出并指示不再可能从分片中获取更多记录。

请在此处参考我们的文档：http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/model/GetRecordsResult.html#getNextShardIterator()

"如果设置为 null，则分片已关闭，请求的迭代器将不再返回任何数据。"

希望对您有所帮助，感谢您对 DynamoDB 的关注！