jdcloud_sdk.services.jcq.models package

Submodules

jdcloud_sdk.services.jcq.models.AccessPoint module

class jdcloud_sdk.services.jcq.models.AccessPoint.AccessPoint(sdkAddress=None, httpAddress=None)[source]

Bases: object

Parameters:
  • sdkAddress – (Optional) sdk接入点
  • httpAddress – (Optional) http接入点

jdcloud_sdk.services.jcq.models.DeadLetter module

class jdcloud_sdk.services.jcq.models.DeadLetter.DeadLetter(messageId=None, expireTime=None)[source]

Bases: object

Parameters:
  • messageId – (Optional) id
  • expireTime – (Optional) 过期时间

jdcloud_sdk.services.jcq.models.DeadLetterNumber module

class jdcloud_sdk.services.jcq.models.DeadLetterNumber.DeadLetterNumber(topicId=None, topicName=None, consumerGroupId=None, deadLetterNumber=None)[source]

Bases: object

Parameters:
  • topicId – (Optional) topic的编号
  • topicName – (Optional) topic名称
  • consumerGroupId – (Optional) consumerGroupId
  • deadLetterNumber – (Optional) 死信队列数

jdcloud_sdk.services.jcq.models.Message module

class jdcloud_sdk.services.jcq.models.Message.Message(messageId=None, body=None, tags=None, properties=None, storeTime=None)[source]

Bases: object

Parameters:
  • messageId – (Optional) 消息id
  • body – (Optional) 内容
  • tags – (Optional) tag以逗号隔开
  • properties – (Optional) 用户设置的属性json字符串
  • storeTime – (Optional) 消息的存储时间

jdcloud_sdk.services.jcq.models.Permission module

class jdcloud_sdk.services.jcq.models.Permission.Permission(userId=None, permission=None)[source]

Bases: object

Parameters:
  • userId – (Optional) userId
  • permission – (Optional) permission, [SUB, PUB, PUBSUB]

jdcloud_sdk.services.jcq.models.Subscription module

class jdcloud_sdk.services.jcq.models.Subscription.Subscription(consumerGroupId=None, endPoint=None, messageInvisibleTimeInSeconds=None, subscriptionType=None, tags=None, dlqEnable=None, maxRetryTimes=None, createTime=None, lastUpdateTime=None, consumerNumbers=None)[source]

Bases: object

Parameters:
  • consumerGroupId – (Optional) consumerGroupId
  • endPoint – (Optional) endPoint
  • messageInvisibleTimeInSeconds – (Optional) messageInvisibleTimeInSeconds
  • subscriptionType – (Optional) subscriptionType
  • tags – (Optional) tags
  • dlqEnable – (Optional) 是否开启死信队列
  • maxRetryTimes – (Optional) 最大重试次数
  • createTime – (Optional) 创建时间
  • lastUpdateTime – (Optional) 最后更新时间
  • consumerNumbers – (Optional) 在线consumer个数

jdcloud_sdk.services.jcq.models.Tag module

class jdcloud_sdk.services.jcq.models.Tag.Tag(key=None, value=None)[source]

Bases: object

Parameters:
  • key – (Optional) 标签的键
  • value – (Optional) 标签的值

jdcloud_sdk.services.jcq.models.Topic module

class jdcloud_sdk.services.jcq.models.Topic.Topic(topicId=None, topicName=None, description=None, createTime=None, lastUpdateTime=None, topicStatus=None, subscriptionCount=None, messageLifeTimeInHours=None, topicConfig=None, own=None, authorizedPermission=None, tags=None)[source]

Bases: object

Parameters:
  • topicId – (Optional) topic Id
  • topicName – (Optional) topic名称
  • description – (Optional) 描述
  • createTime – (Optional) 创建时间
  • lastUpdateTime – (Optional) 更新时间
  • topicStatus – (Optional) topicStatus
  • subscriptionCount – (Optional) 自己创建的订阅数
  • messageLifeTimeInHours – (Optional) 消息生命周期时长小时
  • topicConfig – (Optional) 配置信息
  • own – (Optional) 是否是自己的topic
  • authorizedPermission – (Optional) 被授权的权限[PUB,SUB,PUBSUB,READ_ONLY,ADMIN]
  • tags – (Optional) 标签信息

jdcloud_sdk.services.jcq.models.TopicConfig module

class jdcloud_sdk.services.jcq.models.TopicConfig.TopicConfig(maxMessageSizeKB=None, threshold=None, topicPermission=None, topicType=None)[source]

Bases: object

Parameters:
  • maxMessageSizeKB – (Optional) 消息最大长度
  • threshold – (Optional) tps
  • topicPermission – (Optional) topicPermission
  • topicType – (Optional) topicType

Module contents