代码拉取完成,页面将自动刷新
# frozen_string_literal: true
# Copyright (c) 2017-2018 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.
require 'json'
module TencentCloud
module Trocket
module V20230308
class Client < TencentCloud::Common::AbstractClient
def initialize(credential, region, profile = nil)
api_version = '2023-03-08'
api_endpoint = 'trocket.tencentcloudapi.com'
sdk_version = 'TROCKET_' + File.read(File.expand_path('../VERSION', __dir__)).strip
super(credential, region, api_version, api_endpoint, sdk_version, profile)
end
# 创建消费组
# @param request: Request instance for CreateConsumerGroup.
# @type request: :class:`Tencentcloud::trocket::V20230308::CreateConsumerGroupRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::CreateConsumerGroupResponse`
def CreateConsumerGroup(request)
body = send_request('CreateConsumerGroup', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateConsumerGroupResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 创建 RocketMQ 5.x 集群
# @param request: Request instance for CreateInstance.
# @type request: :class:`Tencentcloud::trocket::V20230308::CreateInstanceRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::CreateInstanceResponse`
def CreateInstance(request)
body = send_request('CreateInstance', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateInstanceResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 为MQTT实例创建公网接入点
# @param request: Request instance for CreateMQTTInsPublicEndpoint.
# @type request: :class:`Tencentcloud::trocket::V20230308::CreateMQTTInsPublicEndpointRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::CreateMQTTInsPublicEndpointResponse`
def CreateMQTTInsPublicEndpoint(request)
body = send_request('CreateMQTTInsPublicEndpoint', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateMQTTInsPublicEndpointResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 购买新的MQTT实例
# @param request: Request instance for CreateMQTTInstance.
# @type request: :class:`Tencentcloud::trocket::V20230308::CreateMQTTInstanceRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::CreateMQTTInstanceResponse`
def CreateMQTTInstance(request)
body = send_request('CreateMQTTInstance', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateMQTTInstanceResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 创建主题
# @param request: Request instance for CreateMQTTTopic.
# @type request: :class:`Tencentcloud::trocket::V20230308::CreateMQTTTopicRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::CreateMQTTTopicResponse`
def CreateMQTTTopic(request)
body = send_request('CreateMQTTTopic', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateMQTTTopicResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 添加mqtt角色
# @param request: Request instance for CreateMQTTUser.
# @type request: :class:`Tencentcloud::trocket::V20230308::CreateMQTTUserRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::CreateMQTTUserResponse`
def CreateMQTTUser(request)
body = send_request('CreateMQTTUser', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateMQTTUserResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 添加角色
# @param request: Request instance for CreateRole.
# @type request: :class:`Tencentcloud::trocket::V20230308::CreateRoleRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::CreateRoleResponse`
def CreateRole(request)
body = send_request('CreateRole', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateRoleResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 创建主题
# @param request: Request instance for CreateTopic.
# @type request: :class:`Tencentcloud::trocket::V20230308::CreateTopicRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::CreateTopicResponse`
def CreateTopic(request)
body = send_request('CreateTopic', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateTopicResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 删除消费组
# @param request: Request instance for DeleteConsumerGroup.
# @type request: :class:`Tencentcloud::trocket::V20230308::DeleteConsumerGroupRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DeleteConsumerGroupResponse`
def DeleteConsumerGroup(request)
body = send_request('DeleteConsumerGroup', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteConsumerGroupResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 删除实例
# @param request: Request instance for DeleteInstance.
# @type request: :class:`Tencentcloud::trocket::V20230308::DeleteInstanceRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DeleteInstanceResponse`
def DeleteInstance(request)
body = send_request('DeleteInstance', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteInstanceResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 删除MQTT实例的公网接入点
# @param request: Request instance for DeleteMQTTInsPublicEndpoint.
# @type request: :class:`Tencentcloud::trocket::V20230308::DeleteMQTTInsPublicEndpointRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DeleteMQTTInsPublicEndpointResponse`
def DeleteMQTTInsPublicEndpoint(request)
body = send_request('DeleteMQTTInsPublicEndpoint', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteMQTTInsPublicEndpointResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 删除MQTT实例
# @param request: Request instance for DeleteMQTTInstance.
# @type request: :class:`Tencentcloud::trocket::V20230308::DeleteMQTTInstanceRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DeleteMQTTInstanceResponse`
def DeleteMQTTInstance(request)
body = send_request('DeleteMQTTInstance', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteMQTTInstanceResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 删除MQTT主题
# @param request: Request instance for DeleteMQTTTopic.
# @type request: :class:`Tencentcloud::trocket::V20230308::DeleteMQTTTopicRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DeleteMQTTTopicResponse`
def DeleteMQTTTopic(request)
body = send_request('DeleteMQTTTopic', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteMQTTTopicResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 删除MQTT访问用户
# @param request: Request instance for DeleteMQTTUser.
# @type request: :class:`Tencentcloud::trocket::V20230308::DeleteMQTTUserRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DeleteMQTTUserResponse`
def DeleteMQTTUser(request)
body = send_request('DeleteMQTTUser', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteMQTTUserResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 删除角色
# @param request: Request instance for DeleteRole.
# @type request: :class:`Tencentcloud::trocket::V20230308::DeleteRoleRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DeleteRoleResponse`
def DeleteRole(request)
body = send_request('DeleteRole', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteRoleResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 删除主题
# @param request: Request instance for DeleteTopic.
# @type request: :class:`Tencentcloud::trocket::V20230308::DeleteTopicRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DeleteTopicResponse`
def DeleteTopic(request)
body = send_request('DeleteTopic', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteTopicResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询消费组详情
# @param request: Request instance for DescribeConsumerGroup.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeConsumerGroupRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeConsumerGroupResponse`
def DescribeConsumerGroup(request)
body = send_request('DescribeConsumerGroup', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeConsumerGroupResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 获取消费组列表,Filter参数使用说明如下:
# 1. ConsumerGroupName,名称模糊查询
# 2. ConsumeMessageOrderly,投递顺序性。"true":顺序投递;"false":并发投递
# @param request: Request instance for DescribeConsumerGroupList.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeConsumerGroupListRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeConsumerGroupListResponse`
def DescribeConsumerGroupList(request)
body = send_request('DescribeConsumerGroupList', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeConsumerGroupListResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询实例信息
# @param request: Request instance for DescribeInstance.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeInstanceRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeInstanceResponse`
def DescribeInstance(request)
body = send_request('DescribeInstance', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeInstanceResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 获取实例列表,Filters参数使用说明如下:
# 1. InstanceName, 名称模糊查询
# 2. InstanceId,实例ID查询
# 3. InstanceType, 实例类型查询,支持多选
# 3. InstanceStatus,实例状态查询,支持多选
# 当使用TagFilters查询时,Filters参数失效。
# @param request: Request instance for DescribeInstanceList.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeInstanceListRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeInstanceListResponse`
def DescribeInstanceList(request)
body = send_request('DescribeInstanceList', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeInstanceListResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询 MQTT 客户端详情
# @param request: Request instance for DescribeMQTTClient.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTClientRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTClientResponse`
def DescribeMQTTClient(request)
body = send_request('DescribeMQTTClient', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTClientResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询MQTT实例公网接入点
# @param request: Request instance for DescribeMQTTInsPublicEndpoints.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTInsPublicEndpointsRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTInsPublicEndpointsResponse`
def DescribeMQTTInsPublicEndpoints(request)
body = send_request('DescribeMQTTInsPublicEndpoints', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTInsPublicEndpointsResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询MQTT实例公网接入点
# @param request: Request instance for DescribeMQTTInsVPCEndpoints.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTInsVPCEndpointsRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTInsVPCEndpointsResponse`
def DescribeMQTTInsVPCEndpoints(request)
body = send_request('DescribeMQTTInsVPCEndpoints', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTInsVPCEndpointsResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询实例信息
# @param request: Request instance for DescribeMQTTInstance.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTInstanceRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTInstanceResponse`
def DescribeMQTTInstance(request)
body = send_request('DescribeMQTTInstance', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTInstanceResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询MQTT集群证书列表
# @param request: Request instance for DescribeMQTTInstanceCert.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTInstanceCertRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTInstanceCertResponse`
def DescribeMQTTInstanceCert(request)
body = send_request('DescribeMQTTInstanceCert', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTInstanceCertResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 获取实例列表,Filters参数使用说明如下:
# 1. InstanceName, 名称模糊查询
# 2. InstanceId,实例ID查询
# 3. InstanceType, 实例类型查询,支持多选
# 3. InstanceStatus,实例状态查询,支持多选
# 当使用TagFilters查询时,Filters参数失效。
# @param request: Request instance for DescribeMQTTInstanceList.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTInstanceListRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTInstanceListResponse`
def DescribeMQTTInstanceList(request)
body = send_request('DescribeMQTTInstanceList', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTInstanceListResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询MQTT消息详情
# @param request: Request instance for DescribeMQTTMessage.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTMessageRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTMessageResponse`
def DescribeMQTTMessage(request)
body = send_request('DescribeMQTTMessage', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTMessageResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询消息列表,如查询死信,请设置ConsumerGroup参数
# @param request: Request instance for DescribeMQTTMessageList.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTMessageListRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTMessageListResponse`
def DescribeMQTTMessageList(request)
body = send_request('DescribeMQTTMessageList', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTMessageListResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 获取产品售卖规格
# @param request: Request instance for DescribeMQTTProductSKUList.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTProductSKUListRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTProductSKUListResponse`
def DescribeMQTTProductSKUList(request)
body = send_request('DescribeMQTTProductSKUList', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTProductSKUListResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询mqtt主题详情
# @param request: Request instance for DescribeMQTTTopic.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTTopicRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTTopicResponse`
def DescribeMQTTTopic(request)
body = send_request('DescribeMQTTTopic', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTTopicResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 获取主题列表,Filter参数使用说明如下:
# 1. TopicName,主题名称模糊搜索
# 2. TopicType,主题类型查询,支持多选,可选值:Normal,Order,Transaction,DelayScheduled
# @param request: Request instance for DescribeMQTTTopicList.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTTopicListRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTTopicListResponse`
def DescribeMQTTTopicList(request)
body = send_request('DescribeMQTTTopicList', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTTopicListResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询用户列表,Filter参数使用说明如下:
# 1. Username,用户名称模糊搜索
# @param request: Request instance for DescribeMQTTUserList.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTUserListRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeMQTTUserListResponse`
def DescribeMQTTUserList(request)
body = send_request('DescribeMQTTUserList', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeMQTTUserListResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询角色列表,Filter参数使用说明如下:
# 1. RoleName,角色名称模糊搜索
# @param request: Request instance for DescribeRoleList.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeRoleListRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeRoleListResponse`
def DescribeRoleList(request)
body = send_request('DescribeRoleList', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeRoleListResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 查询主题详情,Offset和Limit参数是指订阅该主题的消费组查询分页参数,Filter参数使用说明如下:
# ConsumerGroup,消费组名称过滤
# @param request: Request instance for DescribeTopic.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeTopicRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeTopicResponse`
def DescribeTopic(request)
body = send_request('DescribeTopic', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeTopicResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 获取主题列表,Filter参数使用说明如下:
# 1. TopicName,主题名称模糊搜索
# 2. TopicType,主题类型查询,支持多选,可选值:Normal,Order,Transaction,DelayScheduled
# @param request: Request instance for DescribeTopicList.
# @type request: :class:`Tencentcloud::trocket::V20230308::DescribeTopicListRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::DescribeTopicListResponse`
def DescribeTopicList(request)
body = send_request('DescribeTopicList', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DescribeTopicListResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 导入消费者组列表
# @param request: Request instance for ImportSourceClusterConsumerGroups.
# @type request: :class:`Tencentcloud::trocket::V20230308::ImportSourceClusterConsumerGroupsRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ImportSourceClusterConsumerGroupsResponse`
def ImportSourceClusterConsumerGroups(request)
body = send_request('ImportSourceClusterConsumerGroups', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ImportSourceClusterConsumerGroupsResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 导入topic列表
# @param request: Request instance for ImportSourceClusterTopics.
# @type request: :class:`Tencentcloud::trocket::V20230308::ImportSourceClusterTopicsRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ImportSourceClusterTopicsResponse`
def ImportSourceClusterTopics(request)
body = send_request('ImportSourceClusterTopics', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ImportSourceClusterTopicsResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 修改消费组属性
# @param request: Request instance for ModifyConsumerGroup.
# @type request: :class:`Tencentcloud::trocket::V20230308::ModifyConsumerGroupRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ModifyConsumerGroupResponse`
def ModifyConsumerGroup(request)
body = send_request('ModifyConsumerGroup', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ModifyConsumerGroupResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 修改实例属性
# @param request: Request instance for ModifyInstance.
# @type request: :class:`Tencentcloud::trocket::V20230308::ModifyInstanceRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ModifyInstanceResponse`
def ModifyInstance(request)
body = send_request('ModifyInstance', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ModifyInstanceResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 更新MQTT实例公网接入点
# @param request: Request instance for ModifyMQTTInsPublicEndpoint.
# @type request: :class:`Tencentcloud::trocket::V20230308::ModifyMQTTInsPublicEndpointRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ModifyMQTTInsPublicEndpointResponse`
def ModifyMQTTInsPublicEndpoint(request)
body = send_request('ModifyMQTTInsPublicEndpoint', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ModifyMQTTInsPublicEndpointResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 修改实例属性
# @param request: Request instance for ModifyMQTTInstance.
# @type request: :class:`Tencentcloud::trocket::V20230308::ModifyMQTTInstanceRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ModifyMQTTInstanceResponse`
def ModifyMQTTInstance(request)
body = send_request('ModifyMQTTInstance', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ModifyMQTTInstanceResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 更新MQTT集群绑定证书
# 参数传空,则为删除证书
# @param request: Request instance for ModifyMQTTInstanceCertBinding.
# @type request: :class:`Tencentcloud::trocket::V20230308::ModifyMQTTInstanceCertBindingRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ModifyMQTTInstanceCertBindingResponse`
def ModifyMQTTInstanceCertBinding(request)
body = send_request('ModifyMQTTInstanceCertBinding', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ModifyMQTTInstanceCertBindingResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 修改主题属性
# @param request: Request instance for ModifyMQTTTopic.
# @type request: :class:`Tencentcloud::trocket::V20230308::ModifyMQTTTopicRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ModifyMQTTTopicResponse`
def ModifyMQTTTopic(request)
body = send_request('ModifyMQTTTopic', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ModifyMQTTTopicResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 修改MQTT角色
# @param request: Request instance for ModifyMQTTUser.
# @type request: :class:`Tencentcloud::trocket::V20230308::ModifyMQTTUserRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ModifyMQTTUserResponse`
def ModifyMQTTUser(request)
body = send_request('ModifyMQTTUser', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ModifyMQTTUserResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 修改角色
# @param request: Request instance for ModifyRole.
# @type request: :class:`Tencentcloud::trocket::V20230308::ModifyRoleRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ModifyRoleResponse`
def ModifyRole(request)
body = send_request('ModifyRole', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ModifyRoleResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
# 修改主题属性
# @param request: Request instance for ModifyTopic.
# @type request: :class:`Tencentcloud::trocket::V20230308::ModifyTopicRequest`
# @rtype: :class:`Tencentcloud::trocket::V20230308::ModifyTopicResponse`
def ModifyTopic(request)
body = send_request('ModifyTopic', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ModifyTopicResponse.new
model.deserialize(response['Response'])
model
else
code = response['Response']['Error']['Code']
message = response['Response']['Error']['Message']
reqid = response['Response']['RequestId']
raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
end
rescue TencentCloud::Common::TencentCloudSDKException => e
raise e
rescue StandardError => e
raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
end
end
end
end
end
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。