調用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的更新記錄