# 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 Emr module V20190103 class Client < TencentCloud::Common::AbstractClient def initialize(credential, region, profile = nil) api_version = '2019-01-03' api_endpoint = 'emr.tencentcloudapi.com' sdk_version = 'EMR_' + File.read(File.expand_path('../VERSION', __dir__)).strip super(credential, region, api_version, api_endpoint, sdk_version, profile) end # 添加扩缩容规则,按负载和时间 # @param request: Request instance for AddMetricScaleStrategy. # @type request: :class:`Tencentcloud::emr::V20190103::AddMetricScaleStrategyRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::AddMetricScaleStrategyResponse` def AddMetricScaleStrategy(request) body = send_request('AddMetricScaleStrategy', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = AddMetricScaleStrategyResponse.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 # 该接口支持安装了OpenLdap组件的集群。 # 新增用户列表(用户管理)。 # @param request: Request instance for AddUsersForUserManager. # @type request: :class:`Tencentcloud::emr::V20190103::AddUsersForUserManagerRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::AddUsersForUserManagerResponse` def AddUsersForUserManager(request) body = send_request('AddUsersForUserManager', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = AddUsersForUserManagerResponse.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 # 创建EMR集群实例 # @param request: Request instance for CreateCluster. # @type request: :class:`Tencentcloud::emr::V20190103::CreateClusterRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::CreateClusterResponse` def CreateCluster(request) body = send_request('CreateCluster', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = CreateClusterResponse.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 # 创建EMR集群实例 # @param request: Request instance for CreateInstance. # @type request: :class:`Tencentcloud::emr::V20190103::CreateInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::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 # 本接口(CreateSLInstance)用于创建 Lite HBase 实例 # - 接口调用成功,会创建Lite HBase实例,创建实例请求成功会返回创建实例的 InstaceId 和请求的 RequestID。 # - 接口为异步接口,接口返回时操作并未立即完成,实例操作结果可以通过调用 DescribeInstancesList 查看当前实例的 StatusDesc 状态。 # @param request: Request instance for CreateSLInstance. # @type request: :class:`Tencentcloud::emr::V20190103::CreateSLInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::CreateSLInstanceResponse` def CreateSLInstance(request) body = send_request('CreateSLInstance', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = CreateSLInstanceResponse.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 DeleteAutoScaleStrategy. # @type request: :class:`Tencentcloud::emr::V20190103::DeleteAutoScaleStrategyRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DeleteAutoScaleStrategyResponse` def DeleteAutoScaleStrategy(request) body = send_request('DeleteAutoScaleStrategy', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DeleteAutoScaleStrategyResponse.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 DeleteUserManagerUserList. # @type request: :class:`Tencentcloud::emr::V20190103::DeleteUserManagerUserListRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DeleteUserManagerUserListResponse` def DeleteUserManagerUserList(request) body = send_request('DeleteUserManagerUserList', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DeleteUserManagerUserListResponse.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 # yarn资源调度-部署生效 # @param request: Request instance for DeployYarnConf. # @type request: :class:`Tencentcloud::emr::V20190103::DeployYarnConfRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DeployYarnConfResponse` def DeployYarnConf(request) body = send_request('DeployYarnConf', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DeployYarnConfResponse.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 DescribeAutoScaleGroupGlobalConf. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeAutoScaleGroupGlobalConfRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeAutoScaleGroupGlobalConfResponse` def DescribeAutoScaleGroupGlobalConf(request) body = send_request('DescribeAutoScaleGroupGlobalConf', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeAutoScaleGroupGlobalConfResponse.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 DescribeAutoScaleRecords. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeAutoScaleRecordsRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeAutoScaleRecordsResponse` def DescribeAutoScaleRecords(request) body = send_request('DescribeAutoScaleRecords', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeAutoScaleRecordsResponse.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 DescribeAutoScaleStrategies. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeAutoScaleStrategiesRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeAutoScaleStrategiesResponse` def DescribeAutoScaleStrategies(request) body = send_request('DescribeAutoScaleStrategies', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeAutoScaleStrategiesResponse.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 # 查询EMR任务运行详情状态 # @param request: Request instance for DescribeClusterFlowStatusDetail. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeClusterFlowStatusDetailRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeClusterFlowStatusDetailResponse` def DescribeClusterFlowStatusDetail(request) body = send_request('DescribeClusterFlowStatusDetail', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeClusterFlowStatusDetailResponse.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 DescribeClusterNodes. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeClusterNodesRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeClusterNodesResponse` def DescribeClusterNodes(request) body = send_request('DescribeClusterNodes', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeClusterNodesResponse.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 # 获取账户的CVM配额 # @param request: Request instance for DescribeCvmQuota. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeCvmQuotaRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeCvmQuotaResponse` def DescribeCvmQuota(request) body = send_request('DescribeCvmQuota', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeCvmQuotaResponse.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 # yarn application 统计接口查询 # @param request: Request instance for DescribeEmrApplicationStatics. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeEmrApplicationStaticsRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeEmrApplicationStaticsResponse` def DescribeEmrApplicationStatics(request) body = send_request('DescribeEmrApplicationStatics', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeEmrApplicationStaticsResponse.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 DescribeEmrOverviewMetrics. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeEmrOverviewMetricsRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeEmrOverviewMetricsResponse` def DescribeEmrOverviewMetrics(request) body = send_request('DescribeEmrOverviewMetrics', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeEmrOverviewMetricsResponse.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 # 查询YARN资源调度的全局配置 # @param request: Request instance for DescribeGlobalConfig. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeGlobalConfigRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeGlobalConfigResponse` def DescribeGlobalConfig(request) body = send_request('DescribeGlobalConfig', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeGlobalConfigResponse.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 # 获取Hbase表级监控数据概览接口 # @param request: Request instance for DescribeHBaseTableOverview. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeHBaseTableOverviewRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeHBaseTableOverviewResponse` def DescribeHBaseTableOverview(request) body = send_request('DescribeHBaseTableOverview', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeHBaseTableOverviewResponse.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 # 获取hive查询信息 # @param request: Request instance for DescribeHiveQueries. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeHiveQueriesRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeHiveQueriesResponse` def DescribeHiveQueries(request) body = send_request('DescribeHiveQueries', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeHiveQueriesResponse.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 # DescribeImpalaQueries # @param request: Request instance for DescribeImpalaQueries. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeImpalaQueriesRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeImpalaQueriesResponse` def DescribeImpalaQueries(request) body = send_request('DescribeImpalaQueries', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeImpalaQueriesResponse.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 DescribeInsightList. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeInsightListRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeInsightListResponse` def DescribeInsightList(request) body = send_request('DescribeInsightList', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeInsightListResponse.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 DescribeInstanceRenewNodes. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeInstanceRenewNodesRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeInstanceRenewNodesResponse` def DescribeInstanceRenewNodes(request) body = send_request('DescribeInstanceRenewNodes', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeInstanceRenewNodesResponse.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 DescribeInstances. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeInstancesRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeInstancesResponse` def DescribeInstances(request) body = send_request('DescribeInstances', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeInstancesResponse.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 DescribeInstancesList. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeInstancesListRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeInstancesListResponse` def DescribeInstancesList(request) body = send_request('DescribeInstancesList', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeInstancesListResponse.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 DescribeJobFlow. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeJobFlowRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeJobFlowResponse` def DescribeJobFlow(request) body = send_request('DescribeJobFlow', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeJobFlowResponse.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 # 查询YARN资源调度数据信息。已废弃,请使用`DescribeYarnQueue`去查询队列信息。 # @param request: Request instance for DescribeResourceSchedule. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeResourceScheduleRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeResourceScheduleResponse` def DescribeResourceSchedule(request) body = send_request('DescribeResourceSchedule', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeResourceScheduleResponse.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 # YARN资源调度-变更详情 # @param request: Request instance for DescribeResourceScheduleDiffDetail. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeResourceScheduleDiffDetailRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeResourceScheduleDiffDetailResponse` def DescribeResourceScheduleDiffDetail(request) body = send_request('DescribeResourceScheduleDiffDetail', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeResourceScheduleDiffDetailResponse.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 # 本接口(DescribeSLInstance)用于查询 Lite HBase 实例基本信息 # @param request: Request instance for DescribeSLInstance. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeSLInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeSLInstanceResponse` def DescribeSLInstance(request) body = send_request('DescribeSLInstance', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeSLInstanceResponse.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 # 本接口(DescribeSLInstanceList)用于查询 Lite HBase 实例列表详细信息 # @param request: Request instance for DescribeSLInstanceList. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeSLInstanceListRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeSLInstanceListResponse` def DescribeSLInstanceList(request) body = send_request('DescribeSLInstanceList', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeSLInstanceListResponse.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 DescribeServiceNodeInfos. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeServiceNodeInfosRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeServiceNodeInfosResponse` def DescribeServiceNodeInfos(request) body = send_request('DescribeServiceNodeInfos', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeServiceNodeInfosResponse.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 # 获取trino查询结果 # @param request: Request instance for DescribeTrinoQueryInfo. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeTrinoQueryInfoRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeTrinoQueryInfoResponse` def DescribeTrinoQueryInfo(request) body = send_request('DescribeTrinoQueryInfo', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeTrinoQueryInfoResponse.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 # 该接口支持安装了OpenLdap组件的集群。 # 批量导出用户。对于kerberos集群,如果需要kertab文件下载地址,可以将NeedKeytabInfo设置为true;注意SupportDownLoadKeyTab为true,但是DownLoadKeyTabUrl为空字符串,表示keytab文件在后台没有准备好(正在生成)。 # @param request: Request instance for DescribeUsersForUserManager. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeUsersForUserManagerRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeUsersForUserManagerResponse` def DescribeUsersForUserManager(request) body = send_request('DescribeUsersForUserManager', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeUsersForUserManagerResponse.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 # DescribeYarnApplications # @param request: Request instance for DescribeYarnApplications. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeYarnApplicationsRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeYarnApplicationsResponse` def DescribeYarnApplications(request) body = send_request('DescribeYarnApplications', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeYarnApplicationsResponse.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 DescribeYarnQueue. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeYarnQueueRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeYarnQueueResponse` def DescribeYarnQueue(request) body = send_request('DescribeYarnQueue', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeYarnQueueResponse.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 # 查看yarn资源调度的调度历史。废弃,请使用流程中心查看历史记录。 # @param request: Request instance for DescribeYarnScheduleHistory. # @type request: :class:`Tencentcloud::emr::V20190103::DescribeYarnScheduleHistoryRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::DescribeYarnScheduleHistoryResponse` def DescribeYarnScheduleHistory(request) body = send_request('DescribeYarnScheduleHistory', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = DescribeYarnScheduleHistoryResponse.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 InquirePriceRenewEmr. # @type request: :class:`Tencentcloud::emr::V20190103::InquirePriceRenewEmrRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::InquirePriceRenewEmrResponse` def InquirePriceRenewEmr(request) body = send_request('InquirePriceRenewEmr', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = InquirePriceRenewEmrResponse.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 InquiryPriceCreateInstance. # @type request: :class:`Tencentcloud::emr::V20190103::InquiryPriceCreateInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::InquiryPriceCreateInstanceResponse` def InquiryPriceCreateInstance(request) body = send_request('InquiryPriceCreateInstance', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = InquiryPriceCreateInstanceResponse.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 InquiryPriceRenewInstance. # @type request: :class:`Tencentcloud::emr::V20190103::InquiryPriceRenewInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::InquiryPriceRenewInstanceResponse` def InquiryPriceRenewInstance(request) body = send_request('InquiryPriceRenewInstance', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = InquiryPriceRenewInstanceResponse.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 InquiryPriceScaleOutInstance. # @type request: :class:`Tencentcloud::emr::V20190103::InquiryPriceScaleOutInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::InquiryPriceScaleOutInstanceResponse` def InquiryPriceScaleOutInstance(request) body = send_request('InquiryPriceScaleOutInstance', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = InquiryPriceScaleOutInstanceResponse.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 InquiryPriceUpdateInstance. # @type request: :class:`Tencentcloud::emr::V20190103::InquiryPriceUpdateInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::InquiryPriceUpdateInstanceResponse` def InquiryPriceUpdateInstance(request) body = send_request('InquiryPriceUpdateInstance', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = InquiryPriceUpdateInstanceResponse.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 ModifyAutoRenewFlag. # @type request: :class:`Tencentcloud::emr::V20190103::ModifyAutoRenewFlagRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifyAutoRenewFlagResponse` def ModifyAutoRenewFlag(request) body = send_request('ModifyAutoRenewFlag', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifyAutoRenewFlagResponse.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 ModifyAutoScaleStrategy. # @type request: :class:`Tencentcloud::emr::V20190103::ModifyAutoScaleStrategyRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifyAutoScaleStrategyResponse` def ModifyAutoScaleStrategy(request) body = send_request('ModifyAutoScaleStrategy', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifyAutoScaleStrategyResponse.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 # 修改YARN资源调度的全局配置 # @param request: Request instance for ModifyGlobalConfig. # @type request: :class:`Tencentcloud::emr::V20190103::ModifyGlobalConfigRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifyGlobalConfigResponse` def ModifyGlobalConfig(request) body = send_request('ModifyGlobalConfig', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifyGlobalConfigResponse.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 # 刷新YARN的动态资源池。已废弃,请使用`DeployYarnConf` # @param request: Request instance for ModifyResourcePools. # @type request: :class:`Tencentcloud::emr::V20190103::ModifyResourcePoolsRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifyResourcePoolsResponse` def ModifyResourcePools(request) body = send_request('ModifyResourcePools', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifyResourcePoolsResponse.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 # 修改YARN资源调度的资源配置。已废弃,请使用`ModifyYarnQueueV2`来修改队列配置 # @param request: Request instance for ModifyResourceScheduleConfig. # @type request: :class:`Tencentcloud::emr::V20190103::ModifyResourceScheduleConfigRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifyResourceScheduleConfigResponse` def ModifyResourceScheduleConfig(request) body = send_request('ModifyResourceScheduleConfig', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifyResourceScheduleConfigResponse.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 # 修改了yarn的资源调度器,点击部署生效。 # @param request: Request instance for ModifyResourceScheduler. # @type request: :class:`Tencentcloud::emr::V20190103::ModifyResourceSchedulerRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifyResourceSchedulerResponse` def ModifyResourceScheduler(request) body = send_request('ModifyResourceScheduler', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifyResourceSchedulerResponse.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 ModifyResourcesTags. # @type request: :class:`Tencentcloud::emr::V20190103::ModifyResourcesTagsRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifyResourcesTagsResponse` def ModifyResourcesTags(request) body = send_request('ModifyResourcesTags', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifyResourcesTagsResponse.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 # 本接口(ModifySLInstance)用于修改Lite HBase 实例节点数。 # - 接口调用成功,会创建Lite HBase实例,创建实例请求成功会返回请求的 RequestID。 # - 接口为异步接口,接口返回时操作并未立即完成,实例操作结果可以通过调用 DescribeInstancesList 查看当前实例的 StatusDesc 状态。 # @param request: Request instance for ModifySLInstance. # @type request: :class:`Tencentcloud::emr::V20190103::ModifySLInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifySLInstanceResponse` def ModifySLInstance(request) body = send_request('ModifySLInstance', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifySLInstanceResponse.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 ModifyUserManagerPwd. # @type request: :class:`Tencentcloud::emr::V20190103::ModifyUserManagerPwdRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifyUserManagerPwdResponse` def ModifyUserManagerPwd(request) body = send_request('ModifyUserManagerPwd', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifyUserManagerPwdResponse.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 # 部署生效。已废弃,请使用`DeployYarnConf`接口进行部署生效 # @param request: Request instance for ModifyYarnDeploy. # @type request: :class:`Tencentcloud::emr::V20190103::ModifyYarnDeployRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifyYarnDeployResponse` def ModifyYarnDeploy(request) body = send_request('ModifyYarnDeploy', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifyYarnDeployResponse.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 ModifyYarnQueueV2. # @type request: :class:`Tencentcloud::emr::V20190103::ModifyYarnQueueV2Request` # @rtype: :class:`Tencentcloud::emr::V20190103::ModifyYarnQueueV2Response` def ModifyYarnQueueV2(request) body = send_request('ModifyYarnQueueV2', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ModifyYarnQueueV2Response.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 # 修改YARN资源调度的资源配置 # @param request: Request instance for ResetYarnConfig. # @type request: :class:`Tencentcloud::emr::V20190103::ResetYarnConfigRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ResetYarnConfigResponse` def ResetYarnConfig(request) body = send_request('ResetYarnConfig', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ResetYarnConfigResponse.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 RunJobFlow. # @type request: :class:`Tencentcloud::emr::V20190103::RunJobFlowRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::RunJobFlowResponse` def RunJobFlow(request) body = send_request('RunJobFlow', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = RunJobFlowResponse.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 ScaleOutCluster. # @type request: :class:`Tencentcloud::emr::V20190103::ScaleOutClusterRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ScaleOutClusterResponse` def ScaleOutCluster(request) body = send_request('ScaleOutCluster', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ScaleOutClusterResponse.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 ScaleOutInstance. # @type request: :class:`Tencentcloud::emr::V20190103::ScaleOutInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::ScaleOutInstanceResponse` def ScaleOutInstance(request) body = send_request('ScaleOutInstance', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = ScaleOutInstanceResponse.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 StartStopServiceOrMonitor. # @type request: :class:`Tencentcloud::emr::V20190103::StartStopServiceOrMonitorRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::StartStopServiceOrMonitorResponse` def StartStopServiceOrMonitor(request) body = send_request('StartStopServiceOrMonitor', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = StartStopServiceOrMonitorResponse.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 # EMR同步TKE中POD状态 # @param request: Request instance for SyncPodState. # @type request: :class:`Tencentcloud::emr::V20190103::SyncPodStateRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::SyncPodStateResponse` def SyncPodState(request) body = send_request('SyncPodState', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = SyncPodStateResponse.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 TerminateClusterNodes. # @type request: :class:`Tencentcloud::emr::V20190103::TerminateClusterNodesRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::TerminateClusterNodesResponse` def TerminateClusterNodes(request) body = send_request('TerminateClusterNodes', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = TerminateClusterNodesResponse.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 # 销毁EMR实例。此接口仅支持弹性MapReduce正式计费版本。 # @param request: Request instance for TerminateInstance. # @type request: :class:`Tencentcloud::emr::V20190103::TerminateInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::TerminateInstanceResponse` def TerminateInstance(request) body = send_request('TerminateInstance', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = TerminateInstanceResponse.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 # 本接口(TerminateSLInstance)用于销毁 Lite HBase 实例 # @param request: Request instance for TerminateSLInstance. # @type request: :class:`Tencentcloud::emr::V20190103::TerminateSLInstanceRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::TerminateSLInstanceResponse` def TerminateSLInstance(request) body = send_request('TerminateSLInstance', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = TerminateSLInstanceResponse.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 # 缩容Task节点 # @param request: Request instance for TerminateTasks. # @type request: :class:`Tencentcloud::emr::V20190103::TerminateTasksRequest` # @rtype: :class:`Tencentcloud::emr::V20190103::TerminateTasksResponse` def TerminateTasks(request) body = send_request('TerminateTasks', request.serialize) response = JSON.parse(body) if response['Response'].key?('Error') == false model = TerminateTasksResponse.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