調用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 | 讀取Stream資料時CU的計算是根據讀取所有行總大小除以4 KB向上取整。關於行的資料大小計算方式的更多資訊,請參見資料存放區。 | |
may_more_record | bool | 指示是否可能還有更多的記錄可供讀取,以便用戶端可以做出進一步的資料讀取或處理決策。 |