通过GetStreamRecord接口读取Shard的增量数据-表格存储-阿里云

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

请求消息结构

message GetStreamRecordRequest {
    required string shard_iterator = 1;
    optional int32 limit = 2;
    optional string table_name = 3;
}

名称	类型	是否必选	描述
shard_iterator	string	是	当前Shard读取的iterator。
limit	int32	否	本次读取的最大个数。
table_name	string	否	数据表名称。

响应消息结构

message GetStreamRecordResponse {
    repeated StreamRecord stream_records = 1;
    optional raw_string next_shard_iterator = 2;
    optional ConsumedCapacity consumed = 3;
    optional bool may_more_record = 4;
}

名称	类型	描述
StreamRecord	repeated StreamRecord	读取当前Shard记录的record entry。
next_shard_iterator	string	下次读取此Shard的iterator。
consumed	ConsumedCapacity	读取Stream数据时CU的计算是根据读取所有行总大小除以4 KB向上取整。关于行的数据大小计算方式的更多信息，请参见数据存储。
may_more_record	bool	指示是否可能还有更多的记录可供读取，以便客户端可以做出进一步的数据读取或处理决策。

使用SDK

Java SDK：获取Shard的更新记录