jdcloud_sdk.services.streambus.models package

Submodules

jdcloud_sdk.services.streambus.models.AddTopic module

class jdcloud_sdk.services.streambus.models.AddTopic.AddTopic(topic=None, target=None, parameterList=None)[source]

Bases: object

Parameters:
  • topic – (Optional)
  • target – (Optional)
  • parameterList – (Optional) 归档相关的具体参数

jdcloud_sdk.services.streambus.models.ConsumerGroup module

class jdcloud_sdk.services.streambus.models.ConsumerGroup.ConsumerGroup(id=None, name=None, createdTime=None, delete=None, topicId=None)[source]

Bases: object

Parameters:
  • id – (Optional)
  • name – (Optional)
  • createdTime – (Optional)
  • delete – (Optional)
  • topicId – (Optional)

jdcloud_sdk.services.streambus.models.ParameterList module

class jdcloud_sdk.services.streambus.models.ParameterList.ParameterList(pKey=None, pValue=None)[source]

Bases: object

Parameters:
  • pKey – (Optional)
  • pValue – (Optional)

jdcloud_sdk.services.streambus.models.Target module

class jdcloud_sdk.services.streambus.models.Target.Target(name=None, recordSize=None, cycle=None)[source]

Bases: object

Parameters:
  • name – (Optional) 需要归档的目的地
  • recordSize – (Optional) 当达到这个数据量时开始归档
  • cycle – (Optional) 进行归档任务的时间周期

jdcloud_sdk.services.streambus.models.Topic module

class jdcloud_sdk.services.streambus.models.Topic.Topic(id=None, archived=None, lifecycle=None, partitionNum=None, name=None, shardNum=None, remark=None)[source]

Bases: object

Parameters:
  • id – (Optional) 主题id
  • archived – (Optional) 是否归档（0：未归档，1：已归档）
  • lifecycle – (Optional) 数据写入后的保留时间
  • partitionNum – (Optional) 分区
  • name – (Optional) 流数据总线中topic的名字
  • shardNum – (Optional) 流数据总线shard的数量
  • remark – (Optional) 备注

jdcloud_sdk.services.streambus.models.TopicListInfo module

class jdcloud_sdk.services.streambus.models.TopicListInfo.TopicListInfo(archived=None, createdTime=None, deleted=None, id=None, lifecycle=None, name=None, partitionNum=None, remark=None, shardNum=None, status=None, topicName=None, uid=None, updatedTime=None, userPin=None, dataSize=None)[source]

Bases: object

Parameters:
  • archived – (Optional) 是否归档（0：未归档，1：已归档）
  • createdTime – (Optional) 创建topic的时间戳
  • deleted – (Optional) topic是否已删除（0：未删除，1：删除）
  • id – (Optional) topic的id值
  • lifecycle – (Optional) 数据写入后的保留时间
  • name – (Optional) 流数据总线中topic的名字
  • partitionNum – (Optional) 对应kafka中的分区数
  • remark – (Optional) 备注
  • shardNum – (Optional) 流数据总线shard的数量
  • status – (Optional) 0: 已创建, 1: 创建中
  • topicName – (Optional) 对应kafka中的topic名字
  • uid – (Optional) 对应kafka中的uid
  • updatedTime – (Optional) 更新topic的时间戳
  • userPin – (Optional) 用户的userPin
  • dataSize – (Optional)

jdcloud_sdk.services.streambus.models.TopicModel module

class jdcloud_sdk.services.streambus.models.TopicModel.TopicModel(topic=None, target=None, parameterList=None)[source]

Bases: object

Parameters:
  • topic – (Optional)
  • target – (Optional)
  • parameterList – (Optional) 归档相关的具体参数，需要对归档进行新建，更新，删除，修改对应参数值即可。<br>ossFlag，bucketName，directory，objectName 这四个参数值与ossFlag有关，若ossFlag为false，后面三个可为空，若为true，后面三个为异常数据保存位置，按需要填写即可。<br> 1）如果归档到数据计算服务需要传database，table，type，example，delimiter，targetColumn，analysisColumn，partsTargetColumn，partsAnalysisColumn。<br>2）如果归档到JFS需要传bucket，prefix，infix。<br>3）如果归档到京东云 Elasticsearch需要传host，port，indexType，idType，indexName，indexReferField，timestampFieldFormat，timestampIndexFormat，typeName，idReferField，noResolve，username，password。<br> 4）如果归档到mysql，则需要传host，database，table，username，password，type，example，delimiter。 <br>5)如果要归档到京东云数据库则需要传rdsId，database，table，username，password，type，example，delimiter。

Module contents