jdcloud_sdk.services.streambus.apis package¶
Submodules¶
jdcloud_sdk.services.streambus.apis.AddTopicRequest module¶
-
class
jdcloud_sdk.services.streambus.apis.AddTopicRequest.AddTopicParameters(regionId, topicModel)[source]¶ Bases:
objectParameters: - regionId – 地域ID
- topicModel – 示例：{“topicModel”:{“topic”:{“archived”:0,”id”:””,”name”:”create”,”remark”:”备注”,”shardNum”:1,”partitionNum”:2,”lifecycle”:3}}}
-
class
jdcloud_sdk.services.streambus.apis.AddTopicRequest.AddTopicRequest(parameters, header=None, version='v1')[source]¶ Bases:
jdcloud_sdk.core.jdcloudrequest.JDCloudRequest创建topic时，topicModel中只需要传topic参数，另外两个参数可为空
jdcloud_sdk.services.streambus.apis.CreateConsumerGroupRequest module¶
-
class
jdcloud_sdk.services.streambus.apis.CreateConsumerGroupRequest.CreateConsumerGroupParameters(regionId)[source]¶ Bases:
objectParameters: regionId – Region ID
-
class
jdcloud_sdk.services.streambus.apis.CreateConsumerGroupRequest.CreateConsumerGroupRequest(parameters, header=None, version='v1')[source]¶ Bases:
jdcloud_sdk.core.jdcloudrequest.JDCloudRequest创建consumerGroupName
jdcloud_sdk.services.streambus.apis.DeleteConsumerGroupRequest module¶
-
class
jdcloud_sdk.services.streambus.apis.DeleteConsumerGroupRequest.DeleteConsumerGroupParameters(regionId, topicId, consumerGroupId)[source]¶ Bases:
objectParameters: - regionId – Region ID
- topicId – 主题ID
- consumerGroupId – 消费组ID
-
class
jdcloud_sdk.services.streambus.apis.DeleteConsumerGroupRequest.DeleteConsumerGroupRequest(parameters, header=None, version='v1')[source]¶ Bases:
jdcloud_sdk.core.jdcloudrequest.JDCloudRequest删除consumerGroupName
jdcloud_sdk.services.streambus.apis.DeleteTopicRequest module¶
-
class
jdcloud_sdk.services.streambus.apis.DeleteTopicRequest.DeleteTopicParameters(regionId, name)[source]¶ Bases:
objectParameters: - regionId – 地域ID
- name –
-
class
jdcloud_sdk.services.streambus.apis.DeleteTopicRequest.DeleteTopicRequest(parameters, header=None, version='v1')[source]¶ Bases:
jdcloud_sdk.core.jdcloudrequest.JDCloudRequest删除topic
jdcloud_sdk.services.streambus.apis.DescribeTopicRequest module¶
-
class
jdcloud_sdk.services.streambus.apis.DescribeTopicRequest.DescribeTopicParameters(regionId, name)[source]¶ Bases:
objectParameters: - regionId – 地域ID
- name –
-
class
jdcloud_sdk.services.streambus.apis.DescribeTopicRequest.DescribeTopicRequest(parameters, header=None, version='v1')[source]¶ Bases:
jdcloud_sdk.core.jdcloudrequest.JDCloudRequest查询指定主题,如果已归档会返回归档信息
jdcloud_sdk.services.streambus.apis.GetConsumerGroupListRequest module¶
-
class
jdcloud_sdk.services.streambus.apis.GetConsumerGroupListRequest.GetConsumerGroupListParameters(regionId, topicId)[source]¶ Bases:
objectParameters: - regionId – Region ID
- topicId – 主题id
-
class
jdcloud_sdk.services.streambus.apis.GetConsumerGroupListRequest.GetConsumerGroupListRequest(parameters, header=None, version='v1')[source]¶ Bases:
jdcloud_sdk.core.jdcloudrequest.JDCloudRequest查看指定主题的所有消费组
jdcloud_sdk.services.streambus.apis.GetTopicListRequest module¶
-
class
jdcloud_sdk.services.streambus.apis.GetTopicListRequest.GetTopicListParameters(regionId)[source]¶ Bases:
objectParameters: regionId – 地域ID
-
class
jdcloud_sdk.services.streambus.apis.GetTopicListRequest.GetTopicListRequest(parameters, header=None, version='v1')[source]¶ Bases:
jdcloud_sdk.core.jdcloudrequest.JDCloudRequest查询topic列表，返回topic的集合
jdcloud_sdk.services.streambus.apis.UpdateTopicRequest module¶
-
class
jdcloud_sdk.services.streambus.apis.UpdateTopicRequest.UpdateTopicParameters(regionId, topicModel)[source]¶ Bases:
objectParameters: - regionId – 地域ID
- topicModel – 当更新主题时只需要修改topicModel中的topic中的属性即可；创建归档需要指定target以及归档的目的地(mysql,京东云 Elasticsearch,对象存储,数据计算服务)参数
-
class
jdcloud_sdk.services.streambus.apis.UpdateTopicRequest.UpdateTopicRequest(parameters, header=None, version='v1')[source]¶ Bases:
jdcloud_sdk.core.jdcloudrequest.JDCloudRequest此接口可以用来更新主题，创建归档，修改归档，删除归档，传入不同的参数可以实现不同的功能。修改归档只需要修改相应归档的参数，删除归档只需要把归档参数置为空即可