调用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向上取整。关于行的数据大小计算方式的更多信息,请参见数据存储。
|