调用GetStreamRecord接口读取当前Shard的增量内容。

请求消息结构

message GetStreamRecordRequest {
    required string shard_iterator = 1;
    optional int32 limit = 2;
}            
名称 类型 是否必选 描述
shard_iterator string 当前Shard读取的iterator。
limit int32 本次读取的最大个数。

响应消息结构

message GetStreamRecordResponse {
    message StreamRecord {
        required ActionType action_type = 1;
        required bytes record = 2;
    }
    repeated StreamRecord stream_records = 1;
    optional raw_string next_shard_iterator = 2;
    optional ConsumedCapacity consumed = 3;
}
            
名称 类型 描述
StreamRecord repeated StreamRecord 读取当前Shard记录的record entry。
shard_iterator string 下次读取此Shard的iterator。
consumed ConsumedCapacity 读取Stream数据时CU的计算是根据读取所有行总大小除以4 KB向上取整。关于行的数据大小计算方式的更多信息,请参见数据存储

使用SDK

Java SDK:获取Shard的更新记录