开发者社区> 问答> 正文

如何操作DescribeStream



行为:


获取当前stream的shard信息。

请求结构:message DescribeStreamRequest {
    required string stream_id = 1;
    optional string inclusive_start_shard_id = 2;
    optional int32 shard_limit = 3;
}





stream_id:


  • 类型:required string

  • 当前stream的id


inclusive_start_shard_id:


  • 类型:required string

  • 查询起始shard的id


shard_limit:


  • 类型:required string

  • 单次查询返回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:


  • 类型:required string

  • 当前stream的id


expiration_time:


  • 类型:required int32

  • Stream的过期时间


table_name:


  • 类型:required string

  • 当前stream 所属的table名字


creation_time:


  • 类型:required int32

  • 当前stream创建的时间


stream_status:


  • 类型:required StreamStatus

  • 当前stream的状态,包括enabling和active


stream_status:


  • 类型:required StreamStatus

  • 当前stream的状态,包括enabling和active


shards:


  • 类型:required StreamShard

  • streamShard的信息,包括shard的id,父shard的id,父shard的邻居shard信息(适用于父shard发生merge)


next_shard_id:


  • 类型:optional string

  • 分页查询下一个shard的起始id


注意事项:


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

展开
收起
云栖大讲堂 2017-10-25 14:17:37 1686 0
0 条回答
写回答
取消 提交回答
问答地址:
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载