调用DescribeStream接口获取当前Stream的Shard信息。

注意事项

读取当前Shard的数据时需要确保父Shard的数据已经全部读取完毕。

请求消息结构

message DescribeStreamRequest {
    required string stream_id = 1;
    optional string inclusive_start_shard_id = 2;
    optional int32 shard_limit = 3;
}           
名称 类型 是否必选 描述
stream_id string 当前Stream的ID。
inclusive_start_shard_id string 查询起始Shard的ID。
shard_limit int32 单次查询返回Shard数目的上限。

响应消息结构

message DescribeStreamResponse {
    required string stream_id = 1;
    required int32 expiration_time = 2;
    required string table_name = 3;
    required int64 creation_time = 4;
    required StreamStatus stream_status = 5;
    repeated StreamShard shards = 6;
    optional string next_shard_id = 7;
}

message StreamShard {
    required string shard_id = 1;
    optional string parent_id = 2;
    optional string parent_sibling_id = 3;
}            
名称 类型 描述
stream_id string 当前Stream的ID。
expiration_time int32 Stream的过期时间。
table_name string 当前Stream所属的table名称。
creation_time int64 当前Stream创建的时间。
stream_status StreamStatus 当前Stream的状态,包括enabling和active。
shards StreamShard Streamshard的信息,包括Shard的ID,父Shard的ID和父Shard的邻居Shard信息。适用于父Shard发生merge。
next_shard_id string 分页查询下一个Shard的起始ID。

使用SDK

Java SDK:查询表Stream描述信息