# -*- coding: utf8 -*- # Copyright (c) 2017-2021 THL A29 Limited, a Tencent company. All Rights Reserved. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. import json from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException from tencentcloud.common.abstract_client import AbstractClient from tencentcloud.tdmq.v20200217 import models class TdmqClient(AbstractClient): _apiVersion = '2020-02-17' _endpoint = 'tdmq.tencentcloudapi.com' _service = 'tdmq' def AcknowledgeMessage(self, request): """根据提供的 MessageID 确认指定 topic 中的消息 :param request: Request instance for AcknowledgeMessage. :type request: :class:`tencentcloud.tdmq.v20200217.models.AcknowledgeMessageRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.AcknowledgeMessageResponse` """ try: params = request._serialize() headers = request.headers body = self.call("AcknowledgeMessage", params, headers=headers) response = json.loads(body) model = models.AcknowledgeMessageResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ClearCmqQueue(self, request): """清空cmq消息队列中的消息 :param request: Request instance for ClearCmqQueue. :type request: :class:`tencentcloud.tdmq.v20200217.models.ClearCmqQueueRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ClearCmqQueueResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ClearCmqQueue", params, headers=headers) response = json.loads(body) model = models.ClearCmqQueueResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ClearCmqSubscriptionFilterTags(self, request): """清空订阅者消息标签 :param request: Request instance for ClearCmqSubscriptionFilterTags. :type request: :class:`tencentcloud.tdmq.v20200217.models.ClearCmqSubscriptionFilterTagsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ClearCmqSubscriptionFilterTagsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ClearCmqSubscriptionFilterTags", params, headers=headers) response = json.loads(body) model = models.ClearCmqSubscriptionFilterTagsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateAMQPCluster(self, request): """产品下线了，对应的接口也要下线。 创建AMQP集群 :param request: Request instance for CreateAMQPCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateAMQPClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateAMQPClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateAMQPCluster", params, headers=headers) response = json.loads(body) model = models.CreateAMQPClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateAMQPExchange(self, request): """产品下线了，对应的接口也要下线。 创建AMQP Exchange :param request: Request instance for CreateAMQPExchange. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateAMQPExchangeRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateAMQPExchangeResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateAMQPExchange", params, headers=headers) response = json.loads(body) model = models.CreateAMQPExchangeResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateAMQPQueue(self, request): """产品下线了，对应的接口也要下线。 创建AMQP队列 :param request: Request instance for CreateAMQPQueue. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateAMQPQueueRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateAMQPQueueResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateAMQPQueue", params, headers=headers) response = json.loads(body) model = models.CreateAMQPQueueResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateAMQPRouteRelation(self, request): """产品下线了，对应的接口也要下线。 创建AMQP路由关系 :param request: Request instance for CreateAMQPRouteRelation. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateAMQPRouteRelationRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateAMQPRouteRelationResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateAMQPRouteRelation", params, headers=headers) response = json.loads(body) model = models.CreateAMQPRouteRelationResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateAMQPVHost(self, request): """产品下线了，对应的接口也要下线。 创建Amqp Vhost :param request: Request instance for CreateAMQPVHost. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateAMQPVHostRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateAMQPVHostResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateAMQPVHost", params, headers=headers) response = json.loads(body) model = models.CreateAMQPVHostResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateCluster(self, request): """创建用户的集群 :param request: Request instance for CreateCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateCluster", params, headers=headers) response = json.loads(body) model = models.CreateClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateCmqQueue(self, request): """创建cmq队列接口 :param request: Request instance for CreateCmqQueue. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateCmqQueueRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateCmqQueueResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateCmqQueue", params, headers=headers) response = json.loads(body) model = models.CreateCmqQueueResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateCmqSubscribe(self, request): """创建cmq订阅接口 :param request: Request instance for CreateCmqSubscribe. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateCmqSubscribeRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateCmqSubscribeResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateCmqSubscribe", params, headers=headers) response = json.loads(body) model = models.CreateCmqSubscribeResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateCmqTopic(self, request): """创建cmq主题 :param request: Request instance for CreateCmqTopic. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateCmqTopicRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateCmqTopicResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateCmqTopic", params, headers=headers) response = json.loads(body) model = models.CreateCmqTopicResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateEnvironment(self, request): """用于在用户账户下创建消息队列 Tdmq 命名空间 :param request: Request instance for CreateEnvironment. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateEnvironmentRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateEnvironmentResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateEnvironment", params, headers=headers) response = json.loads(body) model = models.CreateEnvironmentResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateEnvironmentRole(self, request): """创建环境角色授权 :param request: Request instance for CreateEnvironmentRole. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateEnvironmentRoleRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateEnvironmentRoleResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateEnvironmentRole", params, headers=headers) response = json.loads(body) model = models.CreateEnvironmentRoleResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateRabbitMQVipInstance(self, request): """创建RabbitMQ专享版实例 :param request: Request instance for CreateRabbitMQVipInstance. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateRabbitMQVipInstanceRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateRabbitMQVipInstanceResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateRabbitMQVipInstance", params, headers=headers) response = json.loads(body) model = models.CreateRabbitMQVipInstanceResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateRocketMQCluster(self, request): """此接口用于创建一个RocketMQ集群 :param request: Request instance for CreateRocketMQCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateRocketMQClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateRocketMQClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateRocketMQCluster", params, headers=headers) response = json.loads(body) model = models.CreateRocketMQClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateRocketMQGroup(self, request): """创建RocketMQ消费组 :param request: Request instance for CreateRocketMQGroup. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateRocketMQGroupRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateRocketMQGroupResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateRocketMQGroup", params, headers=headers) response = json.loads(body) model = models.CreateRocketMQGroupResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateRocketMQNamespace(self, request): """创建RocketMQ命名空间 :param request: Request instance for CreateRocketMQNamespace. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateRocketMQNamespaceRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateRocketMQNamespaceResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateRocketMQNamespace", params, headers=headers) response = json.loads(body) model = models.CreateRocketMQNamespaceResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateRocketMQTopic(self, request): """创建RocketMQ主题 :param request: Request instance for CreateRocketMQTopic. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateRocketMQTopicRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateRocketMQTopicResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateRocketMQTopic", params, headers=headers) response = json.loads(body) model = models.CreateRocketMQTopicResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateRole(self, request): """创建角色 :param request: Request instance for CreateRole. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateRoleRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateRoleResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateRole", params, headers=headers) response = json.loads(body) model = models.CreateRoleResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateSubscription(self, request): """创建一个主题的订阅关系 :param request: Request instance for CreateSubscription. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateSubscriptionRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateSubscriptionResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateSubscription", params, headers=headers) response = json.loads(body) model = models.CreateSubscriptionResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def CreateTopic(self, request): """新增指定分区、类型的消息主题 :param request: Request instance for CreateTopic. :type request: :class:`tencentcloud.tdmq.v20200217.models.CreateTopicRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.CreateTopicResponse` """ try: params = request._serialize() headers = request.headers body = self.call("CreateTopic", params, headers=headers) response = json.loads(body) model = models.CreateTopicResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteAMQPCluster(self, request): """产品下线了，对应的接口也要下线。 删除AMQP集群 :param request: Request instance for DeleteAMQPCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteAMQPClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteAMQPClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteAMQPCluster", params, headers=headers) response = json.loads(body) model = models.DeleteAMQPClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteAMQPExchange(self, request): """产品下线了，对应的接口也要下线。 删除Amqp交换机 :param request: Request instance for DeleteAMQPExchange. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteAMQPExchangeRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteAMQPExchangeResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteAMQPExchange", params, headers=headers) response = json.loads(body) model = models.DeleteAMQPExchangeResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteAMQPQueue(self, request): """产品下线了，对应的接口也要下线。 删除Amqp队列 :param request: Request instance for DeleteAMQPQueue. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteAMQPQueueRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteAMQPQueueResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteAMQPQueue", params, headers=headers) response = json.loads(body) model = models.DeleteAMQPQueueResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteAMQPRouteRelation(self, request): """产品下线了，对应的接口也要下线。 删除Amqp路由关系 :param request: Request instance for DeleteAMQPRouteRelation. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteAMQPRouteRelationRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteAMQPRouteRelationResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteAMQPRouteRelation", params, headers=headers) response = json.loads(body) model = models.DeleteAMQPRouteRelationResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteAMQPVHost(self, request): """产品下线了，对应的接口也要下线。 删除Vhost :param request: Request instance for DeleteAMQPVHost. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteAMQPVHostRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteAMQPVHostResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteAMQPVHost", params, headers=headers) response = json.loads(body) model = models.DeleteAMQPVHostResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteCluster(self, request): """删除集群 :param request: Request instance for DeleteCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteCluster", params, headers=headers) response = json.loads(body) model = models.DeleteClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteCmqQueue(self, request): """删除cmq队列 :param request: Request instance for DeleteCmqQueue. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteCmqQueueRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteCmqQueueResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteCmqQueue", params, headers=headers) response = json.loads(body) model = models.DeleteCmqQueueResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteCmqSubscribe(self, request): """删除cmq订阅 :param request: Request instance for DeleteCmqSubscribe. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteCmqSubscribeRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteCmqSubscribeResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteCmqSubscribe", params, headers=headers) response = json.loads(body) model = models.DeleteCmqSubscribeResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteCmqTopic(self, request): """删除cmq主题 :param request: Request instance for DeleteCmqTopic. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteCmqTopicRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteCmqTopicResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteCmqTopic", params, headers=headers) response = json.loads(body) model = models.DeleteCmqTopicResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteEnvironmentRoles(self, request): """删除环境角色授权。 :param request: Request instance for DeleteEnvironmentRoles. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteEnvironmentRolesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteEnvironmentRolesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteEnvironmentRoles", params, headers=headers) response = json.loads(body) model = models.DeleteEnvironmentRolesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteEnvironments(self, request): """批量删除租户下的命名空间 :param request: Request instance for DeleteEnvironments. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteEnvironmentsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteEnvironmentsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteEnvironments", params, headers=headers) response = json.loads(body) model = models.DeleteEnvironmentsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteRocketMQCluster(self, request): """删除RocketMQ集群 :param request: Request instance for DeleteRocketMQCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteRocketMQClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteRocketMQClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteRocketMQCluster", params, headers=headers) response = json.loads(body) model = models.DeleteRocketMQClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteRocketMQGroup(self, request): """删除RocketMQ消费组 :param request: Request instance for DeleteRocketMQGroup. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteRocketMQGroupRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteRocketMQGroupResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteRocketMQGroup", params, headers=headers) response = json.loads(body) model = models.DeleteRocketMQGroupResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteRocketMQNamespace(self, request): """删除RocketMQ命名空间 :param request: Request instance for DeleteRocketMQNamespace. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteRocketMQNamespaceRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteRocketMQNamespaceResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteRocketMQNamespace", params, headers=headers) response = json.loads(body) model = models.DeleteRocketMQNamespaceResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteRocketMQTopic(self, request): """删除RocketMQ主题 :param request: Request instance for DeleteRocketMQTopic. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteRocketMQTopicRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteRocketMQTopicResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteRocketMQTopic", params, headers=headers) response = json.loads(body) model = models.DeleteRocketMQTopicResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteRoles(self, request): """删除角色，支持批量。 :param request: Request instance for DeleteRoles. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteRolesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteRolesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteRoles", params, headers=headers) response = json.loads(body) model = models.DeleteRolesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteSubscriptions(self, request): """删除订阅关系 :param request: Request instance for DeleteSubscriptions. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteSubscriptionsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteSubscriptionsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteSubscriptions", params, headers=headers) response = json.loads(body) model = models.DeleteSubscriptionsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DeleteTopics(self, request): """批量删除topics :param request: Request instance for DeleteTopics. :type request: :class:`tencentcloud.tdmq.v20200217.models.DeleteTopicsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DeleteTopicsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DeleteTopics", params, headers=headers) response = json.loads(body) model = models.DeleteTopicsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeAMQPCluster(self, request): """产品下线了，对应的接口也要下线。 获取单个Amqp集群信息 :param request: Request instance for DescribeAMQPCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeAMQPCluster", params, headers=headers) response = json.loads(body) model = models.DescribeAMQPClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeAMQPClusters(self, request): """获取amqp集群列表 :param request: Request instance for DescribeAMQPClusters. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPClustersRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPClustersResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeAMQPClusters", params, headers=headers) response = json.loads(body) model = models.DescribeAMQPClustersResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeAMQPCreateQuota(self, request): """产品下线了，对应的接口也要下线。 获取用户的配额，如Queue容量，Exchange容量，Vhost容量，单Vhost Tps数,剩余可创建集群数 :param request: Request instance for DescribeAMQPCreateQuota. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPCreateQuotaRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPCreateQuotaResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeAMQPCreateQuota", params, headers=headers) response = json.loads(body) model = models.DescribeAMQPCreateQuotaResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeAMQPExchanges(self, request): """产品下线了，对应的接口也要下线。 获取AMQP Exchange列表 :param request: Request instance for DescribeAMQPExchanges. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPExchangesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPExchangesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeAMQPExchanges", params, headers=headers) response = json.loads(body) model = models.DescribeAMQPExchangesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeAMQPQueues(self, request): """产品下线了，对应的接口也要下线。 获取Amqp队列列表 :param request: Request instance for DescribeAMQPQueues. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPQueuesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPQueuesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeAMQPQueues", params, headers=headers) response = json.loads(body) model = models.DescribeAMQPQueuesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeAMQPRouteRelations(self, request): """产品下线了，对应的接口也要下线。 获取Amqp路由关系列表 :param request: Request instance for DescribeAMQPRouteRelations. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPRouteRelationsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPRouteRelationsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeAMQPRouteRelations", params, headers=headers) response = json.loads(body) model = models.DescribeAMQPRouteRelationsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeAMQPVHosts(self, request): """产品下线了，对应的接口也要下线。 获取Amqp Vhost 列表 :param request: Request instance for DescribeAMQPVHosts. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPVHostsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeAMQPVHostsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeAMQPVHosts", params, headers=headers) response = json.loads(body) model = models.DescribeAMQPVHostsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeAllTenants(self, request): """获取某个租户的虚拟集群列表 :param request: Request instance for DescribeAllTenants. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeAllTenantsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeAllTenantsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeAllTenants", params, headers=headers) response = json.loads(body) model = models.DescribeAllTenantsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeBindClusters(self, request): """获取用户绑定的专享集群列表 :param request: Request instance for DescribeBindClusters. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeBindClustersRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeBindClustersResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeBindClusters", params, headers=headers) response = json.loads(body) model = models.DescribeBindClustersResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeBindVpcs(self, request): """获取租户VPC绑定关系 :param request: Request instance for DescribeBindVpcs. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeBindVpcsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeBindVpcsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeBindVpcs", params, headers=headers) response = json.loads(body) model = models.DescribeBindVpcsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeClusterDetail(self, request): """获取集群的详细信息 :param request: Request instance for DescribeClusterDetail. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeClusterDetailRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeClusterDetailResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeClusterDetail", params, headers=headers) response = json.loads(body) model = models.DescribeClusterDetailResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeClusters(self, request): """获取集群列表 :param request: Request instance for DescribeClusters. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeClustersRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeClustersResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeClusters", params, headers=headers) response = json.loads(body) model = models.DescribeClustersResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeCmqDeadLetterSourceQueues(self, request): """枚举cmq死信队列源队列 :param request: Request instance for DescribeCmqDeadLetterSourceQueues. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqDeadLetterSourceQueuesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqDeadLetterSourceQueuesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeCmqDeadLetterSourceQueues", params, headers=headers) response = json.loads(body) model = models.DescribeCmqDeadLetterSourceQueuesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeCmqQueueDetail(self, request): """查询cmq队列详情 :param request: Request instance for DescribeCmqQueueDetail. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqQueueDetailRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqQueueDetailResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeCmqQueueDetail", params, headers=headers) response = json.loads(body) model = models.DescribeCmqQueueDetailResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeCmqQueues(self, request): """查询cmq全量队列 :param request: Request instance for DescribeCmqQueues. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqQueuesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqQueuesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeCmqQueues", params, headers=headers) response = json.loads(body) model = models.DescribeCmqQueuesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeCmqSubscriptionDetail(self, request): """查询cmq订阅详情 :param request: Request instance for DescribeCmqSubscriptionDetail. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqSubscriptionDetailRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqSubscriptionDetailResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeCmqSubscriptionDetail", params, headers=headers) response = json.loads(body) model = models.DescribeCmqSubscriptionDetailResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeCmqTopicDetail(self, request): """查询cmq主题详情 :param request: Request instance for DescribeCmqTopicDetail. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqTopicDetailRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqTopicDetailResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeCmqTopicDetail", params, headers=headers) response = json.loads(body) model = models.DescribeCmqTopicDetailResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeCmqTopics(self, request): """枚举cmq全量主题 :param request: Request instance for DescribeCmqTopics. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqTopicsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeCmqTopicsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeCmqTopics", params, headers=headers) response = json.loads(body) model = models.DescribeCmqTopicsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeEnvironmentAttributes(self, request): """获取指定命名空间的属性 :param request: Request instance for DescribeEnvironmentAttributes. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeEnvironmentAttributesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeEnvironmentAttributesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeEnvironmentAttributes", params, headers=headers) response = json.loads(body) model = models.DescribeEnvironmentAttributesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeEnvironmentRoles(self, request): """获取命名空间角色列表 :param request: Request instance for DescribeEnvironmentRoles. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeEnvironmentRolesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeEnvironmentRolesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeEnvironmentRoles", params, headers=headers) response = json.loads(body) model = models.DescribeEnvironmentRolesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeEnvironments(self, request): """获取租户下命名空间列表 :param request: Request instance for DescribeEnvironments. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeEnvironmentsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeEnvironmentsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeEnvironments", params, headers=headers) response = json.loads(body) model = models.DescribeEnvironmentsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeNamespaceBundlesOpt(self, request): """运营端获取命名空间bundle列表 :param request: Request instance for DescribeNamespaceBundlesOpt. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeNamespaceBundlesOptRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeNamespaceBundlesOptResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeNamespaceBundlesOpt", params, headers=headers) response = json.loads(body) model = models.DescribeNamespaceBundlesOptResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeNodeHealthOpt(self, request): """运营端获节点健康状态 :param request: Request instance for DescribeNodeHealthOpt. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeNodeHealthOptRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeNodeHealthOptResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeNodeHealthOpt", params, headers=headers) response = json.loads(body) model = models.DescribeNodeHealthOptResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribePublisherSummary(self, request): """获取消息生产概览信息 :param request: Request instance for DescribePublisherSummary. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribePublisherSummaryRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribePublisherSummaryResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribePublisherSummary", params, headers=headers) response = json.loads(body) model = models.DescribePublisherSummaryResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribePublishers(self, request): """获取生产者信息列表 :param request: Request instance for DescribePublishers. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribePublishersRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribePublishersResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribePublishers", params, headers=headers) response = json.loads(body) model = models.DescribePublishersResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribePulsarProInstanceDetail(self, request): """获取Pulsar专业版集群实例信息 :param request: Request instance for DescribePulsarProInstanceDetail. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribePulsarProInstanceDetailRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribePulsarProInstanceDetailResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribePulsarProInstanceDetail", params, headers=headers) response = json.loads(body) model = models.DescribePulsarProInstanceDetailResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribePulsarProInstances(self, request): """查询用户已购的Pulsar专业版实例列表 :param request: Request instance for DescribePulsarProInstances. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribePulsarProInstancesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribePulsarProInstancesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribePulsarProInstances", params, headers=headers) response = json.loads(body) model = models.DescribePulsarProInstancesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRabbitMQNodeList(self, request): """RabbitMQ专享版查询节点列表 :param request: Request instance for DescribeRabbitMQNodeList. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRabbitMQNodeListRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRabbitMQNodeListResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRabbitMQNodeList", params, headers=headers) response = json.loads(body) model = models.DescribeRabbitMQNodeListResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRabbitMQVipInstance(self, request): """获取单个RabbitMQ专享实例信息 :param request: Request instance for DescribeRabbitMQVipInstance. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRabbitMQVipInstanceRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRabbitMQVipInstanceResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRabbitMQVipInstance", params, headers=headers) response = json.loads(body) model = models.DescribeRabbitMQVipInstanceResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRabbitMQVipInstances(self, request): """查询用户已购的RabbitMQ专享实例列表 :param request: Request instance for DescribeRabbitMQVipInstances. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRabbitMQVipInstancesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRabbitMQVipInstancesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRabbitMQVipInstances", params, headers=headers) response = json.loads(body) model = models.DescribeRabbitMQVipInstancesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRocketMQCluster(self, request): """获取单个RocketMQ集群信息 :param request: Request instance for DescribeRocketMQCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRocketMQCluster", params, headers=headers) response = json.loads(body) model = models.DescribeRocketMQClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRocketMQClusters(self, request): """获取RocketMQ集群列表 :param request: Request instance for DescribeRocketMQClusters. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQClustersRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQClustersResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRocketMQClusters", params, headers=headers) response = json.loads(body) model = models.DescribeRocketMQClustersResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRocketMQGroups(self, request): """获取RocketMQ消费组列表 :param request: Request instance for DescribeRocketMQGroups. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQGroupsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQGroupsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRocketMQGroups", params, headers=headers) response = json.loads(body) model = models.DescribeRocketMQGroupsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRocketMQNamespaces(self, request): """获取RocketMQ命名空间列表 :param request: Request instance for DescribeRocketMQNamespaces. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQNamespacesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQNamespacesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRocketMQNamespaces", params, headers=headers) response = json.loads(body) model = models.DescribeRocketMQNamespacesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRocketMQTopics(self, request): """获取RocketMQ主题列表 :param request: Request instance for DescribeRocketMQTopics. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQTopicsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQTopicsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRocketMQTopics", params, headers=headers) response = json.loads(body) model = models.DescribeRocketMQTopicsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRocketMQVipInstanceDetail(self, request): """获取单个RocketMQ专享集群信息 :param request: Request instance for DescribeRocketMQVipInstanceDetail. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQVipInstanceDetailRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQVipInstanceDetailResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRocketMQVipInstanceDetail", params, headers=headers) response = json.loads(body) model = models.DescribeRocketMQVipInstanceDetailResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRocketMQVipInstances(self, request): """查询用户已购的RocketMQ专享实例列表 :param request: Request instance for DescribeRocketMQVipInstances. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQVipInstancesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRocketMQVipInstancesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRocketMQVipInstances", params, headers=headers) response = json.loads(body) model = models.DescribeRocketMQVipInstancesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeRoles(self, request): """获取角色列表 :param request: Request instance for DescribeRoles. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeRolesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeRolesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeRoles", params, headers=headers) response = json.loads(body) model = models.DescribeRolesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeSubscriptions(self, request): """查询指定环境和主题下的订阅者列表 :param request: Request instance for DescribeSubscriptions. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeSubscriptionsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeSubscriptionsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeSubscriptions", params, headers=headers) response = json.loads(body) model = models.DescribeSubscriptionsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def DescribeTopics(self, request): """获取环境下主题列表 :param request: Request instance for DescribeTopics. :type request: :class:`tencentcloud.tdmq.v20200217.models.DescribeTopicsRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.DescribeTopicsResponse` """ try: params = request._serialize() headers = request.headers body = self.call("DescribeTopics", params, headers=headers) response = json.loads(body) model = models.DescribeTopicsResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyAMQPCluster(self, request): """更新Amqp集群信息 :param request: Request instance for ModifyAMQPCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyAMQPClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyAMQPClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyAMQPCluster", params, headers=headers) response = json.loads(body) model = models.ModifyAMQPClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyAMQPExchange(self, request): """产品下线了，对应的接口也要下线。 更新Amqp交换机 :param request: Request instance for ModifyAMQPExchange. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyAMQPExchangeRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyAMQPExchangeResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyAMQPExchange", params, headers=headers) response = json.loads(body) model = models.ModifyAMQPExchangeResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyAMQPQueue(self, request): """产品下线了，对应的接口也要下线。 更新Amqp队列 :param request: Request instance for ModifyAMQPQueue. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyAMQPQueueRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyAMQPQueueResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyAMQPQueue", params, headers=headers) response = json.loads(body) model = models.ModifyAMQPQueueResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyAMQPVHost(self, request): """产品下线了，对应的接口也要下线。 更新Vhost :param request: Request instance for ModifyAMQPVHost. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyAMQPVHostRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyAMQPVHostResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyAMQPVHost", params, headers=headers) response = json.loads(body) model = models.ModifyAMQPVHostResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyCluster(self, request): """更新集群信息 :param request: Request instance for ModifyCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyCluster", params, headers=headers) response = json.loads(body) model = models.ModifyClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyCmqQueueAttribute(self, request): """修改cmq队列属性 :param request: Request instance for ModifyCmqQueueAttribute. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyCmqQueueAttributeRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyCmqQueueAttributeResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyCmqQueueAttribute", params, headers=headers) response = json.loads(body) model = models.ModifyCmqQueueAttributeResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyCmqSubscriptionAttribute(self, request): """修改cmq订阅属性 :param request: Request instance for ModifyCmqSubscriptionAttribute. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyCmqSubscriptionAttributeRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyCmqSubscriptionAttributeResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyCmqSubscriptionAttribute", params, headers=headers) response = json.loads(body) model = models.ModifyCmqSubscriptionAttributeResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyCmqTopicAttribute(self, request): """修改cmq主题属性 :param request: Request instance for ModifyCmqTopicAttribute. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyCmqTopicAttributeRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyCmqTopicAttributeResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyCmqTopicAttribute", params, headers=headers) response = json.loads(body) model = models.ModifyCmqTopicAttributeResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyEnvironmentAttributes(self, request): """修改指定命名空间的属性值 :param request: Request instance for ModifyEnvironmentAttributes. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyEnvironmentAttributesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyEnvironmentAttributesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyEnvironmentAttributes", params, headers=headers) response = json.loads(body) model = models.ModifyEnvironmentAttributesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyEnvironmentRole(self, request): """修改环境角色授权。 :param request: Request instance for ModifyEnvironmentRole. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyEnvironmentRoleRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyEnvironmentRoleResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyEnvironmentRole", params, headers=headers) response = json.loads(body) model = models.ModifyEnvironmentRoleResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyRabbitMQVipInstance(self, request): """修改RabbitMQ专享版实例 :param request: Request instance for ModifyRabbitMQVipInstance. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyRabbitMQVipInstanceRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyRabbitMQVipInstanceResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyRabbitMQVipInstance", params, headers=headers) response = json.loads(body) model = models.ModifyRabbitMQVipInstanceResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyRocketMQCluster(self, request): """更新RocketMQ集群信息 :param request: Request instance for ModifyRocketMQCluster. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyRocketMQClusterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyRocketMQClusterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyRocketMQCluster", params, headers=headers) response = json.loads(body) model = models.ModifyRocketMQClusterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyRocketMQGroup(self, request): """更新RocketMQ消费组信息 :param request: Request instance for ModifyRocketMQGroup. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyRocketMQGroupRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyRocketMQGroupResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyRocketMQGroup", params, headers=headers) response = json.loads(body) model = models.ModifyRocketMQGroupResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyRocketMQInstanceSpec(self, request): """本API用于修改RocketMQ专享实例配置，可以支持实例规格、节点数和存储的升配和实例规格的降配。本API发起订单并成功支付后进入实例配置变更的流程，可通过DescribeRocketMQVipInstances查询实例是否已变更完成。 :param request: Request instance for ModifyRocketMQInstanceSpec. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyRocketMQInstanceSpecRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyRocketMQInstanceSpecResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyRocketMQInstanceSpec", params, headers=headers) response = json.loads(body) model = models.ModifyRocketMQInstanceSpecResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyRocketMQNamespace(self, request): """更新RocketMQ命名空间 :param request: Request instance for ModifyRocketMQNamespace. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyRocketMQNamespaceRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyRocketMQNamespaceResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyRocketMQNamespace", params, headers=headers) response = json.loads(body) model = models.ModifyRocketMQNamespaceResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyRocketMQTopic(self, request): """更新RocketMQ主题信息 :param request: Request instance for ModifyRocketMQTopic. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyRocketMQTopicRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyRocketMQTopicResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyRocketMQTopic", params, headers=headers) response = json.loads(body) model = models.ModifyRocketMQTopicResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyRole(self, request): """角色修改 :param request: Request instance for ModifyRole. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyRoleRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyRoleResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyRole", params, headers=headers) response = json.loads(body) model = models.ModifyRoleResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ModifyTopic(self, request): """修改主题备注和分区数 :param request: Request instance for ModifyTopic. :type request: :class:`tencentcloud.tdmq.v20200217.models.ModifyTopicRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ModifyTopicResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ModifyTopic", params, headers=headers) response = json.loads(body) model = models.ModifyTopicResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def PublishCmqMsg(self, request): """发送cmq主题消息 :param request: Request instance for PublishCmqMsg. :type request: :class:`tencentcloud.tdmq.v20200217.models.PublishCmqMsgRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.PublishCmqMsgResponse` """ try: params = request._serialize() headers = request.headers body = self.call("PublishCmqMsg", params, headers=headers) response = json.loads(body) model = models.PublishCmqMsgResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ReceiveMessage(self, request): """当前 ReceiveMessage 接口只支持 Partitioned 类型的 Topic。该接口用于接收发送到指定 Partitioned Topic 中的消息，当 Partitioned Topic 中没有消息但还去尝试调用该接口时，会抛出 ReceiveTimeout 的异常。 如何使用 BatchReceivePolicy： BatchReceive 接口提供了如下三个参数： ● MaxNumMessages: 即每次使用 BatchReceive 的时候，最多一次Receive接口返回多少条消息。 ● MaxNumBytes：即每次使用 BatchReceive 的时候，最多一次Receive接口返回多大内容的消息，单位是：bytes。 ● Timeout：即每次使用 BatchReceive 的时候，最多一次 Receive 接口的超时时间是多久，单位是：MS。 默认如果上述三个参数都不指定，即关闭 BatchReceive 的特性。如果三个参数中的任意一个参数指定的数值大于 0，即开启 BatchReceive。BatchReceive 的结束条件为到达上述三个参数中任意一个指定的阈值。 注意：MaxNumMessages 和 MaxNumBytes 每一次接收的最大消息同时受限于 ReceiveQueueSize 的大小，如果 ReceiveQueueSize 的大小设置为 5，MaxNumMessages 设置为10，那么一次 BatchReceive 接收的最多的消息是 5条，而不是10条。 BatchReceivePolicy 的接口会一次性返回多条消息： 1. 多条消息的内容之间使用特殊字符 '###' 来进行分割，业务侧接收到消息之后，可以利用不同语言提供的 Split 工具分割不同的消息。 2. 多条消息的 MessageID 之间使用特殊字符 '###' 来进行分割，业务侧接收到消息之后，可以利用不同语言提供的 Split 工具分割不同的消息。（用于在调用 AcknowledgeMessage 接口中填入所需要的 MessageID 字段信息） :param request: Request instance for ReceiveMessage. :type request: :class:`tencentcloud.tdmq.v20200217.models.ReceiveMessageRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ReceiveMessageResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ReceiveMessage", params, headers=headers) response = json.loads(body) model = models.ReceiveMessageResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ResetMsgSubOffsetByTimestamp(self, request): """根据时间戳进行消息回溯，精确到毫秒 :param request: Request instance for ResetMsgSubOffsetByTimestamp. :type request: :class:`tencentcloud.tdmq.v20200217.models.ResetMsgSubOffsetByTimestampRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ResetMsgSubOffsetByTimestampResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ResetMsgSubOffsetByTimestamp", params, headers=headers) response = json.loads(body) model = models.ResetMsgSubOffsetByTimestampResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def ResetRocketMQConsumerOffSet(self, request): """重置指定Group的消费位点到指定时间戳 :param request: Request instance for ResetRocketMQConsumerOffSet. :type request: :class:`tencentcloud.tdmq.v20200217.models.ResetRocketMQConsumerOffSetRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.ResetRocketMQConsumerOffSetResponse` """ try: params = request._serialize() headers = request.headers body = self.call("ResetRocketMQConsumerOffSet", params, headers=headers) response = json.loads(body) model = models.ResetRocketMQConsumerOffSetResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def RewindCmqQueue(self, request): """回溯cmq队列 :param request: Request instance for RewindCmqQueue. :type request: :class:`tencentcloud.tdmq.v20200217.models.RewindCmqQueueRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.RewindCmqQueueResponse` """ try: params = request._serialize() headers = request.headers body = self.call("RewindCmqQueue", params, headers=headers) response = json.loads(body) model = models.RewindCmqQueueResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def SendBatchMessages(self, request): """批量发送消息 注意：TDMQ 批量发送消息的接口是在 TDMQ-HTTP 的服务侧将消息打包为一个 Batch，然后将该 Batch 在服务内部当作一次 TCP 请求发送出去。所以在使用过程中，用户还是按照单条消息发送的逻辑，每一条消息是一个独立的 HTTP 的请求，在 TDMQ-HTTP 的服务内部，会将多个 HTTP 的请求聚合为一个 Batch 发送到服务端。即，批量发送消息在使用上与发送单条消息是一致的，batch 的聚合是在 TDMQ-HTTP 的服务内部完成的。 :param request: Request instance for SendBatchMessages. :type request: :class:`tencentcloud.tdmq.v20200217.models.SendBatchMessagesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.SendBatchMessagesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("SendBatchMessages", params, headers=headers) response = json.loads(body) model = models.SendBatchMessagesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def SendCmqMsg(self, request): """发送cmq消息 :param request: Request instance for SendCmqMsg. :type request: :class:`tencentcloud.tdmq.v20200217.models.SendCmqMsgRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.SendCmqMsgResponse` """ try: params = request._serialize() headers = request.headers body = self.call("SendCmqMsg", params, headers=headers) response = json.loads(body) model = models.SendCmqMsgResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def SendMessages(self, request): """发送单条消息 :param request: Request instance for SendMessages. :type request: :class:`tencentcloud.tdmq.v20200217.models.SendMessagesRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.SendMessagesResponse` """ try: params = request._serialize() headers = request.headers body = self.call("SendMessages", params, headers=headers) response = json.loads(body) model = models.SendMessagesResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def SendMsg(self, request): """此接口仅用于测试发生消息，不能作为现网正式生产使用 :param request: Request instance for SendMsg. :type request: :class:`tencentcloud.tdmq.v20200217.models.SendMsgRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.SendMsgResponse` """ try: params = request._serialize() headers = request.headers body = self.call("SendMsg", params, headers=headers) response = json.loads(body) model = models.SendMsgResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message) def UnbindCmqDeadLetter(self, request): """解绑cmq死信队列 :param request: Request instance for UnbindCmqDeadLetter. :type request: :class:`tencentcloud.tdmq.v20200217.models.UnbindCmqDeadLetterRequest` :rtype: :class:`tencentcloud.tdmq.v20200217.models.UnbindCmqDeadLetterResponse` """ try: params = request._serialize() headers = request.headers body = self.call("UnbindCmqDeadLetter", params, headers=headers) response = json.loads(body) model = models.UnbindCmqDeadLetterResponse() model._deserialize(response["Response"]) return model except Exception as e: if isinstance(e, TencentCloudSDKException): raise else: raise TencentCloudSDKException(e.message, e.message)