# -*- coding: utf8 -*-
# Copyright (c) 2017-2021 THL A29 Limited, a Tencent company. All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
import warnings
from tencentcloud.common.abstract_model import AbstractModel
class AddUsersForUserManagerRequest(AbstractModel):
"""AddUsersForUserManager请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 集群字符串ID
:type InstanceId: str
:param UserManagerUserList: 用户信息列表
:type UserManagerUserList: list of UserInfoForUserManager
"""
self.InstanceId = None
self.UserManagerUserList = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
if params.get("UserManagerUserList") is not None:
self.UserManagerUserList = []
for item in params.get("UserManagerUserList"):
obj = UserInfoForUserManager()
obj._deserialize(item)
self.UserManagerUserList.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class AddUsersForUserManagerResponse(AbstractModel):
"""AddUsersForUserManager返回参数结构体
"""
def __init__(self):
r"""
:param SuccessUserList: 添加成功的用户列表
注意：此字段可能返回 null，表示取不到有效值。
:type SuccessUserList: list of str
:param FailedUserList: 添加失败的用户列表
注意：此字段可能返回 null，表示取不到有效值。
:type FailedUserList: list of str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.SuccessUserList = None
self.FailedUserList = None
self.RequestId = None
def _deserialize(self, params):
self.SuccessUserList = params.get("SuccessUserList")
self.FailedUserList = params.get("FailedUserList")
self.RequestId = params.get("RequestId")
class AllNodeResourceSpec(AbstractModel):
"""资源描述
"""
def __init__(self):
r"""
:param MasterResourceSpec: 描述Master节点资源
注意：此字段可能返回 null，表示取不到有效值。
:type MasterResourceSpec: :class:`tencentcloud.emr.v20190103.models.NodeResourceSpec`
:param CoreResourceSpec: 描述Core节点资源
注意：此字段可能返回 null，表示取不到有效值。
:type CoreResourceSpec: :class:`tencentcloud.emr.v20190103.models.NodeResourceSpec`
:param TaskResourceSpec: 描述Taskr节点资源
注意：此字段可能返回 null，表示取不到有效值。
:type TaskResourceSpec: :class:`tencentcloud.emr.v20190103.models.NodeResourceSpec`
:param CommonResourceSpec: 描述Common节点资源
注意：此字段可能返回 null，表示取不到有效值。
:type CommonResourceSpec: :class:`tencentcloud.emr.v20190103.models.NodeResourceSpec`
:param MasterCount: Master节点数量
注意：此字段可能返回 null，表示取不到有效值。
:type MasterCount: int
:param CoreCount: Corer节点数量
注意：此字段可能返回 null，表示取不到有效值。
:type CoreCount: int
:param TaskCount: Task节点数量
注意：此字段可能返回 null，表示取不到有效值。
:type TaskCount: int
:param CommonCount: Common节点数量
注意：此字段可能返回 null，表示取不到有效值。
:type CommonCount: int
"""
self.MasterResourceSpec = None
self.CoreResourceSpec = None
self.TaskResourceSpec = None
self.CommonResourceSpec = None
self.MasterCount = None
self.CoreCount = None
self.TaskCount = None
self.CommonCount = None
def _deserialize(self, params):
if params.get("MasterResourceSpec") is not None:
self.MasterResourceSpec = NodeResourceSpec()
self.MasterResourceSpec._deserialize(params.get("MasterResourceSpec"))
if params.get("CoreResourceSpec") is not None:
self.CoreResourceSpec = NodeResourceSpec()
self.CoreResourceSpec._deserialize(params.get("CoreResourceSpec"))
if params.get("TaskResourceSpec") is not None:
self.TaskResourceSpec = NodeResourceSpec()
self.TaskResourceSpec._deserialize(params.get("TaskResourceSpec"))
if params.get("CommonResourceSpec") is not None:
self.CommonResourceSpec = NodeResourceSpec()
self.CommonResourceSpec._deserialize(params.get("CommonResourceSpec"))
self.MasterCount = params.get("MasterCount")
self.CoreCount = params.get("CoreCount")
self.TaskCount = params.get("TaskCount")
self.CommonCount = params.get("CommonCount")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ApplicationStatics(AbstractModel):
"""yarn application 统计信息
"""
def __init__(self):
r"""
:param Queue: 队列名
:type Queue: str
:param User: 用户名
:type User: str
:param ApplicationType: 作业类型
:type ApplicationType: str
:param SumMemorySeconds: SumMemorySeconds含义
:type SumMemorySeconds: int
:param SumVCoreSeconds: SumVCoreSeconds含义
:type SumVCoreSeconds: int
:param SumHDFSBytesWritten: SumHDFSBytesWritten（带单位）
:type SumHDFSBytesWritten: str
:param SumHDFSBytesRead: SumHDFSBytesRead（待单位）
:type SumHDFSBytesRead: str
:param CountApps: 作业数
:type CountApps: int
"""
self.Queue = None
self.User = None
self.ApplicationType = None
self.SumMemorySeconds = None
self.SumVCoreSeconds = None
self.SumHDFSBytesWritten = None
self.SumHDFSBytesRead = None
self.CountApps = None
def _deserialize(self, params):
self.Queue = params.get("Queue")
self.User = params.get("User")
self.ApplicationType = params.get("ApplicationType")
self.SumMemorySeconds = params.get("SumMemorySeconds")
self.SumVCoreSeconds = params.get("SumVCoreSeconds")
self.SumHDFSBytesWritten = params.get("SumHDFSBytesWritten")
self.SumHDFSBytesRead = params.get("SumHDFSBytesRead")
self.CountApps = params.get("CountApps")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class BootstrapAction(AbstractModel):
"""引导脚本
"""
def __init__(self):
r"""
:param Path: 脚本位置，支持cos上的文件，且只支持https协议。
:type Path: str
:param WhenRun: 执行时间。
resourceAfter 表示在机器资源申请成功后执行。
clusterBefore 表示在集群初始化前执行。
clusterAfter 表示在集群初始化后执行。
:type WhenRun: str
:param Args: 脚本参数
:type Args: list of str
"""
self.Path = None
self.WhenRun = None
self.Args = None
def _deserialize(self, params):
self.Path = params.get("Path")
self.WhenRun = params.get("WhenRun")
self.Args = params.get("Args")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class COSSettings(AbstractModel):
"""COS 相关配置
"""
def __init__(self):
r"""
:param CosSecretId: COS SecretId
:type CosSecretId: str
:param CosSecretKey: COS SecrectKey
:type CosSecretKey: str
:param LogOnCosPath: 日志存储在COS上的路径
:type LogOnCosPath: str
"""
self.CosSecretId = None
self.CosSecretKey = None
self.LogOnCosPath = None
def _deserialize(self, params):
self.CosSecretId = params.get("CosSecretId")
self.CosSecretKey = params.get("CosSecretKey")
self.LogOnCosPath = params.get("LogOnCosPath")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class CdbInfo(AbstractModel):
"""出参
"""
def __init__(self):
r"""
:param InstanceName: 数据库实例
注意：此字段可能返回 null，表示取不到有效值。
:type InstanceName: str
:param Ip: 数据库IP
注意：此字段可能返回 null，表示取不到有效值。
:type Ip: str
:param Port: 数据库端口
注意：此字段可能返回 null，表示取不到有效值。
:type Port: int
:param MemSize: 数据库内存规格
注意：此字段可能返回 null，表示取不到有效值。
:type MemSize: int
:param Volume: 数据库磁盘规格
注意：此字段可能返回 null，表示取不到有效值。
:type Volume: int
:param Service: 服务标识
注意：此字段可能返回 null，表示取不到有效值。
:type Service: str
:param ExpireTime: 过期时间
注意：此字段可能返回 null，表示取不到有效值。
:type ExpireTime: str
:param ApplyTime: 申请时间
注意：此字段可能返回 null，表示取不到有效值。
:type ApplyTime: str
:param PayType: 付费类型
注意：此字段可能返回 null，表示取不到有效值。
:type PayType: int
:param ExpireFlag: 过期标识
注意：此字段可能返回 null，表示取不到有效值。
:type ExpireFlag: bool
:param Status: 数据库状态
注意：此字段可能返回 null，表示取不到有效值。
:type Status: int
:param IsAutoRenew: 续费标识
注意：此字段可能返回 null，表示取不到有效值。
:type IsAutoRenew: int
:param SerialNo: 数据库字符串
注意：此字段可能返回 null，表示取不到有效值。
:type SerialNo: str
:param ZoneId: ZoneId
注意：此字段可能返回 null，表示取不到有效值。
:type ZoneId: int
:param RegionId: RegionId
注意：此字段可能返回 null，表示取不到有效值。
:type RegionId: int
"""
self.InstanceName = None
self.Ip = None
self.Port = None
self.MemSize = None
self.Volume = None
self.Service = None
self.ExpireTime = None
self.ApplyTime = None
self.PayType = None
self.ExpireFlag = None
self.Status = None
self.IsAutoRenew = None
self.SerialNo = None
self.ZoneId = None
self.RegionId = None
def _deserialize(self, params):
self.InstanceName = params.get("InstanceName")
self.Ip = params.get("Ip")
self.Port = params.get("Port")
self.MemSize = params.get("MemSize")
self.Volume = params.get("Volume")
self.Service = params.get("Service")
self.ExpireTime = params.get("ExpireTime")
self.ApplyTime = params.get("ApplyTime")
self.PayType = params.get("PayType")
self.ExpireFlag = params.get("ExpireFlag")
self.Status = params.get("Status")
self.IsAutoRenew = params.get("IsAutoRenew")
self.SerialNo = params.get("SerialNo")
self.ZoneId = params.get("ZoneId")
self.RegionId = params.get("RegionId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ClusterExternalServiceInfo(AbstractModel):
"""当前集群共用组件与集群对应关系
"""
def __init__(self):
r"""
:param DependType: 依赖关系，0:被其他集群依赖，1:依赖其他集群
注意：此字段可能返回 null，表示取不到有效值。
:type DependType: int
:param Service: 共用组件
注意：此字段可能返回 null，表示取不到有效值。
:type Service: str
:param ClusterId: 共用集群
注意：此字段可能返回 null，表示取不到有效值。
:type ClusterId: str
:param ClusterStatus: 共用集群状态
注意：此字段可能返回 null，表示取不到有效值。
:type ClusterStatus: int
"""
self.DependType = None
self.Service = None
self.ClusterId = None
self.ClusterStatus = None
def _deserialize(self, params):
self.DependType = params.get("DependType")
self.Service = params.get("Service")
self.ClusterId = params.get("ClusterId")
self.ClusterStatus = params.get("ClusterStatus")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ClusterInstancesInfo(AbstractModel):
"""集群实例信息
"""
def __init__(self):
r"""
:param Id: ID号
注意：此字段可能返回 null，表示取不到有效值。
:type Id: int
:param ClusterId: 集群ID
注意：此字段可能返回 null，表示取不到有效值。
:type ClusterId: str
:param Ftitle: 标题
注意：此字段可能返回 null，表示取不到有效值。
:type Ftitle: str
:param ClusterName: 集群名
注意：此字段可能返回 null，表示取不到有效值。
:type ClusterName: str
:param RegionId: 地域ID
注意：此字段可能返回 null，表示取不到有效值。
:type RegionId: int
:param ZoneId: 地区ID
注意：此字段可能返回 null，表示取不到有效值。
:type ZoneId: int
:param AppId: 用户APPID
注意：此字段可能返回 null，表示取不到有效值。
:type AppId: int
:param Uin: 用户UIN
注意：此字段可能返回 null，表示取不到有效值。
:type Uin: str
:param ProjectId: 项目Id
注意：此字段可能返回 null，表示取不到有效值。
:type ProjectId: int
:param VpcId: 集群VPCID
注意：此字段可能返回 null，表示取不到有效值。
:type VpcId: int
:param SubnetId: 子网ID
注意：此字段可能返回 null，表示取不到有效值。
:type SubnetId: int
:param Status: 实例的状态码。取值范围：
2：表示集群运行中。
3：表示集群创建中。
4：表示集群扩容中。
5：表示集群增加router节点中。
6：表示集群安装组件中。
7：表示集群执行命令中。
8：表示重启服务中。
9：表示进入维护中。
10：表示服务暂停中。
11：表示退出维护中。
12：表示退出暂停中。
13：表示配置下发中。
14：表示销毁集群中。
15：表示销毁core节点中。
16：销毁task节点中。
17：表示销毁router节点中。
18：表示更改webproxy密码中。
19：表示集群隔离中。
20：表示集群冲正中。
21：表示集群回收中。
22：表示变配等待中。
23：表示集群已隔离。
24：表示缩容节点中。
33：表示集群等待退费中。
34：表示集群已退费。
301：表示创建失败。
302：表示扩容失败。
注意：此字段可能返回 null，表示取不到有效值。
:type Status: int
:param AddTime: 添加时间
注意：此字段可能返回 null，表示取不到有效值。
:type AddTime: str
:param RunTime: 已经运行时间
注意：此字段可能返回 null，表示取不到有效值。
:type RunTime: str
:param Config: 集群产品配置信息
注意：此字段可能返回 null，表示取不到有效值。
:type Config: :class:`tencentcloud.emr.v20190103.models.EmrProductConfigOutter`
:param MasterIp: 主节点外网IP
注意：此字段可能返回 null，表示取不到有效值。
:type MasterIp: str
:param EmrVersion: EMR版本
注意：此字段可能返回 null，表示取不到有效值。
:type EmrVersion: str
:param ChargeType: 收费类型
注意：此字段可能返回 null，表示取不到有效值。
:type ChargeType: int
:param TradeVersion: 交易版本
注意：此字段可能返回 null，表示取不到有效值。
:type TradeVersion: int
:param ResourceOrderId: 资源订单ID
注意：此字段可能返回 null，表示取不到有效值。
:type ResourceOrderId: int
:param IsTradeCluster: 是否计费集群
注意：此字段可能返回 null，表示取不到有效值。
:type IsTradeCluster: int
:param AlarmInfo: 集群错误状态告警信息
注意：此字段可能返回 null，表示取不到有效值。
:type AlarmInfo: str
:param IsWoodpeckerCluster: 是否采用新架构
注意：此字段可能返回 null，表示取不到有效值。
:type IsWoodpeckerCluster: int
:param MetaDb: 元数据库信息
注意：此字段可能返回 null，表示取不到有效值。
:type MetaDb: str
:param Tags: 标签信息
注意：此字段可能返回 null，表示取不到有效值。
:type Tags: list of Tag
:param HiveMetaDb: Hive元数据信息
注意：此字段可能返回 null，表示取不到有效值。
:type HiveMetaDb: str
:param ServiceClass: 集群类型:EMR,CLICKHOUSE,DRUID
注意：此字段可能返回 null，表示取不到有效值。
:type ServiceClass: str
:param AliasInfo: 集群所有节点的别名序列化
注意：此字段可能返回 null，表示取不到有效值。
:type AliasInfo: str
:param ProductId: 集群版本Id
注意：此字段可能返回 null，表示取不到有效值。
:type ProductId: int
:param Zone: 地区ID
注意：此字段可能返回 null，表示取不到有效值。
:type Zone: str
:param SceneName: 场景名称
注意：此字段可能返回 null，表示取不到有效值。
:type SceneName: str
:param SceneServiceClass: 场景化集群类型
注意：此字段可能返回 null，表示取不到有效值。
:type SceneServiceClass: str
:param SceneEmrVersion: 场景化EMR版本
注意：此字段可能返回 null，表示取不到有效值。
:type SceneEmrVersion: str
:param DisplayName: 场景化集群类型
注意：此字段可能返回 null，表示取不到有效值。
:type DisplayName: str
:param VpcName: vpc name
注意：此字段可能返回 null，表示取不到有效值。
:type VpcName: str
:param SubnetName: subnet name
注意：此字段可能返回 null，表示取不到有效值。
:type SubnetName: str
:param ClusterExternalServiceInfo: 集群依赖关系
注意：此字段可能返回 null，表示取不到有效值。
:type ClusterExternalServiceInfo: list of ClusterExternalServiceInfo
:param UniqVpcId: 集群vpcid 字符串类型
注意：此字段可能返回 null，表示取不到有效值。
:type UniqVpcId: str
:param UniqSubnetId: 子网id 字符串类型
注意：此字段可能返回 null，表示取不到有效值。
:type UniqSubnetId: str
:param TopologyInfoList: 节点信息
注意：此字段可能返回 null，表示取不到有效值。
:type TopologyInfoList: list of TopologyInfo
:param IsMultiZoneCluster: 是否是跨AZ集群
注意：此字段可能返回 null，表示取不到有效值。
:type IsMultiZoneCluster: bool
:param IsCvmReplace: 是否开通异常节点自动补偿
注意：此字段可能返回 null，表示取不到有效值。
:type IsCvmReplace: bool
"""
self.Id = None
self.ClusterId = None
self.Ftitle = None
self.ClusterName = None
self.RegionId = None
self.ZoneId = None
self.AppId = None
self.Uin = None
self.ProjectId = None
self.VpcId = None
self.SubnetId = None
self.Status = None
self.AddTime = None
self.RunTime = None
self.Config = None
self.MasterIp = None
self.EmrVersion = None
self.ChargeType = None
self.TradeVersion = None
self.ResourceOrderId = None
self.IsTradeCluster = None
self.AlarmInfo = None
self.IsWoodpeckerCluster = None
self.MetaDb = None
self.Tags = None
self.HiveMetaDb = None
self.ServiceClass = None
self.AliasInfo = None
self.ProductId = None
self.Zone = None
self.SceneName = None
self.SceneServiceClass = None
self.SceneEmrVersion = None
self.DisplayName = None
self.VpcName = None
self.SubnetName = None
self.ClusterExternalServiceInfo = None
self.UniqVpcId = None
self.UniqSubnetId = None
self.TopologyInfoList = None
self.IsMultiZoneCluster = None
self.IsCvmReplace = None
def _deserialize(self, params):
self.Id = params.get("Id")
self.ClusterId = params.get("ClusterId")
self.Ftitle = params.get("Ftitle")
self.ClusterName = params.get("ClusterName")
self.RegionId = params.get("RegionId")
self.ZoneId = params.get("ZoneId")
self.AppId = params.get("AppId")
self.Uin = params.get("Uin")
self.ProjectId = params.get("ProjectId")
self.VpcId = params.get("VpcId")
self.SubnetId = params.get("SubnetId")
self.Status = params.get("Status")
self.AddTime = params.get("AddTime")
self.RunTime = params.get("RunTime")
if params.get("Config") is not None:
self.Config = EmrProductConfigOutter()
self.Config._deserialize(params.get("Config"))
self.MasterIp = params.get("MasterIp")
self.EmrVersion = params.get("EmrVersion")
self.ChargeType = params.get("ChargeType")
self.TradeVersion = params.get("TradeVersion")
self.ResourceOrderId = params.get("ResourceOrderId")
self.IsTradeCluster = params.get("IsTradeCluster")
self.AlarmInfo = params.get("AlarmInfo")
self.IsWoodpeckerCluster = params.get("IsWoodpeckerCluster")
self.MetaDb = params.get("MetaDb")
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
self.HiveMetaDb = params.get("HiveMetaDb")
self.ServiceClass = params.get("ServiceClass")
self.AliasInfo = params.get("AliasInfo")
self.ProductId = params.get("ProductId")
self.Zone = params.get("Zone")
self.SceneName = params.get("SceneName")
self.SceneServiceClass = params.get("SceneServiceClass")
self.SceneEmrVersion = params.get("SceneEmrVersion")
self.DisplayName = params.get("DisplayName")
self.VpcName = params.get("VpcName")
self.SubnetName = params.get("SubnetName")
if params.get("ClusterExternalServiceInfo") is not None:
self.ClusterExternalServiceInfo = []
for item in params.get("ClusterExternalServiceInfo"):
obj = ClusterExternalServiceInfo()
obj._deserialize(item)
self.ClusterExternalServiceInfo.append(obj)
self.UniqVpcId = params.get("UniqVpcId")
self.UniqSubnetId = params.get("UniqSubnetId")
if params.get("TopologyInfoList") is not None:
self.TopologyInfoList = []
for item in params.get("TopologyInfoList"):
obj = TopologyInfo()
obj._deserialize(item)
self.TopologyInfoList.append(obj)
self.IsMultiZoneCluster = params.get("IsMultiZoneCluster")
self.IsCvmReplace = params.get("IsCvmReplace")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ClusterSetting(AbstractModel):
"""集群配置。
"""
def __init__(self):
r"""
:param InstanceChargeType: 付费方式。
PREPAID 包年包月。
POSTPAID_BY_HOUR 按量计费，默认方式。
:type InstanceChargeType: str
:param SupportHA: 是否为HA集群。
:type SupportHA: bool
:param SecurityGroupIds: 集群所使用的安全组，目前仅支持一个。
:type SecurityGroupIds: list of str
:param Placement: 实例位置。
:type Placement: :class:`tencentcloud.emr.v20190103.models.Placement`
:param VPCSettings: 实例所在VPC。
:type VPCSettings: :class:`tencentcloud.emr.v20190103.models.VPCSettings`
:param LoginSettings: 实例登录配置。
:type LoginSettings: :class:`tencentcloud.emr.v20190103.models.LoginSettings`
:param TagSpecification: 实例标签，示例：["{\"TagKey\":\"test-tag1\",\"TagValue\":\"001\"}","{\"TagKey\":\"test-tag2\",\"TagValue\":\"002\"}"]。
:type TagSpecification: list of str
:param MetaDB: 元数据库配置。
:type MetaDB: :class:`tencentcloud.emr.v20190103.models.MetaDbInfo`
:param ResourceSpec: 实例硬件配置。
:type ResourceSpec: :class:`tencentcloud.emr.v20190103.models.JobFlowResourceSpec`
:param PublicIpAssigned: 是否申请公网IP，默认为false。
:type PublicIpAssigned: bool
:param InstanceChargePrepaid: 包年包月配置，只对包年包月集群生效。
:type InstanceChargePrepaid: :class:`tencentcloud.emr.v20190103.models.InstanceChargePrepaid`
:param DisasterRecoverGroupIds: 集群置放群组。
:type DisasterRecoverGroupIds: str
:param CbsEncryptFlag: 是否使用cbs加密。
:type CbsEncryptFlag: bool
:param RemoteTcpDefaultPort: 是否使用远程登录，默认为false。
:type RemoteTcpDefaultPort: bool
"""
self.InstanceChargeType = None
self.SupportHA = None
self.SecurityGroupIds = None
self.Placement = None
self.VPCSettings = None
self.LoginSettings = None
self.TagSpecification = None
self.MetaDB = None
self.ResourceSpec = None
self.PublicIpAssigned = None
self.InstanceChargePrepaid = None
self.DisasterRecoverGroupIds = None
self.CbsEncryptFlag = None
self.RemoteTcpDefaultPort = None
def _deserialize(self, params):
self.InstanceChargeType = params.get("InstanceChargeType")
self.SupportHA = params.get("SupportHA")
self.SecurityGroupIds = params.get("SecurityGroupIds")
if params.get("Placement") is not None:
self.Placement = Placement()
self.Placement._deserialize(params.get("Placement"))
if params.get("VPCSettings") is not None:
self.VPCSettings = VPCSettings()
self.VPCSettings._deserialize(params.get("VPCSettings"))
if params.get("LoginSettings") is not None:
self.LoginSettings = LoginSettings()
self.LoginSettings._deserialize(params.get("LoginSettings"))
self.TagSpecification = params.get("TagSpecification")
if params.get("MetaDB") is not None:
self.MetaDB = MetaDbInfo()
self.MetaDB._deserialize(params.get("MetaDB"))
if params.get("ResourceSpec") is not None:
self.ResourceSpec = JobFlowResourceSpec()
self.ResourceSpec._deserialize(params.get("ResourceSpec"))
self.PublicIpAssigned = params.get("PublicIpAssigned")
if params.get("InstanceChargePrepaid") is not None:
self.InstanceChargePrepaid = InstanceChargePrepaid()
self.InstanceChargePrepaid._deserialize(params.get("InstanceChargePrepaid"))
self.DisasterRecoverGroupIds = params.get("DisasterRecoverGroupIds")
self.CbsEncryptFlag = params.get("CbsEncryptFlag")
self.RemoteTcpDefaultPort = params.get("RemoteTcpDefaultPort")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ComponentBasicRestartInfo(AbstractModel):
"""操作的进程范围
"""
def __init__(self):
r"""
:param ComponentName: 进程名，必填，如NameNode
注意：此字段可能返回 null，表示取不到有效值。
:type ComponentName: str
:param IpList: 操作的IP列表
注意：此字段可能返回 null，表示取不到有效值。
:type IpList: list of str
"""
self.ComponentName = None
self.IpList = None
def _deserialize(self, params):
self.ComponentName = params.get("ComponentName")
self.IpList = params.get("IpList")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class Configuration(AbstractModel):
"""自定义配置参数
"""
def __init__(self):
r"""
:param Classification: 配置文件名，支持SPARK、HIVE、HDFS、YARN的部分配置文件自定义。
:type Classification: str
:param Properties: 配置参数通过KV的形式传入，部分文件支持自定义，可以通过特殊的键"content"传入所有内容。
:type Properties: str
"""
self.Classification = None
self.Properties = None
def _deserialize(self, params):
self.Classification = params.get("Classification")
self.Properties = params.get("Properties")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class CreateClusterRequest(AbstractModel):
"""CreateCluster请求参数结构体
"""
def __init__(self):
r"""
:param ProductVersion: EMR产品版本名称如EMR-V2.3.0 表示2.3.0版本的EMR， 当前支持产品版本名称查询：[产品版本名称](https://cloud.tencent.com/document/product/589/66338)
:type ProductVersion: str
:param EnableSupportHAFlag: 是否开启节点高可用。取值范围：
true：表示开启节点高可用。
false：表示不开启节点高可用。
:type EnableSupportHAFlag: bool
:param InstanceName: 实例名称。
长度限制为6-36个字符。
只允许包含中文、字母、数字、-、_。
:type InstanceName: str
:param InstanceChargeType: 实例计费模式。取值范围：
PREPAID：预付费，即包年包月。
POSTPAID_BY_HOUR：按小时后付费。
:type InstanceChargeType: str
:param LoginSettings: 实例登录设置。通过该参数可以设置所购买节点的登录方式密码或者密钥。
设置密钥时，密码仅用于组件原生WebUI快捷入口登录。
未设置密钥时，密码用于登录所购节点以及组件原生WebUI快捷入口登录。
:type LoginSettings: :class:`tencentcloud.emr.v20190103.models.LoginSettings`
:param SceneSoftwareConfig: 集群应用场景以及支持部署组件配置
:type SceneSoftwareConfig: :class:`tencentcloud.emr.v20190103.models.SceneSoftwareConfig`
:param InstanceChargePrepaid: 即包年包月相关参数设置。通过该参数可以指定包年包月实例的购买时长、是否设置自动续费等属性。若指定实例的付费模式为预付费则该参数必传。
:type InstanceChargePrepaid: :class:`tencentcloud.emr.v20190103.models.InstanceChargePrepaid`
:param SecurityGroupIds: 实例所属安全组的ID，形如sg-xxxxxxxx。该参数可以通过调用 [DescribeSecurityGroups](https://cloud.tencent.com/document/api/215/15808) 的返回值中的SecurityGroupId字段来获取。
:type SecurityGroupIds: list of str
:param ScriptBootstrapActionConfig: [引导操作](https://cloud.tencent.com/document/product/589/35656)脚本设置。
:type ScriptBootstrapActionConfig: list of ScriptBootstrapActionConfig
:param ClientToken: 唯一随机标识，时效性为5分钟，需要调用者指定 防止客户端重复创建资源，例如 a9a90aa6-751a-41b6-aad6-fae360632808
:type ClientToken: str
:param NeedMasterWan: 是否开启集群Master节点公网。取值范围：
NEED_MASTER_WAN：表示开启集群Master节点公网。
NOT_NEED_MASTER_WAN：表示不开启。默认开启集群Master节点公网。
:type NeedMasterWan: str
:param EnableRemoteLoginFlag: 是否开启外网远程登录。（在SecurityGroupId不为空时，该参数无效）不填默认为不开启 取值范围：
true：表示开启
false：表示不开启
:type EnableRemoteLoginFlag: bool
:param EnableKerberosFlag: 是否开启Kerberos认证。默认不开启 取值范围：
true：表示开启
false：表示不开启
:type EnableKerberosFlag: bool
:param CustomConf: [自定义软件配置](https://cloud.tencent.com/document/product/589/35655?from_cn_redirect=1)
:type CustomConf: str
:param Tags: 标签描述列表。通过指定该参数可以同时绑定标签到相应的实例。
:type Tags: list of Tag
:param DisasterRecoverGroupIds: 分散置放群组ID列表，当前只支持指定一个。
该参数可以通过调用 [DescribeDisasterRecoverGroups](https://cloud.tencent.com/document/product/213/17810)的返回值中的DisasterRecoverGroupId字段来获取。
:type DisasterRecoverGroupIds: list of str
:param EnableCbsEncryptFlag: 是否开启集群维度CBS加密。默认不加密 取值范围：
true：表示加密
false：表示不加密
:type EnableCbsEncryptFlag: bool
:param MetaDBInfo: MetaDB信息，当MetaType选择EMR_NEW_META时，MetaDataJdbcUrl MetaDataUser MetaDataPass UnifyMetaInstanceId不用填
当MetaType选择EMR_EXIT_META时，填写UnifyMetaInstanceId
当MetaType选择USER_CUSTOM_META时，填写MetaDataJdbcUrl MetaDataUser MetaDataPass
:type MetaDBInfo: :class:`tencentcloud.emr.v20190103.models.CustomMetaDBInfo`
:param DependService: 共享组件信息
:type DependService: list of DependService
:param ZoneResourceConfiguration: 节点资源的规格，有几个可用区，就填几个，按顺序第一个为主可用区，第二个为备可用区，第三个为仲裁可用区。如果没有开启跨AZ，则长度为1即可。
:type ZoneResourceConfiguration: list of ZoneResourceConfiguration
"""
self.ProductVersion = None
self.EnableSupportHAFlag = None
self.InstanceName = None
self.InstanceChargeType = None
self.LoginSettings = None
self.SceneSoftwareConfig = None
self.InstanceChargePrepaid = None
self.SecurityGroupIds = None
self.ScriptBootstrapActionConfig = None
self.ClientToken = None
self.NeedMasterWan = None
self.EnableRemoteLoginFlag = None
self.EnableKerberosFlag = None
self.CustomConf = None
self.Tags = None
self.DisasterRecoverGroupIds = None
self.EnableCbsEncryptFlag = None
self.MetaDBInfo = None
self.DependService = None
self.ZoneResourceConfiguration = None
def _deserialize(self, params):
self.ProductVersion = params.get("ProductVersion")
self.EnableSupportHAFlag = params.get("EnableSupportHAFlag")
self.InstanceName = params.get("InstanceName")
self.InstanceChargeType = params.get("InstanceChargeType")
if params.get("LoginSettings") is not None:
self.LoginSettings = LoginSettings()
self.LoginSettings._deserialize(params.get("LoginSettings"))
if params.get("SceneSoftwareConfig") is not None:
self.SceneSoftwareConfig = SceneSoftwareConfig()
self.SceneSoftwareConfig._deserialize(params.get("SceneSoftwareConfig"))
if params.get("InstanceChargePrepaid") is not None:
self.InstanceChargePrepaid = InstanceChargePrepaid()
self.InstanceChargePrepaid._deserialize(params.get("InstanceChargePrepaid"))
self.SecurityGroupIds = params.get("SecurityGroupIds")
if params.get("ScriptBootstrapActionConfig") is not None:
self.ScriptBootstrapActionConfig = []
for item in params.get("ScriptBootstrapActionConfig"):
obj = ScriptBootstrapActionConfig()
obj._deserialize(item)
self.ScriptBootstrapActionConfig.append(obj)
self.ClientToken = params.get("ClientToken")
self.NeedMasterWan = params.get("NeedMasterWan")
self.EnableRemoteLoginFlag = params.get("EnableRemoteLoginFlag")
self.EnableKerberosFlag = params.get("EnableKerberosFlag")
self.CustomConf = params.get("CustomConf")
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
self.DisasterRecoverGroupIds = params.get("DisasterRecoverGroupIds")
self.EnableCbsEncryptFlag = params.get("EnableCbsEncryptFlag")
if params.get("MetaDBInfo") is not None:
self.MetaDBInfo = CustomMetaDBInfo()
self.MetaDBInfo._deserialize(params.get("MetaDBInfo"))
if params.get("DependService") is not None:
self.DependService = []
for item in params.get("DependService"):
obj = DependService()
obj._deserialize(item)
self.DependService.append(obj)
if params.get("ZoneResourceConfiguration") is not None:
self.ZoneResourceConfiguration = []
for item in params.get("ZoneResourceConfiguration"):
obj = ZoneResourceConfiguration()
obj._deserialize(item)
self.ZoneResourceConfiguration.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class CreateClusterResponse(AbstractModel):
"""CreateCluster返回参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 实例ID
注意：此字段可能返回 null，表示取不到有效值。
:type InstanceId: str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.InstanceId = None
self.RequestId = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.RequestId = params.get("RequestId")
class CreateInstanceRequest(AbstractModel):
"""CreateInstance请求参数结构体
"""
def __init__(self):
r"""
:param ProductId: 产品ID，不同产品ID表示不同的EMR产品版本。取值范围：
16：表示EMR-V2.3.0。
20：表示EMR-V2.5.0。
25：表示EMR-V3.1.0。
27：表示KAFKA-V1.0.0。
30：表示EMR-V2.6.0。
33 : 表示EMR-V3.2.1。
34 : 表示EMR-V3.3.0。
36 : 表示STARROCKS-V1.0.0。
37 : 表示EMR-V3.4.0。
38 : 表示EMR-V2.7.0。
39 : 表示STARROCKS-V1.1.0。
41 : 表示DRUID-V1.1.0。
:type ProductId: int
:param Software: 部署的组件列表。不同的EMR产品ID（ProductId：具体含义参考入参ProductId字段）对应不同可选组件列表，不同产品版本可选组件列表查询：[组件版本](https://cloud.tencent.com/document/product/589/20279) ；
填写实例值：hive、flink。
:type Software: list of str
:param SupportHA: 是否开启节点高可用。取值范围：
0：表示不开启节点高可用。
1：表示开启节点高可用。
:type SupportHA: int
:param InstanceName: 实例名称。
长度限制为6-36个字符。
只允许包含中文、字母、数字、-、_。
:type InstanceName: str
:param PayMode: 实例计费模式。取值范围：
0：表示按量计费。
1：表示包年包月。
:type PayMode: int
:param TimeSpan: 购买实例的时长。结合TimeUnit一起使用。
TimeUnit为s时，该参数只能填写3600，表示按量计费实例。
TimeUnit为m时，该参数填写的数字表示包年包月实例的购买时长，如1表示购买一个月
:type TimeSpan: int
:param TimeUnit: 购买实例的时间单位。取值范围：
s：表示秒。PayMode取值为0时，TimeUnit只能取值为s。
m：表示月份。PayMode取值为1时，TimeUnit只能取值为m。
:type TimeUnit: str
:param LoginSettings: 实例登录设置。通过该参数可以设置所购买节点的登录方式密码或者密钥。
设置密钥时，密码仅用于组件原生WebUI快捷入口登录。
未设置密钥时，密码用于登录所购节点以及组件原生WebUI快捷入口登录。
:type LoginSettings: :class:`tencentcloud.emr.v20190103.models.LoginSettings`
:param VPCSettings: 私有网络相关信息配置。通过该参数可以指定私有网络的ID，子网ID等信息。
:type VPCSettings: :class:`tencentcloud.emr.v20190103.models.VPCSettings`
:param ResourceSpec: 节点资源的规格。
:type ResourceSpec: :class:`tencentcloud.emr.v20190103.models.NewResourceSpec`
:param COSSettings: 开启COS访问需要设置的参数。
:type COSSettings: :class:`tencentcloud.emr.v20190103.models.COSSettings`
:param Placement: 实例所在的位置。通过该参数可以指定实例所属可用区，所属项目等属性。
:type Placement: :class:`tencentcloud.emr.v20190103.models.Placement`
:param SgId: 实例所属安全组的ID，形如sg-xxxxxxxx。该参数可以通过调用 [DescribeSecurityGroups](https://cloud.tencent.com/document/api/215/15808) 的返回值中的SecurityGroupId字段来获取。
:type SgId: str
:param PreExecutedFileSettings: [引导操作](https://cloud.tencent.com/document/product/589/35656)脚本设置。
:type PreExecutedFileSettings: list of PreExecuteFileSettings
:param AutoRenew: 包年包月实例是否自动续费。取值范围：
0：表示不自动续费。
1：表示自动续费。
:type AutoRenew: int
:param ClientToken: 客户端Token。
:type ClientToken: str
:param NeedMasterWan: 是否开启集群Master节点公网。取值范围：
NEED_MASTER_WAN：表示开启集群Master节点公网。
NOT_NEED_MASTER_WAN：表示不开启。默认开启集群Master节点公网。
:type NeedMasterWan: str
:param RemoteLoginAtCreate: 是否需要开启外网远程登录，即22号端口。在SgId不为空时，该参数无效。
:type RemoteLoginAtCreate: int
:param CheckSecurity: 是否开启安全集群。0表示不开启，非0表示开启。
:type CheckSecurity: int
:param ExtendFsField: 访问外部文件系统。
:type ExtendFsField: str
:param Tags: 标签描述列表。通过指定该参数可以同时绑定标签到相应的实例。
:type Tags: list of Tag
:param DisasterRecoverGroupIds: 分散置放群组ID列表，当前只支持指定一个。
该参数可以通过调用 [DescribeSecurityGroups](https://cloud.tencent.com/document/product/213/15486 ) 的返回值中的SecurityGroupId字段来获取。
:type DisasterRecoverGroupIds: list of str
:param CbsEncrypt: 集群维度CBS加密盘，默认0表示不加密，1表示加密
:type CbsEncrypt: int
:param MetaType: hive共享元数据库类型。取值范围：
EMR_NEW_META：表示集群默认创建
EMR_EXIT_META：表示集群使用指定EMR-MetaDB。
USER_CUSTOM_META：表示集群使用自定义MetaDB。
:type MetaType: str
:param UnifyMetaInstanceId: EMR-MetaDB实例
:type UnifyMetaInstanceId: str
:param MetaDBInfo: 自定义MetaDB信息
:type MetaDBInfo: :class:`tencentcloud.emr.v20190103.models.CustomMetaInfo`
:param ApplicationRole: 自定义应用角色。
:type ApplicationRole: str
:param SceneName: 场景化取值：
Hadoop-Kudu
Hadoop-Zookeeper
Hadoop-Presto
Hadoop-Hbase
:type SceneName: str
:param ExternalService: 共享组件信息
:type ExternalService: list of ExternalService
:param VersionID: 如果为0，则MultiZone、MultiDeployStrategy、MultiZoneSettings是disable的状态，如果为1，则废弃ResourceSpec，使用MultiZoneSettings。
:type VersionID: int
:param MultiZone: true表示开启跨AZ部署；仅为新建集群时的用户参数，后续不支持调整。
:type MultiZone: bool
:param MultiZoneSettings: 节点资源的规格，有几个可用区，就填几个，按顺序第一个为主可用区，第二个为备可用区，第三个为仲裁可用区。如果没有开启跨AZ，则长度为1即可。
:type MultiZoneSettings: list of MultiZoneSetting
"""
self.ProductId = None
self.Software = None
self.SupportHA = None
self.InstanceName = None
self.PayMode = None
self.TimeSpan = None
self.TimeUnit = None
self.LoginSettings = None
self.VPCSettings = None
self.ResourceSpec = None
self.COSSettings = None
self.Placement = None
self.SgId = None
self.PreExecutedFileSettings = None
self.AutoRenew = None
self.ClientToken = None
self.NeedMasterWan = None
self.RemoteLoginAtCreate = None
self.CheckSecurity = None
self.ExtendFsField = None
self.Tags = None
self.DisasterRecoverGroupIds = None
self.CbsEncrypt = None
self.MetaType = None
self.UnifyMetaInstanceId = None
self.MetaDBInfo = None
self.ApplicationRole = None
self.SceneName = None
self.ExternalService = None
self.VersionID = None
self.MultiZone = None
self.MultiZoneSettings = None
def _deserialize(self, params):
self.ProductId = params.get("ProductId")
self.Software = params.get("Software")
self.SupportHA = params.get("SupportHA")
self.InstanceName = params.get("InstanceName")
self.PayMode = params.get("PayMode")
self.TimeSpan = params.get("TimeSpan")
self.TimeUnit = params.get("TimeUnit")
if params.get("LoginSettings") is not None:
self.LoginSettings = LoginSettings()
self.LoginSettings._deserialize(params.get("LoginSettings"))
if params.get("VPCSettings") is not None:
self.VPCSettings = VPCSettings()
self.VPCSettings._deserialize(params.get("VPCSettings"))
if params.get("ResourceSpec") is not None:
self.ResourceSpec = NewResourceSpec()
self.ResourceSpec._deserialize(params.get("ResourceSpec"))
if params.get("COSSettings") is not None:
self.COSSettings = COSSettings()
self.COSSettings._deserialize(params.get("COSSettings"))
if params.get("Placement") is not None:
self.Placement = Placement()
self.Placement._deserialize(params.get("Placement"))
self.SgId = params.get("SgId")
if params.get("PreExecutedFileSettings") is not None:
self.PreExecutedFileSettings = []
for item in params.get("PreExecutedFileSettings"):
obj = PreExecuteFileSettings()
obj._deserialize(item)
self.PreExecutedFileSettings.append(obj)
self.AutoRenew = params.get("AutoRenew")
self.ClientToken = params.get("ClientToken")
self.NeedMasterWan = params.get("NeedMasterWan")
self.RemoteLoginAtCreate = params.get("RemoteLoginAtCreate")
self.CheckSecurity = params.get("CheckSecurity")
self.ExtendFsField = params.get("ExtendFsField")
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
self.DisasterRecoverGroupIds = params.get("DisasterRecoverGroupIds")
self.CbsEncrypt = params.get("CbsEncrypt")
self.MetaType = params.get("MetaType")
self.UnifyMetaInstanceId = params.get("UnifyMetaInstanceId")
if params.get("MetaDBInfo") is not None:
self.MetaDBInfo = CustomMetaInfo()
self.MetaDBInfo._deserialize(params.get("MetaDBInfo"))
self.ApplicationRole = params.get("ApplicationRole")
self.SceneName = params.get("SceneName")
if params.get("ExternalService") is not None:
self.ExternalService = []
for item in params.get("ExternalService"):
obj = ExternalService()
obj._deserialize(item)
self.ExternalService.append(obj)
self.VersionID = params.get("VersionID")
self.MultiZone = params.get("MultiZone")
if params.get("MultiZoneSettings") is not None:
self.MultiZoneSettings = []
for item in params.get("MultiZoneSettings"):
obj = MultiZoneSetting()
obj._deserialize(item)
self.MultiZoneSettings.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class CreateInstanceResponse(AbstractModel):
"""CreateInstance返回参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 实例ID
注意：此字段可能返回 null，表示取不到有效值。
:type InstanceId: str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.InstanceId = None
self.RequestId = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.RequestId = params.get("RequestId")
class CustomMetaDBInfo(AbstractModel):
"""用户Hive-MetaDB信息
"""
def __init__(self):
r"""
:param MetaDataJdbcUrl: 自定义MetaDB的JDBC连接，示例: jdbc:mysql://10.10.10.10:3306/dbname
:type MetaDataJdbcUrl: str
:param MetaDataUser: 自定义MetaDB用户名
:type MetaDataUser: str
:param MetaDataPass: 自定义MetaDB密码
:type MetaDataPass: str
:param MetaType: hive共享元数据库类型。取值范围：
EMR_DEFAULT_META：表示集群默认创建
EMR_EXIST_META：表示集群使用指定EMR-MetaDB。
USER_CUSTOM_META：表示集群使用自定义MetaDB。
:type MetaType: str
:param UnifyMetaInstanceId: EMR-MetaDB实例
:type UnifyMetaInstanceId: str
"""
self.MetaDataJdbcUrl = None
self.MetaDataUser = None
self.MetaDataPass = None
self.MetaType = None
self.UnifyMetaInstanceId = None
def _deserialize(self, params):
self.MetaDataJdbcUrl = params.get("MetaDataJdbcUrl")
self.MetaDataUser = params.get("MetaDataUser")
self.MetaDataPass = params.get("MetaDataPass")
self.MetaType = params.get("MetaType")
self.UnifyMetaInstanceId = params.get("UnifyMetaInstanceId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class CustomMetaInfo(AbstractModel):
"""用户自建Hive-MetaDB信息
"""
def __init__(self):
r"""
:param MetaDataJdbcUrl: 自定义MetaDB的JDBC连接，请以 jdbc:mysql:// 开头
:type MetaDataJdbcUrl: str
:param MetaDataUser: 自定义MetaDB用户名
:type MetaDataUser: str
:param MetaDataPass: 自定义MetaDB密码
:type MetaDataPass: str
"""
self.MetaDataJdbcUrl = None
self.MetaDataUser = None
self.MetaDataPass = None
def _deserialize(self, params):
self.MetaDataJdbcUrl = params.get("MetaDataJdbcUrl")
self.MetaDataUser = params.get("MetaDataUser")
self.MetaDataPass = params.get("MetaDataPass")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class CustomServiceDefine(AbstractModel):
"""共用自建组件参数
"""
def __init__(self):
r"""
:param Name: 自定义参数key
:type Name: str
:param Value: 自定义参数value
:type Value: str
"""
self.Name = None
self.Value = None
def _deserialize(self, params):
self.Name = params.get("Name")
self.Value = params.get("Value")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DeleteUserManagerUserListRequest(AbstractModel):
"""DeleteUserManagerUserList请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 集群实例ID
:type InstanceId: str
:param UserNameList: 集群用户名列表
:type UserNameList: list of str
"""
self.InstanceId = None
self.UserNameList = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.UserNameList = params.get("UserNameList")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DeleteUserManagerUserListResponse(AbstractModel):
"""DeleteUserManagerUserList返回参数结构体
"""
def __init__(self):
r"""
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.RequestId = None
def _deserialize(self, params):
self.RequestId = params.get("RequestId")
class DependService(AbstractModel):
"""共用组件信息
"""
def __init__(self):
r"""
:param ServiceName: 共用组件名
:type ServiceName: str
:param InstanceId: 共用组件集群
:type InstanceId: str
"""
self.ServiceName = None
self.InstanceId = None
def _deserialize(self, params):
self.ServiceName = params.get("ServiceName")
self.InstanceId = params.get("InstanceId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DescribeClusterNodesRequest(AbstractModel):
"""DescribeClusterNodes请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 集群实例ID,实例ID形如: emr-xxxxxxxx
:type InstanceId: str
:param NodeFlag: 节点标识，取值为：
all：表示获取全部类型节点，cdb信息除外。
master：表示获取master节点信息。
core：表示获取core节点信息。
task：表示获取task节点信息。
common：表示获取common节点信息。
router：表示获取router节点信息。
db：表示获取正常状态的cdb信息。
recyle：表示获取回收站隔离中的节点信息，包括cdb信息。
renew：表示获取所有待续费的节点信息，包括cdb信息，自动续费节点不会返回。
注意：现在只支持以上取值，输入其他值会导致错误。
:type NodeFlag: str
:param Offset: 页编号，默认值为0，表示第一页。
:type Offset: int
:param Limit: 每页返回数量，默认值为100，最大值为100。
:type Limit: int
:param HardwareResourceType: 资源类型:支持all/host/pod，默认为all
:type HardwareResourceType: str
:param SearchFields: 支持搜索的字段
:type SearchFields: list of SearchItem
:param OrderField: 无
:type OrderField: str
:param Asc: 无
:type Asc: int
"""
self.InstanceId = None
self.NodeFlag = None
self.Offset = None
self.Limit = None
self.HardwareResourceType = None
self.SearchFields = None
self.OrderField = None
self.Asc = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.NodeFlag = params.get("NodeFlag")
self.Offset = params.get("Offset")
self.Limit = params.get("Limit")
self.HardwareResourceType = params.get("HardwareResourceType")
if params.get("SearchFields") is not None:
self.SearchFields = []
for item in params.get("SearchFields"):
obj = SearchItem()
obj._deserialize(item)
self.SearchFields.append(obj)
self.OrderField = params.get("OrderField")
self.Asc = params.get("Asc")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DescribeClusterNodesResponse(AbstractModel):
"""DescribeClusterNodes返回参数结构体
"""
def __init__(self):
r"""
:param TotalCnt: 查询到的节点总数
:type TotalCnt: int
:param NodeList: 节点详细信息列表
注意：此字段可能返回 null，表示取不到有效值。
:type NodeList: list of NodeHardwareInfo
:param TagKeys: 用户所有的标签键列表
注意：此字段可能返回 null，表示取不到有效值。
:type TagKeys: list of str
:param HardwareResourceTypeList: 资源类型列表
注意：此字段可能返回 null，表示取不到有效值。
:type HardwareResourceTypeList: list of str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.TotalCnt = None
self.NodeList = None
self.TagKeys = None
self.HardwareResourceTypeList = None
self.RequestId = None
def _deserialize(self, params):
self.TotalCnt = params.get("TotalCnt")
if params.get("NodeList") is not None:
self.NodeList = []
for item in params.get("NodeList"):
obj = NodeHardwareInfo()
obj._deserialize(item)
self.NodeList.append(obj)
self.TagKeys = params.get("TagKeys")
self.HardwareResourceTypeList = params.get("HardwareResourceTypeList")
self.RequestId = params.get("RequestId")
class DescribeCvmQuotaRequest(AbstractModel):
"""DescribeCvmQuota请求参数结构体
"""
def __init__(self):
r"""
:param ClusterId: EMR集群ID
:type ClusterId: str
:param ZoneId: 区ID
:type ZoneId: int
"""
self.ClusterId = None
self.ZoneId = None
def _deserialize(self, params):
self.ClusterId = params.get("ClusterId")
self.ZoneId = params.get("ZoneId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DescribeCvmQuotaResponse(AbstractModel):
"""DescribeCvmQuota返回参数结构体
"""
def __init__(self):
r"""
:param PostPaidQuotaSet: 后付费配额列表
注意：此字段可能返回 null，表示取不到有效值。
:type PostPaidQuotaSet: list of QuotaEntity
:param SpotPaidQuotaSet: 竞价实例配额列表
注意：此字段可能返回 null，表示取不到有效值。
:type SpotPaidQuotaSet: list of QuotaEntity
:param EksQuotaSet: eks配额
注意：此字段可能返回 null，表示取不到有效值。
:type EksQuotaSet: list of PodSaleSpec
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.PostPaidQuotaSet = None
self.SpotPaidQuotaSet = None
self.EksQuotaSet = None
self.RequestId = None
def _deserialize(self, params):
if params.get("PostPaidQuotaSet") is not None:
self.PostPaidQuotaSet = []
for item in params.get("PostPaidQuotaSet"):
obj = QuotaEntity()
obj._deserialize(item)
self.PostPaidQuotaSet.append(obj)
if params.get("SpotPaidQuotaSet") is not None:
self.SpotPaidQuotaSet = []
for item in params.get("SpotPaidQuotaSet"):
obj = QuotaEntity()
obj._deserialize(item)
self.SpotPaidQuotaSet.append(obj)
if params.get("EksQuotaSet") is not None:
self.EksQuotaSet = []
for item in params.get("EksQuotaSet"):
obj = PodSaleSpec()
obj._deserialize(item)
self.EksQuotaSet.append(obj)
self.RequestId = params.get("RequestId")
class DescribeEmrApplicationStaticsRequest(AbstractModel):
"""DescribeEmrApplicationStatics请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 集群id
:type InstanceId: str
:param StartTime: 起始时间，时间戳（秒）
:type StartTime: int
:param EndTime: 结束时间，时间戳（秒）
:type EndTime: int
:param Queues: 过滤的队列名
:type Queues: list of str
:param Users: 过滤的用户名
:type Users: list of str
:param ApplicationTypes: 过滤的作业类型
:type ApplicationTypes: list of str
:param GroupBy: 分组字段，可选：queue, user, applicationType
:type GroupBy: list of str
:param OrderBy: 排序字段，可选：sumMemorySeconds, sumVCoreSeconds, sumHDFSBytesWritten, sumHDFSBytesRead
:type OrderBy: str
:param IsAsc: 是否顺序排序，0-逆序，1-正序
:type IsAsc: int
:param Offset: 页号
:type Offset: int
:param Limit: 页容量
:type Limit: int
"""
self.InstanceId = None
self.StartTime = None
self.EndTime = None
self.Queues = None
self.Users = None
self.ApplicationTypes = None
self.GroupBy = None
self.OrderBy = None
self.IsAsc = None
self.Offset = None
self.Limit = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.StartTime = params.get("StartTime")
self.EndTime = params.get("EndTime")
self.Queues = params.get("Queues")
self.Users = params.get("Users")
self.ApplicationTypes = params.get("ApplicationTypes")
self.GroupBy = params.get("GroupBy")
self.OrderBy = params.get("OrderBy")
self.IsAsc = params.get("IsAsc")
self.Offset = params.get("Offset")
self.Limit = params.get("Limit")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DescribeEmrApplicationStaticsResponse(AbstractModel):
"""DescribeEmrApplicationStatics返回参数结构体
"""
def __init__(self):
r"""
:param Statics: 作业统计信息
:type Statics: list of ApplicationStatics
:param TotalCount: 总数
:type TotalCount: int
:param Queues: 可选择的队列名
:type Queues: list of str
:param Users: 可选择的用户名
:type Users: list of str
:param ApplicationTypes: 可选择的作业类型
:type ApplicationTypes: list of str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.Statics = None
self.TotalCount = None
self.Queues = None
self.Users = None
self.ApplicationTypes = None
self.RequestId = None
def _deserialize(self, params):
if params.get("Statics") is not None:
self.Statics = []
for item in params.get("Statics"):
obj = ApplicationStatics()
obj._deserialize(item)
self.Statics.append(obj)
self.TotalCount = params.get("TotalCount")
self.Queues = params.get("Queues")
self.Users = params.get("Users")
self.ApplicationTypes = params.get("ApplicationTypes")
self.RequestId = params.get("RequestId")
class DescribeInstanceRenewNodesRequest(AbstractModel):
"""DescribeInstanceRenewNodes请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 集群实例ID,实例ID形如: emr-xxxxxxxx
:type InstanceId: str
"""
self.InstanceId = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DescribeInstanceRenewNodesResponse(AbstractModel):
"""DescribeInstanceRenewNodes返回参数结构体
"""
def __init__(self):
r"""
:param TotalCnt: 查询到的节点总数
:type TotalCnt: int
:param NodeList: 节点详细信息列表
注意：此字段可能返回 null，表示取不到有效值。
:type NodeList: list of RenewInstancesInfo
:param MetaInfo: 用户所有的标签键列表
注意：此字段可能返回 null，表示取不到有效值。
:type MetaInfo: list of str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.TotalCnt = None
self.NodeList = None
self.MetaInfo = None
self.RequestId = None
def _deserialize(self, params):
self.TotalCnt = params.get("TotalCnt")
if params.get("NodeList") is not None:
self.NodeList = []
for item in params.get("NodeList"):
obj = RenewInstancesInfo()
obj._deserialize(item)
self.NodeList.append(obj)
self.MetaInfo = params.get("MetaInfo")
self.RequestId = params.get("RequestId")
class DescribeInstancesListRequest(AbstractModel):
"""DescribeInstancesList请求参数结构体
"""
def __init__(self):
r"""
:param DisplayStrategy: 集群筛选策略。取值范围：clusterList：表示查询除了已销毁集群之外的集群列表。monitorManage：表示查询除了已销毁、创建中以及创建失败的集群之外的集群列表。cloudHardwareManage/componentManage：目前这两个取值为预留取值，暂时和monitorManage表示同样的含义。
:type DisplayStrategy: str
:param Offset: 页编号，默认值为0，表示第一页。
:type Offset: int
:param Limit: 每页返回数量，默认值为10，最大值为100。
:type Limit: int
:param OrderField: 排序字段。取值范围：clusterId：表示按照实例ID排序。addTime：表示按照实例创建时间排序。status：表示按照实例的状态码排序。
:type OrderField: str
:param Asc: 按照OrderField升序或者降序进行排序。取值范围：0：表示降序。1：表示升序。默认值为0。
:type Asc: int
:param Filters: 自定义查询
:type Filters: list of Filters
"""
self.DisplayStrategy = None
self.Offset = None
self.Limit = None
self.OrderField = None
self.Asc = None
self.Filters = None
def _deserialize(self, params):
self.DisplayStrategy = params.get("DisplayStrategy")
self.Offset = params.get("Offset")
self.Limit = params.get("Limit")
self.OrderField = params.get("OrderField")
self.Asc = params.get("Asc")
if params.get("Filters") is not None:
self.Filters = []
for item in params.get("Filters"):
obj = Filters()
obj._deserialize(item)
self.Filters.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DescribeInstancesListResponse(AbstractModel):
"""DescribeInstancesList返回参数结构体
"""
def __init__(self):
r"""
:param TotalCnt: 符合条件的实例总数。
:type TotalCnt: int
:param InstancesList: 集群实例列表
:type InstancesList: list of EmrListInstance
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.TotalCnt = None
self.InstancesList = None
self.RequestId = None
def _deserialize(self, params):
self.TotalCnt = params.get("TotalCnt")
if params.get("InstancesList") is not None:
self.InstancesList = []
for item in params.get("InstancesList"):
obj = EmrListInstance()
obj._deserialize(item)
self.InstancesList.append(obj)
self.RequestId = params.get("RequestId")
class DescribeInstancesRequest(AbstractModel):
"""DescribeInstances请求参数结构体
"""
def __init__(self):
r"""
:param DisplayStrategy: 集群筛选策略。取值范围：
clusterList：表示查询除了已销毁集群之外的集群列表。
monitorManage：表示查询除了已销毁、创建中以及创建失败的集群之外的集群列表。
cloudHardwareManage/componentManage：目前这两个取值为预留取值，暂时和monitorManage表示同样的含义。
:type DisplayStrategy: str
:param InstanceIds: 按照一个或者多个实例ID查询。实例ID形如: emr-xxxxxxxx 。(此参数的具体格式可参考API[简介](https://cloud.tencent.com/document/api/213/15688)的 Ids.N 一节)。如果不填写实例ID，返回该APPID下所有实例列表。
:type InstanceIds: list of str
:param Offset: 页编号，默认值为0，表示第一页。
:type Offset: int
:param Limit: 每页返回数量，默认值为10，最大值为100。
:type Limit: int
:param ProjectId: 建议必填-1，表示拉取所有项目下的集群。
不填默认值为0，表示拉取默认项目下的集群。
实例所属项目ID。该参数可以通过调用 [DescribeProject](https://cloud.tencent.com/document/api/378/4400) 的返回值中的 projectId 字段来获取。
:type ProjectId: int
:param OrderField: 排序字段。取值范围：
clusterId：表示按照实例ID排序。
addTime：表示按照实例创建时间排序。
status：表示按照实例的状态码排序。
:type OrderField: str
:param Asc: 按照OrderField升序或者降序进行排序。取值范围：
0：表示降序。
1：表示升序。默认值为0。
:type Asc: int
"""
self.DisplayStrategy = None
self.InstanceIds = None
self.Offset = None
self.Limit = None
self.ProjectId = None
self.OrderField = None
self.Asc = None
def _deserialize(self, params):
self.DisplayStrategy = params.get("DisplayStrategy")
self.InstanceIds = params.get("InstanceIds")
self.Offset = params.get("Offset")
self.Limit = params.get("Limit")
self.ProjectId = params.get("ProjectId")
self.OrderField = params.get("OrderField")
self.Asc = params.get("Asc")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DescribeInstancesResponse(AbstractModel):
"""DescribeInstances返回参数结构体
"""
def __init__(self):
r"""
:param TotalCnt: 符合条件的实例总数。
:type TotalCnt: int
:param ClusterList: EMR实例详细信息列表。
注意：此字段可能返回 null，表示取不到有效值。
:type ClusterList: list of ClusterInstancesInfo
:param TagKeys: 实例关联的标签键列表。
注意：此字段可能返回 null，表示取不到有效值。
:type TagKeys: list of str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.TotalCnt = None
self.ClusterList = None
self.TagKeys = None
self.RequestId = None
def _deserialize(self, params):
self.TotalCnt = params.get("TotalCnt")
if params.get("ClusterList") is not None:
self.ClusterList = []
for item in params.get("ClusterList"):
obj = ClusterInstancesInfo()
obj._deserialize(item)
self.ClusterList.append(obj)
self.TagKeys = params.get("TagKeys")
self.RequestId = params.get("RequestId")
class DescribeJobFlowRequest(AbstractModel):
"""DescribeJobFlow请求参数结构体
"""
def __init__(self):
r"""
:param JobFlowId: 流程任务Id，RunJobFlow接口返回的值。
:type JobFlowId: int
"""
self.JobFlowId = None
def _deserialize(self, params):
self.JobFlowId = params.get("JobFlowId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DescribeJobFlowResponse(AbstractModel):
"""DescribeJobFlow返回参数结构体
"""
def __init__(self):
r"""
:param State: 流程任务状态，可以为以下值：
JobFlowInit，流程任务初始化。
JobFlowResourceApplied，资源申请中，通常为JobFlow需要新建集群时的状态。
JobFlowResourceReady，执行流程任务的资源就绪。
JobFlowStepsRunning，流程任务步骤已提交。
JobFlowStepsComplete，流程任务步骤已完成。
JobFlowTerminating，流程任务所需资源销毁中。
JobFlowFinish，流程任务已完成。
:type State: str
:param Details: 流程任务步骤结果。
:type Details: list of JobResult
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.State = None
self.Details = None
self.RequestId = None
def _deserialize(self, params):
self.State = params.get("State")
if params.get("Details") is not None:
self.Details = []
for item in params.get("Details"):
obj = JobResult()
obj._deserialize(item)
self.Details.append(obj)
self.RequestId = params.get("RequestId")
class DescribeResourceScheduleRequest(AbstractModel):
"""DescribeResourceSchedule请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: emr集群的英文id
:type InstanceId: str
"""
self.InstanceId = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DescribeResourceScheduleResponse(AbstractModel):
"""DescribeResourceSchedule返回参数结构体
"""
def __init__(self):
r"""
:param OpenSwitch: 资源调度功能是否开启
:type OpenSwitch: bool
:param Scheduler: 正在使用的资源调度器
:type Scheduler: str
:param FSInfo: 公平调度器的信息
:type FSInfo: str
:param CSInfo: 容量调度器的信息
:type CSInfo: str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.OpenSwitch = None
self.Scheduler = None
self.FSInfo = None
self.CSInfo = None
self.RequestId = None
def _deserialize(self, params):
self.OpenSwitch = params.get("OpenSwitch")
self.Scheduler = params.get("Scheduler")
self.FSInfo = params.get("FSInfo")
self.CSInfo = params.get("CSInfo")
self.RequestId = params.get("RequestId")
class DescribeUsersForUserManagerRequest(AbstractModel):
"""DescribeUsersForUserManager请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 集群实例ID
:type InstanceId: str
:param PageNo: 页码
:type PageNo: int
:param PageSize: 分页的大小
:type PageSize: int
:param UserManagerFilter: 查询用户列表过滤器
:type UserManagerFilter: :class:`tencentcloud.emr.v20190103.models.UserManagerFilter`
:param NeedKeytabInfo: 是否需要keytab文件的信息，仅对开启kerberos的集群有效，默认为false
:type NeedKeytabInfo: bool
"""
self.InstanceId = None
self.PageNo = None
self.PageSize = None
self.UserManagerFilter = None
self.NeedKeytabInfo = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.PageNo = params.get("PageNo")
self.PageSize = params.get("PageSize")
if params.get("UserManagerFilter") is not None:
self.UserManagerFilter = UserManagerFilter()
self.UserManagerFilter._deserialize(params.get("UserManagerFilter"))
self.NeedKeytabInfo = params.get("NeedKeytabInfo")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DescribeUsersForUserManagerResponse(AbstractModel):
"""DescribeUsersForUserManager返回参数结构体
"""
def __init__(self):
r"""
:param TotalCnt: 总数
:type TotalCnt: int
:param UserManagerUserList: 用户信息列表
注意：此字段可能返回 null，表示取不到有效值。
:type UserManagerUserList: list of UserManagerUserBriefInfo
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.TotalCnt = None
self.UserManagerUserList = None
self.RequestId = None
def _deserialize(self, params):
self.TotalCnt = params.get("TotalCnt")
if params.get("UserManagerUserList") is not None:
self.UserManagerUserList = []
for item in params.get("UserManagerUserList"):
obj = UserManagerUserBriefInfo()
obj._deserialize(item)
self.UserManagerUserList.append(obj)
self.RequestId = params.get("RequestId")
class DiskGroup(AbstractModel):
"""磁盘组。
"""
def __init__(self):
r"""
:param Spec: 磁盘规格。
:type Spec: :class:`tencentcloud.emr.v20190103.models.DiskSpec`
:param Count: 同类型磁盘数量。
:type Count: int
"""
self.Spec = None
self.Count = None
def _deserialize(self, params):
if params.get("Spec") is not None:
self.Spec = DiskSpec()
self.Spec._deserialize(params.get("Spec"))
self.Count = params.get("Count")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DiskSpec(AbstractModel):
"""磁盘描述。
"""
def __init__(self):
r"""
:param DiskType: 磁盘类型。
LOCAL_BASIC 本地盘。
CLOUD_BASIC 云硬盘。
LOCAL_SSD 本地SSD。
CLOUD_SSD 云SSD。
CLOUD_PREMIUM 高效云盘。
CLOUD_HSSD 增强型云SSD。
:type DiskType: str
:param DiskSize: 磁盘大小，单位GB。
:type DiskSize: int
"""
self.DiskType = None
self.DiskSize = None
def _deserialize(self, params):
self.DiskType = params.get("DiskType")
self.DiskSize = params.get("DiskSize")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DiskSpecInfo(AbstractModel):
"""节点磁盘信息
"""
def __init__(self):
r"""
:param Count: 磁盘数量
注意：此字段可能返回 null，表示取不到有效值。
:type Count: int
:param DiskType: 系统盘类型 取值范围：
CLOUD_SSD：表示云SSD。
CLOUD_PREMIUM：表示高效云盘。
CLOUD_BASIC：表示云硬盘。
LOCAL_BASIC：表示本地盘。
LOCAL_SSD：表示本地SSD。
数据盘类型 取值范围：
CLOUD_SSD：表示云SSD。
CLOUD_PREMIUM：表示高效云盘。
CLOUD_BASIC：表示云硬盘。
LOCAL_BASIC：表示本地盘。
LOCAL_SSD：表示本地SSD。
CLOUD_HSSD：表示增强型SSD云硬盘。
CLOUD_THROUGHPUT：表示吞吐型云硬盘。
CLOUD_TSSD：表示极速型SSD云硬盘。
注意：此字段可能返回 null，表示取不到有效值。
:type DiskType: str
:param DiskSize: 数据容量，单位为GB
注意：此字段可能返回 null，表示取不到有效值。
:type DiskSize: int
"""
self.Count = None
self.DiskType = None
self.DiskSize = None
def _deserialize(self, params):
self.Count = params.get("Count")
self.DiskType = params.get("DiskType")
self.DiskSize = params.get("DiskSize")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class DynamicPodSpec(AbstractModel):
"""POD浮动规格
"""
def __init__(self):
r"""
:param RequestCpu: 需求最小cpu核数
:type RequestCpu: float
:param LimitCpu: 需求最大cpu核数
:type LimitCpu: float
:param RequestMemory: 需求最小memory，单位MB
:type RequestMemory: float
:param LimitMemory: 需求最大memory，单位MB
:type LimitMemory: float
"""
self.RequestCpu = None
self.LimitCpu = None
self.RequestMemory = None
self.LimitMemory = None
def _deserialize(self, params):
self.RequestCpu = params.get("RequestCpu")
self.LimitCpu = params.get("LimitCpu")
self.RequestMemory = params.get("RequestMemory")
self.LimitMemory = params.get("LimitMemory")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class EmrListInstance(AbstractModel):
"""集群列表返回示例
"""
def __init__(self):
r"""
:param ClusterId: 集群ID
:type ClusterId: str
:param StatusDesc: 状态描述
注意：此字段可能返回 null，表示取不到有效值。
:type StatusDesc: str
:param ClusterName: 集群名字
:type ClusterName: str
:param ZoneId: 集群地域
:type ZoneId: int
:param AppId: 用户APPID
:type AppId: int
:param AddTime: 创建时间
:type AddTime: str
:param RunTime: 运行时间
:type RunTime: str
:param MasterIp: 集群IP
:type MasterIp: str
:param EmrVersion: 集群版本
:type EmrVersion: str
:param ChargeType: 集群计费类型
:type ChargeType: int
:param Id: emr ID
:type Id: int
:param ProductId: 产品ID
注意：此字段可能返回 null，表示取不到有效值。
:type ProductId: int
:param ProjectId: 项目ID
注意：此字段可能返回 null，表示取不到有效值。
:type ProjectId: int
:param RegionId: 区域
注意：此字段可能返回 null，表示取不到有效值。
:type RegionId: int
:param SubnetId: 子网ID
注意：此字段可能返回 null，表示取不到有效值。
:type SubnetId: int
:param VpcId: 网络ID
注意：此字段可能返回 null，表示取不到有效值。
:type VpcId: int
:param Zone: 地区
注意：此字段可能返回 null，表示取不到有效值。
:type Zone: str
:param Status: 状态码
注意：此字段可能返回 null，表示取不到有效值。
:type Status: int
:param Tags: 实例标签
注意：此字段可能返回 null，表示取不到有效值。
:type Tags: list of Tag
:param AlarmInfo: 告警信息
注意：此字段可能返回 null，表示取不到有效值。
:type AlarmInfo: str
:param IsWoodpeckerCluster: 是否是woodpecker集群
注意：此字段可能返回 null，表示取不到有效值。
:type IsWoodpeckerCluster: int
:param VpcName: Vpc中文
注意：此字段可能返回 null，表示取不到有效值。
:type VpcName: str
:param SubnetName: 子网中文
注意：此字段可能返回 null，表示取不到有效值。
:type SubnetName: str
:param UniqVpcId: 字符串VpcId
注意：此字段可能返回 null，表示取不到有效值。
:type UniqVpcId: str
:param UniqSubnetId: 字符串子网
注意：此字段可能返回 null，表示取不到有效值。
:type UniqSubnetId: str
:param ClusterClass: 集群类型
注意：此字段可能返回 null，表示取不到有效值。
:type ClusterClass: str
:param IsMultiZoneCluster: 是否为跨AZ集群
注意：此字段可能返回 null，表示取不到有效值。
:type IsMultiZoneCluster: bool
:param IsHandsCluster: 是否手戳集群
注意：此字段可能返回 null，表示取不到有效值。
:type IsHandsCluster: bool
:param OutSideSoftInfo: 体外客户端组件信息
注意：此字段可能返回 null，表示取不到有效值。
:type OutSideSoftInfo: list of SoftDependInfo
:param IsSupportOutsideCluster: 当前集群的应用场景是否支持体外客户端
注意：此字段可能返回 null，表示取不到有效值。
:type IsSupportOutsideCluster: bool
"""
self.ClusterId = None
self.StatusDesc = None
self.ClusterName = None
self.ZoneId = None
self.AppId = None
self.AddTime = None
self.RunTime = None
self.MasterIp = None
self.EmrVersion = None
self.ChargeType = None
self.Id = None
self.ProductId = None
self.ProjectId = None
self.RegionId = None
self.SubnetId = None
self.VpcId = None
self.Zone = None
self.Status = None
self.Tags = None
self.AlarmInfo = None
self.IsWoodpeckerCluster = None
self.VpcName = None
self.SubnetName = None
self.UniqVpcId = None
self.UniqSubnetId = None
self.ClusterClass = None
self.IsMultiZoneCluster = None
self.IsHandsCluster = None
self.OutSideSoftInfo = None
self.IsSupportOutsideCluster = None
def _deserialize(self, params):
self.ClusterId = params.get("ClusterId")
self.StatusDesc = params.get("StatusDesc")
self.ClusterName = params.get("ClusterName")
self.ZoneId = params.get("ZoneId")
self.AppId = params.get("AppId")
self.AddTime = params.get("AddTime")
self.RunTime = params.get("RunTime")
self.MasterIp = params.get("MasterIp")
self.EmrVersion = params.get("EmrVersion")
self.ChargeType = params.get("ChargeType")
self.Id = params.get("Id")
self.ProductId = params.get("ProductId")
self.ProjectId = params.get("ProjectId")
self.RegionId = params.get("RegionId")
self.SubnetId = params.get("SubnetId")
self.VpcId = params.get("VpcId")
self.Zone = params.get("Zone")
self.Status = params.get("Status")
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
self.AlarmInfo = params.get("AlarmInfo")
self.IsWoodpeckerCluster = params.get("IsWoodpeckerCluster")
self.VpcName = params.get("VpcName")
self.SubnetName = params.get("SubnetName")
self.UniqVpcId = params.get("UniqVpcId")
self.UniqSubnetId = params.get("UniqSubnetId")
self.ClusterClass = params.get("ClusterClass")
self.IsMultiZoneCluster = params.get("IsMultiZoneCluster")
self.IsHandsCluster = params.get("IsHandsCluster")
if params.get("OutSideSoftInfo") is not None:
self.OutSideSoftInfo = []
for item in params.get("OutSideSoftInfo"):
obj = SoftDependInfo()
obj._deserialize(item)
self.OutSideSoftInfo.append(obj)
self.IsSupportOutsideCluster = params.get("IsSupportOutsideCluster")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class EmrPrice(AbstractModel):
"""Emr询价描述
"""
def __init__(self):
r"""
:param OriginalCost: 刊例价格
注意：此字段可能返回 null，表示取不到有效值。
:type OriginalCost: str
:param DiscountCost: 折扣价格
注意：此字段可能返回 null，表示取不到有效值。
:type DiscountCost: str
:param Unit: 单位
注意：此字段可能返回 null，表示取不到有效值。
:type Unit: str
:param PriceSpec: 询价配置
注意：此字段可能返回 null，表示取不到有效值。
:type PriceSpec: :class:`tencentcloud.emr.v20190103.models.PriceResource`
:param SupportSpotPaid: 是否支持竞价实例
注意：此字段可能返回 null，表示取不到有效值。
:type SupportSpotPaid: bool
"""
self.OriginalCost = None
self.DiscountCost = None
self.Unit = None
self.PriceSpec = None
self.SupportSpotPaid = None
def _deserialize(self, params):
self.OriginalCost = params.get("OriginalCost")
self.DiscountCost = params.get("DiscountCost")
self.Unit = params.get("Unit")
if params.get("PriceSpec") is not None:
self.PriceSpec = PriceResource()
self.PriceSpec._deserialize(params.get("PriceSpec"))
self.SupportSpotPaid = params.get("SupportSpotPaid")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class EmrProductConfigOutter(AbstractModel):
"""EMR产品配置
"""
def __init__(self):
r"""
:param SoftInfo: 软件信息
注意：此字段可能返回 null，表示取不到有效值。
:type SoftInfo: list of str
:param MasterNodeSize: Master节点个数
注意：此字段可能返回 null，表示取不到有效值。
:type MasterNodeSize: int
:param CoreNodeSize: Core节点个数
注意：此字段可能返回 null，表示取不到有效值。
:type CoreNodeSize: int
:param TaskNodeSize: Task节点个数
注意：此字段可能返回 null，表示取不到有效值。
:type TaskNodeSize: int
:param ComNodeSize: Common节点个数
注意：此字段可能返回 null，表示取不到有效值。
:type ComNodeSize: int
:param MasterResource: Master节点资源
注意：此字段可能返回 null，表示取不到有效值。
:type MasterResource: :class:`tencentcloud.emr.v20190103.models.OutterResource`
:param CoreResource: Core节点资源
注意：此字段可能返回 null，表示取不到有效值。
:type CoreResource: :class:`tencentcloud.emr.v20190103.models.OutterResource`
:param TaskResource: Task节点资源
注意：此字段可能返回 null，表示取不到有效值。
:type TaskResource: :class:`tencentcloud.emr.v20190103.models.OutterResource`
:param ComResource: Common节点资源
注意：此字段可能返回 null，表示取不到有效值。
:type ComResource: :class:`tencentcloud.emr.v20190103.models.OutterResource`
:param OnCos: 是否使用COS
注意：此字段可能返回 null，表示取不到有效值。
:type OnCos: bool
:param ChargeType: 收费类型
注意：此字段可能返回 null，表示取不到有效值。
:type ChargeType: int
:param RouterNodeSize: Router节点个数
注意：此字段可能返回 null，表示取不到有效值。
:type RouterNodeSize: int
:param SupportHA: 是否支持HA
注意：此字段可能返回 null，表示取不到有效值。
:type SupportHA: bool
:param SecurityOn: 是否支持安全模式
注意：此字段可能返回 null，表示取不到有效值。
:type SecurityOn: bool
:param SecurityGroup: 安全组名称
注意：此字段可能返回 null，表示取不到有效值。
:type SecurityGroup: str
:param CbsEncrypt: 是否开启Cbs加密
注意：此字段可能返回 null，表示取不到有效值。
:type CbsEncrypt: int
:param ApplicationRole: 自定义应用角色。
注意：此字段可能返回 null，表示取不到有效值。
:type ApplicationRole: str
:param SecurityGroups: 安全组
注意：此字段可能返回 null，表示取不到有效值。
:type SecurityGroups: list of str
:param PublicKeyId: SSH密钥Id
注意：此字段可能返回 null，表示取不到有效值。
:type PublicKeyId: str
"""
self.SoftInfo = None
self.MasterNodeSize = None
self.CoreNodeSize = None
self.TaskNodeSize = None
self.ComNodeSize = None
self.MasterResource = None
self.CoreResource = None
self.TaskResource = None
self.ComResource = None
self.OnCos = None
self.ChargeType = None
self.RouterNodeSize = None
self.SupportHA = None
self.SecurityOn = None
self.SecurityGroup = None
self.CbsEncrypt = None
self.ApplicationRole = None
self.SecurityGroups = None
self.PublicKeyId = None
def _deserialize(self, params):
self.SoftInfo = params.get("SoftInfo")
self.MasterNodeSize = params.get("MasterNodeSize")
self.CoreNodeSize = params.get("CoreNodeSize")
self.TaskNodeSize = params.get("TaskNodeSize")
self.ComNodeSize = params.get("ComNodeSize")
if params.get("MasterResource") is not None:
self.MasterResource = OutterResource()
self.MasterResource._deserialize(params.get("MasterResource"))
if params.get("CoreResource") is not None:
self.CoreResource = OutterResource()
self.CoreResource._deserialize(params.get("CoreResource"))
if params.get("TaskResource") is not None:
self.TaskResource = OutterResource()
self.TaskResource._deserialize(params.get("TaskResource"))
if params.get("ComResource") is not None:
self.ComResource = OutterResource()
self.ComResource._deserialize(params.get("ComResource"))
self.OnCos = params.get("OnCos")
self.ChargeType = params.get("ChargeType")
self.RouterNodeSize = params.get("RouterNodeSize")
self.SupportHA = params.get("SupportHA")
self.SecurityOn = params.get("SecurityOn")
self.SecurityGroup = params.get("SecurityGroup")
self.CbsEncrypt = params.get("CbsEncrypt")
self.ApplicationRole = params.get("ApplicationRole")
self.SecurityGroups = params.get("SecurityGroups")
self.PublicKeyId = params.get("PublicKeyId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class Execution(AbstractModel):
"""执行动作。
"""
def __init__(self):
r"""
:param JobType: 任务类型，目前支持以下类型。
1. “MR”，将通过hadoop jar的方式提交。
2. "HIVE"，将通过hive -f的方式提交。
3. "SPARK"，将通过spark-submit的方式提交。
:type JobType: str
:param Args: 任务参数，提供除提交指令以外的参数。
:type Args: list of str
"""
self.JobType = None
self.Args = None
def _deserialize(self, params):
self.JobType = params.get("JobType")
self.Args = params.get("Args")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ExternalService(AbstractModel):
"""共用组件信息
"""
def __init__(self):
r"""
:param ShareType: 共用组件类型，EMR/CUSTOM
:type ShareType: str
:param CustomServiceDefineList: 自定义参数集合
:type CustomServiceDefineList: list of CustomServiceDefine
:param Service: 共用组件名
:type Service: str
:param InstanceId: 共用组件集群
:type InstanceId: str
"""
self.ShareType = None
self.CustomServiceDefineList = None
self.Service = None
self.InstanceId = None
def _deserialize(self, params):
self.ShareType = params.get("ShareType")
if params.get("CustomServiceDefineList") is not None:
self.CustomServiceDefineList = []
for item in params.get("CustomServiceDefineList"):
obj = CustomServiceDefine()
obj._deserialize(item)
self.CustomServiceDefineList.append(obj)
self.Service = params.get("Service")
self.InstanceId = params.get("InstanceId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class Filters(AbstractModel):
"""Emr集群列表实例自定义查询过滤
"""
def __init__(self):
r"""
:param Name: 字段名称
:type Name: str
:param Values: 过滤字段值
:type Values: list of str
"""
self.Name = None
self.Values = None
def _deserialize(self, params):
self.Name = params.get("Name")
self.Values = params.get("Values")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class HostVolumeContext(AbstractModel):
"""Pod HostPath挂载方式描述
"""
def __init__(self):
r"""
:param VolumePath: Pod挂载宿主机的目录。资源对宿主机的挂载点，指定的挂载点对应了宿主机的路径，该挂载点在Pod中作为数据存储目录使用
注意：此字段可能返回 null，表示取不到有效值。
:type VolumePath: str
"""
self.VolumePath = None
def _deserialize(self, params):
self.VolumePath = params.get("VolumePath")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class InquirePriceRenewEmrRequest(AbstractModel):
"""InquirePriceRenewEmr请求参数结构体
"""
def __init__(self):
r"""
:param TimeSpan: 实例续费的时长。需要结合TimeUnit一起使用。1表示续费1一个月
:type TimeSpan: int
:param InstanceId: 待续费集群ID列表。
:type InstanceId: str
:param Placement: 实例所在的位置。通过该参数可以指定实例所属可用区，所属项目等属性。
:type Placement: :class:`tencentcloud.emr.v20190103.models.Placement`
:param PayMode: 实例计费模式。此处只支持取值为1，表示包年包月。
:type PayMode: int
:param TimeUnit: 实例续费的时间单位。取值范围：
m：表示月份。
:type TimeUnit: str
:param Currency: 货币种类。取值范围：
CNY：表示人民币。
:type Currency: str
"""
self.TimeSpan = None
self.InstanceId = None
self.Placement = None
self.PayMode = None
self.TimeUnit = None
self.Currency = None
def _deserialize(self, params):
self.TimeSpan = params.get("TimeSpan")
self.InstanceId = params.get("InstanceId")
if params.get("Placement") is not None:
self.Placement = Placement()
self.Placement._deserialize(params.get("Placement"))
self.PayMode = params.get("PayMode")
self.TimeUnit = params.get("TimeUnit")
self.Currency = params.get("Currency")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class InquirePriceRenewEmrResponse(AbstractModel):
"""InquirePriceRenewEmr返回参数结构体
"""
def __init__(self):
r"""
:param OriginalCost: 原价，单位为元。
注意：此字段可能返回 null，表示取不到有效值。
:type OriginalCost: float
:param DiscountCost: 折扣价，单位为元。
注意：此字段可能返回 null，表示取不到有效值。
:type DiscountCost: float
:param TimeUnit: 实例续费的时间单位。取值范围：
m：表示月份。
注意：此字段可能返回 null，表示取不到有效值。
:type TimeUnit: str
:param TimeSpan: 实例续费的时长。
注意：此字段可能返回 null，表示取不到有效值。
:type TimeSpan: int
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.OriginalCost = None
self.DiscountCost = None
self.TimeUnit = None
self.TimeSpan = None
self.RequestId = None
def _deserialize(self, params):
self.OriginalCost = params.get("OriginalCost")
self.DiscountCost = params.get("DiscountCost")
self.TimeUnit = params.get("TimeUnit")
self.TimeSpan = params.get("TimeSpan")
self.RequestId = params.get("RequestId")
class InquiryPriceCreateInstanceRequest(AbstractModel):
"""InquiryPriceCreateInstance请求参数结构体
"""
def __init__(self):
r"""
:param TimeUnit: 购买实例的时间单位。取值范围：
s：表示秒。PayMode取值为0时，TimeUnit只能取值为s。
m：表示月份。PayMode取值为1时，TimeUnit只能取值为m。
:type TimeUnit: str
:param TimeSpan: 购买实例的时长。结合TimeUnit一起使用。
TimeUnit为s时，该参数只能填写3600，表示按量计费实例。
TimeUnit为m时，该参数填写的数字表示包年包月实例的购买时长，如1表示购买一个月
:type TimeSpan: int
:param Currency: 货币种类。取值范围：
CNY：表示人民币。
:type Currency: str
:param PayMode: 实例计费模式。取值范围：
0：表示按量计费。
1：表示包年包月。
:type PayMode: int
:param SupportHA: 是否开启节点高可用。取值范围：
0：表示不开启节点高可用。
1：表示开启节点高可用。
:type SupportHA: int
:param Software: 部署的组件列表。不同的EMR产品ID（ProductId：具体含义参考入参ProductId字段）需要选择不同的必选组件：
ProductId为1的时候，必选组件包括：hadoop-2.7.3、knox-1.2.0、zookeeper-3.4.9
ProductId为2的时候，必选组件包括：hadoop-2.7.3、knox-1.2.0、zookeeper-3.4.9
ProductId为4的时候，必选组件包括：hadoop-2.8.4、knox-1.2.0、zookeeper-3.4.9
ProductId为7的时候，必选组件包括：hadoop-3.1.2、knox-1.2.0、zookeeper-3.4.9
:type Software: list of str
:param ResourceSpec: 询价的节点规格。
:type ResourceSpec: :class:`tencentcloud.emr.v20190103.models.NewResourceSpec`
:param Placement: 实例所在的位置。通过该参数可以指定实例所属可用区，所属项目等属性。
:type Placement: :class:`tencentcloud.emr.v20190103.models.Placement`
:param VPCSettings: 私有网络相关信息配置。通过该参数可以指定私有网络的ID，子网ID等信息。
:type VPCSettings: :class:`tencentcloud.emr.v20190103.models.VPCSettings`
:param MetaType: hive共享元数据库类型。取值范围：
EMR_NEW_META：表示集群默认创建
EMR_EXIT_METE：表示集群使用指定EMR-MetaDB。
USER_CUSTOM_META：表示集群使用自定义MetaDB。
:type MetaType: str
:param UnifyMetaInstanceId: EMR-MetaDB实例
:type UnifyMetaInstanceId: str
:param MetaDBInfo: 自定义MetaDB信息
:type MetaDBInfo: :class:`tencentcloud.emr.v20190103.models.CustomMetaInfo`
:param ProductId: 产品ID，不同产品ID表示不同的EMR产品版本。取值范围：
1：表示EMR-V1.3.1。
2：表示EMR-V2.0.1。
4：表示EMR-V2.1.0。
7：表示EMR-V3.0.0。
:type ProductId: int
:param SceneName: 场景化取值：
Hadoop-Kudu
Hadoop-Zookeeper
Hadoop-Presto
Hadoop-Hbase
:type SceneName: str
:param ExternalService: 共用组件信息
:type ExternalService: list of ExternalService
:param VersionID: 当前默认值为0，跨AZ特性支持后为1
:type VersionID: int
:param MultiZoneSettings: 可用区的规格信息
:type MultiZoneSettings: list of MultiZoneSetting
"""
self.TimeUnit = None
self.TimeSpan = None
self.Currency = None
self.PayMode = None
self.SupportHA = None
self.Software = None
self.ResourceSpec = None
self.Placement = None
self.VPCSettings = None
self.MetaType = None
self.UnifyMetaInstanceId = None
self.MetaDBInfo = None
self.ProductId = None
self.SceneName = None
self.ExternalService = None
self.VersionID = None
self.MultiZoneSettings = None
def _deserialize(self, params):
self.TimeUnit = params.get("TimeUnit")
self.TimeSpan = params.get("TimeSpan")
self.Currency = params.get("Currency")
self.PayMode = params.get("PayMode")
self.SupportHA = params.get("SupportHA")
self.Software = params.get("Software")
if params.get("ResourceSpec") is not None:
self.ResourceSpec = NewResourceSpec()
self.ResourceSpec._deserialize(params.get("ResourceSpec"))
if params.get("Placement") is not None:
self.Placement = Placement()
self.Placement._deserialize(params.get("Placement"))
if params.get("VPCSettings") is not None:
self.VPCSettings = VPCSettings()
self.VPCSettings._deserialize(params.get("VPCSettings"))
self.MetaType = params.get("MetaType")
self.UnifyMetaInstanceId = params.get("UnifyMetaInstanceId")
if params.get("MetaDBInfo") is not None:
self.MetaDBInfo = CustomMetaInfo()
self.MetaDBInfo._deserialize(params.get("MetaDBInfo"))
self.ProductId = params.get("ProductId")
self.SceneName = params.get("SceneName")
if params.get("ExternalService") is not None:
self.ExternalService = []
for item in params.get("ExternalService"):
obj = ExternalService()
obj._deserialize(item)
self.ExternalService.append(obj)
self.VersionID = params.get("VersionID")
if params.get("MultiZoneSettings") is not None:
self.MultiZoneSettings = []
for item in params.get("MultiZoneSettings"):
obj = MultiZoneSetting()
obj._deserialize(item)
self.MultiZoneSettings.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class InquiryPriceCreateInstanceResponse(AbstractModel):
"""InquiryPriceCreateInstance返回参数结构体
"""
def __init__(self):
r"""
:param OriginalCost: 原价，单位为元。
注意：此字段可能返回 null，表示取不到有效值。
:type OriginalCost: float
:param DiscountCost: 折扣价，单位为元。
注意：此字段可能返回 null，表示取不到有效值。
:type DiscountCost: float
:param TimeUnit: 购买实例的时间单位。取值范围：
s：表示秒。
m：表示月份。
注意：此字段可能返回 null，表示取不到有效值。
:type TimeUnit: str
:param TimeSpan: 购买实例的时长。
注意：此字段可能返回 null，表示取不到有效值。
:type TimeSpan: int
:param PriceList: 价格清单
注意：此字段可能返回 null，表示取不到有效值。
:type PriceList: list of ZoneDetailPriceResult
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.OriginalCost = None
self.DiscountCost = None
self.TimeUnit = None
self.TimeSpan = None
self.PriceList = None
self.RequestId = None
def _deserialize(self, params):
self.OriginalCost = params.get("OriginalCost")
self.DiscountCost = params.get("DiscountCost")
self.TimeUnit = params.get("TimeUnit")
self.TimeSpan = params.get("TimeSpan")
if params.get("PriceList") is not None:
self.PriceList = []
for item in params.get("PriceList"):
obj = ZoneDetailPriceResult()
obj._deserialize(item)
self.PriceList.append(obj)
self.RequestId = params.get("RequestId")
class InquiryPriceRenewInstanceRequest(AbstractModel):
"""InquiryPriceRenewInstance请求参数结构体
"""
def __init__(self):
r"""
:param TimeSpan: 实例续费的时长。需要结合TimeUnit一起使用。1表示续费1一个月
:type TimeSpan: int
:param ResourceIds: 待续费节点的资源ID列表。资源ID形如：emr-vm-xxxxxxxx。有效的资源ID可通过登录[控制台](https://console.cloud.tencent.com/emr/static/hardware)查询。
:type ResourceIds: list of str
:param Placement: 实例所在的位置。通过该参数可以指定实例所属可用区，所属项目等属性。
:type Placement: :class:`tencentcloud.emr.v20190103.models.Placement`
:param PayMode: 实例计费模式。此处只支持取值为1，表示包年包月。
:type PayMode: int
:param TimeUnit: 实例续费的时间单位。取值范围：
m：表示月份。
:type TimeUnit: str
:param Currency: 货币种类。取值范围：
CNY：表示人民币。
:type Currency: str
:param ModifyPayMode: 是否按量转包年包月。0：否，1：是。
:type ModifyPayMode: int
"""
self.TimeSpan = None
self.ResourceIds = None
self.Placement = None
self.PayMode = None
self.TimeUnit = None
self.Currency = None
self.ModifyPayMode = None
def _deserialize(self, params):
self.TimeSpan = params.get("TimeSpan")
self.ResourceIds = params.get("ResourceIds")
if params.get("Placement") is not None:
self.Placement = Placement()
self.Placement._deserialize(params.get("Placement"))
self.PayMode = params.get("PayMode")
self.TimeUnit = params.get("TimeUnit")
self.Currency = params.get("Currency")
self.ModifyPayMode = params.get("ModifyPayMode")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class InquiryPriceRenewInstanceResponse(AbstractModel):
"""InquiryPriceRenewInstance返回参数结构体
"""
def __init__(self):
r"""
:param OriginalCost: 原价，单位为元。
注意：此字段可能返回 null，表示取不到有效值。
:type OriginalCost: float
:param DiscountCost: 折扣价，单位为元。
注意：此字段可能返回 null，表示取不到有效值。
:type DiscountCost: float
:param TimeUnit: 实例续费的时间单位。取值范围：
m：表示月份。
注意：此字段可能返回 null，表示取不到有效值。
:type TimeUnit: str
:param TimeSpan: 实例续费的时长。
注意：此字段可能返回 null，表示取不到有效值。
:type TimeSpan: int
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.OriginalCost = None
self.DiscountCost = None
self.TimeUnit = None
self.TimeSpan = None
self.RequestId = None
def _deserialize(self, params):
self.OriginalCost = params.get("OriginalCost")
self.DiscountCost = params.get("DiscountCost")
self.TimeUnit = params.get("TimeUnit")
self.TimeSpan = params.get("TimeSpan")
self.RequestId = params.get("RequestId")
class InquiryPriceScaleOutInstanceRequest(AbstractModel):
"""InquiryPriceScaleOutInstance请求参数结构体
"""
def __init__(self):
r"""
:param TimeUnit: 扩容的时间单位。取值范围：
s：表示秒。PayMode取值为0时，TimeUnit只能取值为s。
m：表示月份。PayMode取值为1时，TimeUnit只能取值为m。
:type TimeUnit: str
:param TimeSpan: 扩容的时长。结合TimeUnit一起使用。
TimeUnit为s时，该参数只能填写3600，表示按量计费实例。
TimeUnit为m时，该参数填写的数字表示包年包月实例的购买时长，如1表示购买一个月
:type TimeSpan: int
:param ZoneId: 实例所属的可用区ID，例如100003。该参数可以通过调用 [DescribeZones](https://cloud.tencent.com/document/api/213/15707) 的返回值中的ZoneId字段来获取。
:type ZoneId: int
:param PayMode: 实例计费模式。取值范围：
0：表示按量计费。
1：表示包年包月。
:type PayMode: int
:param InstanceId: 实例ID。
:type InstanceId: str
:param CoreCount: 扩容的Core节点数量。
:type CoreCount: int
:param TaskCount: 扩容的Task节点数量。
:type TaskCount: int
:param Currency: 货币种类。取值范围：
CNY：表示人民币。
:type Currency: str
:param RouterCount: 扩容的Router节点数量。
:type RouterCount: int
:param MasterCount: 扩容的Master节点数量。
:type MasterCount: int
"""
self.TimeUnit = None
self.TimeSpan = None
self.ZoneId = None
self.PayMode = None
self.InstanceId = None
self.CoreCount = None
self.TaskCount = None
self.Currency = None
self.RouterCount = None
self.MasterCount = None
def _deserialize(self, params):
self.TimeUnit = params.get("TimeUnit")
self.TimeSpan = params.get("TimeSpan")
self.ZoneId = params.get("ZoneId")
self.PayMode = params.get("PayMode")
self.InstanceId = params.get("InstanceId")
self.CoreCount = params.get("CoreCount")
self.TaskCount = params.get("TaskCount")
self.Currency = params.get("Currency")
self.RouterCount = params.get("RouterCount")
self.MasterCount = params.get("MasterCount")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class InquiryPriceScaleOutInstanceResponse(AbstractModel):
"""InquiryPriceScaleOutInstance返回参数结构体
"""
def __init__(self):
r"""
:param OriginalCost: 原价，单位为元。
注意：此字段可能返回 null，表示取不到有效值。
:type OriginalCost: str
:param DiscountCost: 折扣价，单位为元。
注意：此字段可能返回 null，表示取不到有效值。
:type DiscountCost: str
:param Unit: 扩容的时间单位。取值范围：
s：表示秒。
m：表示月份。
注意：此字段可能返回 null，表示取不到有效值。
:type Unit: str
:param PriceSpec: 询价的节点规格。
注意：此字段可能返回 null，表示取不到有效值。
:type PriceSpec: :class:`tencentcloud.emr.v20190103.models.PriceResource`
:param MultipleEmrPrice: 对应入参MultipleResources中多个规格的询价结果，其它出参返回的是第一个规格的询价结果
注意：此字段可能返回 null，表示取不到有效值。
:type MultipleEmrPrice: list of EmrPrice
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.OriginalCost = None
self.DiscountCost = None
self.Unit = None
self.PriceSpec = None
self.MultipleEmrPrice = None
self.RequestId = None
def _deserialize(self, params):
self.OriginalCost = params.get("OriginalCost")
self.DiscountCost = params.get("DiscountCost")
self.Unit = params.get("Unit")
if params.get("PriceSpec") is not None:
self.PriceSpec = PriceResource()
self.PriceSpec._deserialize(params.get("PriceSpec"))
if params.get("MultipleEmrPrice") is not None:
self.MultipleEmrPrice = []
for item in params.get("MultipleEmrPrice"):
obj = EmrPrice()
obj._deserialize(item)
self.MultipleEmrPrice.append(obj)
self.RequestId = params.get("RequestId")
class InquiryPriceUpdateInstanceRequest(AbstractModel):
"""InquiryPriceUpdateInstance请求参数结构体
"""
def __init__(self):
r"""
:param TimeUnit: 变配的时间单位。取值范围：
s：表示秒。PayMode取值为0时，TimeUnit只能取值为s。
m：表示月份。PayMode取值为1时，TimeUnit只能取值为m。
:type TimeUnit: str
:param TimeSpan: 变配的时长。结合TimeUnit一起使用。
TimeUnit为s时，该参数只能填写3600，表示按量计费实例。
TimeUnit为m时，该参数填写的数字表示包年包月实例的购买时长，如1表示购买一个月
:type TimeSpan: int
:param UpdateSpec: 节点变配的目标配置。
:type UpdateSpec: :class:`tencentcloud.emr.v20190103.models.UpdateInstanceSettings`
:param PayMode: 实例计费模式。取值范围：
0：表示按量计费。
1：表示包年包月。
:type PayMode: int
:param Placement: 实例所在的位置。通过该参数可以指定实例所属可用区，所属项目等属性。
:type Placement: :class:`tencentcloud.emr.v20190103.models.Placement`
:param Currency: 货币种类。取值范围：
CNY：表示人民币。
:type Currency: str
:param ResourceIdList: 批量变配资源ID列表
:type ResourceIdList: list of str
"""
self.TimeUnit = None
self.TimeSpan = None
self.UpdateSpec = None
self.PayMode = None
self.Placement = None
self.Currency = None
self.ResourceIdList = None
def _deserialize(self, params):
self.TimeUnit = params.get("TimeUnit")
self.TimeSpan = params.get("TimeSpan")
if params.get("UpdateSpec") is not None:
self.UpdateSpec = UpdateInstanceSettings()
self.UpdateSpec._deserialize(params.get("UpdateSpec"))
self.PayMode = params.get("PayMode")
if params.get("Placement") is not None:
self.Placement = Placement()
self.Placement._deserialize(params.get("Placement"))
self.Currency = params.get("Currency")
self.ResourceIdList = params.get("ResourceIdList")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class InquiryPriceUpdateInstanceResponse(AbstractModel):
"""InquiryPriceUpdateInstance返回参数结构体
"""
def __init__(self):
r"""
:param OriginalCost: 原价，单位为元。
注意：此字段可能返回 null，表示取不到有效值。
:type OriginalCost: float
:param DiscountCost: 折扣价，单位为元。
注意：此字段可能返回 null，表示取不到有效值。
:type DiscountCost: float
:param TimeUnit: 变配的时间单位。取值范围：
s：表示秒。
m：表示月份。
注意：此字段可能返回 null，表示取不到有效值。
:type TimeUnit: str
:param TimeSpan: 变配的时长。
注意：此字段可能返回 null，表示取不到有效值。
:type TimeSpan: int
:param PriceDetail: 价格详情
注意：此字段可能返回 null，表示取不到有效值。
:type PriceDetail: list of PriceDetail
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.OriginalCost = None
self.DiscountCost = None
self.TimeUnit = None
self.TimeSpan = None
self.PriceDetail = None
self.RequestId = None
def _deserialize(self, params):
self.OriginalCost = params.get("OriginalCost")
self.DiscountCost = params.get("DiscountCost")
self.TimeUnit = params.get("TimeUnit")
self.TimeSpan = params.get("TimeSpan")
if params.get("PriceDetail") is not None:
self.PriceDetail = []
for item in params.get("PriceDetail"):
obj = PriceDetail()
obj._deserialize(item)
self.PriceDetail.append(obj)
self.RequestId = params.get("RequestId")
class InstanceChargePrepaid(AbstractModel):
"""实例预付费参数，只有在付费类型为PREPAID时生效。
"""
def __init__(self):
r"""
:param Period: 包年包月时间，默认为1，单位：月。
取值范围：1, 2, 3, 4, 5, 6, 7, 8, 9, 10,11, 12, 24, 36, 48, 60。
:type Period: int
:param RenewFlag: 是否自动续费，默认为否。
true：是
false：否
:type RenewFlag: bool
"""
self.Period = None
self.RenewFlag = None
def _deserialize(self, params):
self.Period = params.get("Period")
self.RenewFlag = params.get("RenewFlag")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class JobFlowResource(AbstractModel):
"""机器资源描述。
"""
def __init__(self):
r"""
:param Spec: 机器类型描述。
:type Spec: str
:param InstanceType: 机器类型描述，可参考CVM的该含义。
:type InstanceType: str
:param Tags: 标签KV对。
:type Tags: list of Tag
:param DiskGroups: 磁盘描述列表。
:type DiskGroups: list of DiskGroup
"""
self.Spec = None
self.InstanceType = None
self.Tags = None
self.DiskGroups = None
def _deserialize(self, params):
self.Spec = params.get("Spec")
self.InstanceType = params.get("InstanceType")
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
if params.get("DiskGroups") is not None:
self.DiskGroups = []
for item in params.get("DiskGroups"):
obj = DiskGroup()
obj._deserialize(item)
self.DiskGroups.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class JobFlowResourceSpec(AbstractModel):
"""流程作业资源描述
"""
def __init__(self):
r"""
:param MasterCount: 主节点数量。
:type MasterCount: int
:param MasterResourceSpec: 主节点配置。
:type MasterResourceSpec: :class:`tencentcloud.emr.v20190103.models.JobFlowResource`
:param CoreCount: Core节点数量
:type CoreCount: int
:param CoreResourceSpec: Core节点配置。
:type CoreResourceSpec: :class:`tencentcloud.emr.v20190103.models.JobFlowResource`
:param TaskCount: Task节点数量。
:type TaskCount: int
:param CommonCount: Common节点数量。
:type CommonCount: int
:param TaskResourceSpec: Task节点配置。
:type TaskResourceSpec: :class:`tencentcloud.emr.v20190103.models.JobFlowResource`
:param CommonResourceSpec: Common节点配置。
:type CommonResourceSpec: :class:`tencentcloud.emr.v20190103.models.JobFlowResource`
"""
self.MasterCount = None
self.MasterResourceSpec = None
self.CoreCount = None
self.CoreResourceSpec = None
self.TaskCount = None
self.CommonCount = None
self.TaskResourceSpec = None
self.CommonResourceSpec = None
def _deserialize(self, params):
self.MasterCount = params.get("MasterCount")
if params.get("MasterResourceSpec") is not None:
self.MasterResourceSpec = JobFlowResource()
self.MasterResourceSpec._deserialize(params.get("MasterResourceSpec"))
self.CoreCount = params.get("CoreCount")
if params.get("CoreResourceSpec") is not None:
self.CoreResourceSpec = JobFlowResource()
self.CoreResourceSpec._deserialize(params.get("CoreResourceSpec"))
self.TaskCount = params.get("TaskCount")
self.CommonCount = params.get("CommonCount")
if params.get("TaskResourceSpec") is not None:
self.TaskResourceSpec = JobFlowResource()
self.TaskResourceSpec._deserialize(params.get("TaskResourceSpec"))
if params.get("CommonResourceSpec") is not None:
self.CommonResourceSpec = JobFlowResource()
self.CommonResourceSpec._deserialize(params.get("CommonResourceSpec"))
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class JobResult(AbstractModel):
"""任务步骤结果描述
"""
def __init__(self):
r"""
:param Name: 任务步骤名称。
注意：此字段可能返回 null，表示取不到有效值。
:type Name: str
:param ActionOnFailure: 任务步骤失败时的处理策略，可以为以下值：
"CONTINUE"，跳过当前失败步骤，继续后续步骤。
“TERMINATE_CLUSTER”，终止当前及后续步骤，并销毁集群。
“CANCEL_AND_WAIT”，取消当前步骤并阻塞等待处理。
注意：此字段可能返回 null，表示取不到有效值。
:type ActionOnFailure: str
:param JobState: 当前步骤的状态，可以为以下值：
“JobFlowStepStatusInit”，初始化状态，等待执行。
“JobFlowStepStatusRunning”，任务步骤正在执行。
“JobFlowStepStatusFailed”，任务步骤执行失败。
“JobFlowStepStatusSucceed”，任务步骤执行成功。
注意：此字段可能返回 null，表示取不到有效值。
:type JobState: str
:param ApplicationId: YARN任务ID
注意：此字段可能返回 null，表示取不到有效值。
:type ApplicationId: str
"""
self.Name = None
self.ActionOnFailure = None
self.JobState = None
self.ApplicationId = None
def _deserialize(self, params):
self.Name = params.get("Name")
self.ActionOnFailure = params.get("ActionOnFailure")
self.JobState = params.get("JobState")
self.ApplicationId = params.get("ApplicationId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class LoginSettings(AbstractModel):
"""登录设置
"""
def __init__(self):
r"""
:param Password: 实例登录密码，8-16个字符，包含大写字母、小写字母、数字和特殊字符四种，特殊符号仅支持!@%^*，密码第一位不能为特殊字符
:type Password: str
:param PublicKeyId: 密钥ID。关联密钥后，就可以通过对应的私钥来访问实例；PublicKeyId可通过接口[DescribeKeyPairs](https://cloud.tencent.com/document/api/213/15699)获取
:type PublicKeyId: str
"""
self.Password = None
self.PublicKeyId = None
def _deserialize(self, params):
self.Password = params.get("Password")
self.PublicKeyId = params.get("PublicKeyId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class MetaDbInfo(AbstractModel):
"""元数据库信息
"""
def __init__(self):
r"""
:param MetaType: 元数据类型。
:type MetaType: str
:param UnifyMetaInstanceId: 统一元数据库实例ID。
:type UnifyMetaInstanceId: str
:param MetaDBInfo: 自建元数据库信息。
:type MetaDBInfo: :class:`tencentcloud.emr.v20190103.models.CustomMetaInfo`
"""
self.MetaType = None
self.UnifyMetaInstanceId = None
self.MetaDBInfo = None
def _deserialize(self, params):
self.MetaType = params.get("MetaType")
self.UnifyMetaInstanceId = params.get("UnifyMetaInstanceId")
if params.get("MetaDBInfo") is not None:
self.MetaDBInfo = CustomMetaInfo()
self.MetaDBInfo._deserialize(params.get("MetaDBInfo"))
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ModifyResourcePoolsRequest(AbstractModel):
"""ModifyResourcePools请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: emr集群id
:type InstanceId: str
:param Key: 取值范围：
fair:代表公平调度标识
capacity:代表容量调度标识
:type Key: str
"""
self.InstanceId = None
self.Key = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.Key = params.get("Key")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ModifyResourcePoolsResponse(AbstractModel):
"""ModifyResourcePools返回参数结构体
"""
def __init__(self):
r"""
:param IsDraft: false表示不是草稿，提交刷新请求成功
:type IsDraft: bool
:param ErrorMsg: 扩展字段，暂时没用
注意：此字段可能返回 null，表示取不到有效值。
:type ErrorMsg: str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.IsDraft = None
self.ErrorMsg = None
self.RequestId = None
def _deserialize(self, params):
self.IsDraft = params.get("IsDraft")
self.ErrorMsg = params.get("ErrorMsg")
self.RequestId = params.get("RequestId")
class ModifyResourceScheduleConfigRequest(AbstractModel):
"""ModifyResourceScheduleConfig请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: emr集群的英文id
:type InstanceId: str
:param Key: 业务标识，fair表示编辑公平的配置项，fairPlan表示编辑执行计划，capacity表示编辑容量的配置项
:type Key: str
:param Value: 修改后的模块消息
:type Value: str
"""
self.InstanceId = None
self.Key = None
self.Value = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.Key = params.get("Key")
self.Value = params.get("Value")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ModifyResourceScheduleConfigResponse(AbstractModel):
"""ModifyResourceScheduleConfig返回参数结构体
"""
def __init__(self):
r"""
:param IsDraft: true为草稿，表示还没有刷新资源池
:type IsDraft: bool
:param ErrorMsg: 校验错误信息，如果不为空，则说明校验失败，配置没有成功
注意：此字段可能返回 null，表示取不到有效值。
:type ErrorMsg: str
:param Data: 返回数据
注意：此字段可能返回 null，表示取不到有效值。
:type Data: str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.IsDraft = None
self.ErrorMsg = None
self.Data = None
self.RequestId = None
def _deserialize(self, params):
self.IsDraft = params.get("IsDraft")
self.ErrorMsg = params.get("ErrorMsg")
self.Data = params.get("Data")
self.RequestId = params.get("RequestId")
class ModifyResourceSchedulerRequest(AbstractModel):
"""ModifyResourceScheduler请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: emr集群的英文id
:type InstanceId: str
:param OldValue: 老的调度器:fair
:type OldValue: str
:param NewValue: 新的调度器:capacity
:type NewValue: str
"""
self.InstanceId = None
self.OldValue = None
self.NewValue = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.OldValue = params.get("OldValue")
self.NewValue = params.get("NewValue")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ModifyResourceSchedulerResponse(AbstractModel):
"""ModifyResourceScheduler返回参数结构体
"""
def __init__(self):
r"""
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.RequestId = None
def _deserialize(self, params):
self.RequestId = params.get("RequestId")
class MultiDisk(AbstractModel):
"""多云盘参数
"""
def __init__(self):
r"""
:param DiskType: 云盘类型
CLOUD_SSD：表示云SSD。
CLOUD_PREMIUM：表示高效云盘。
CLOUD_HSSD：表示增强型SSD云硬盘。
:type DiskType: str
:param Volume: 云盘大小
:type Volume: int
:param Count: 该类型云盘个数
:type Count: int
"""
self.DiskType = None
self.Volume = None
self.Count = None
def _deserialize(self, params):
self.DiskType = params.get("DiskType")
self.Volume = params.get("Volume")
self.Count = params.get("Count")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class MultiDiskMC(AbstractModel):
"""多云盘参数
"""
def __init__(self):
r"""
:param Count: 该类型云盘个数
注意：此字段可能返回 null，表示取不到有效值。
:type Count: int
:param Type: 磁盘类型
注意：此字段可能返回 null，表示取不到有效值。
:type Type: int
:param Volume: 云盘大小
注意：此字段可能返回 null，表示取不到有效值。
:type Volume: int
"""
self.Count = None
self.Type = None
self.Volume = None
def _deserialize(self, params):
self.Count = params.get("Count")
self.Type = params.get("Type")
self.Volume = params.get("Volume")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class MultiZoneSetting(AbstractModel):
"""各个可用区的参数信息
"""
def __init__(self):
r"""
:param ZoneTag: "master"、"standby"、"third-party"
注意：此字段可能返回 null，表示取不到有效值。
:type ZoneTag: str
:param VPCSettings: 无
:type VPCSettings: :class:`tencentcloud.emr.v20190103.models.VPCSettings`
:param Placement: 无
:type Placement: :class:`tencentcloud.emr.v20190103.models.Placement`
:param ResourceSpec: 无
:type ResourceSpec: :class:`tencentcloud.emr.v20190103.models.NewResourceSpec`
"""
self.ZoneTag = None
self.VPCSettings = None
self.Placement = None
self.ResourceSpec = None
def _deserialize(self, params):
self.ZoneTag = params.get("ZoneTag")
if params.get("VPCSettings") is not None:
self.VPCSettings = VPCSettings()
self.VPCSettings._deserialize(params.get("VPCSettings"))
if params.get("Placement") is not None:
self.Placement = Placement()
self.Placement._deserialize(params.get("Placement"))
if params.get("ResourceSpec") is not None:
self.ResourceSpec = NewResourceSpec()
self.ResourceSpec._deserialize(params.get("ResourceSpec"))
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class NewResourceSpec(AbstractModel):
"""资源描述
"""
def __init__(self):
r"""
:param MasterResourceSpec: 描述Master节点资源
:type MasterResourceSpec: :class:`tencentcloud.emr.v20190103.models.Resource`
:param CoreResourceSpec: 描述Core节点资源
:type CoreResourceSpec: :class:`tencentcloud.emr.v20190103.models.Resource`
:param TaskResourceSpec: 描述Task节点资源
:type TaskResourceSpec: :class:`tencentcloud.emr.v20190103.models.Resource`
:param MasterCount: Master节点数量
:type MasterCount: int
:param CoreCount: Core节点数量
:type CoreCount: int
:param TaskCount: Task节点数量
:type TaskCount: int
:param CommonResourceSpec: 描述Common节点资源
:type CommonResourceSpec: :class:`tencentcloud.emr.v20190103.models.Resource`
:param CommonCount: Common节点数量
:type CommonCount: int
"""
self.MasterResourceSpec = None
self.CoreResourceSpec = None
self.TaskResourceSpec = None
self.MasterCount = None
self.CoreCount = None
self.TaskCount = None
self.CommonResourceSpec = None
self.CommonCount = None
def _deserialize(self, params):
if params.get("MasterResourceSpec") is not None:
self.MasterResourceSpec = Resource()
self.MasterResourceSpec._deserialize(params.get("MasterResourceSpec"))
if params.get("CoreResourceSpec") is not None:
self.CoreResourceSpec = Resource()
self.CoreResourceSpec._deserialize(params.get("CoreResourceSpec"))
if params.get("TaskResourceSpec") is not None:
self.TaskResourceSpec = Resource()
self.TaskResourceSpec._deserialize(params.get("TaskResourceSpec"))
self.MasterCount = params.get("MasterCount")
self.CoreCount = params.get("CoreCount")
self.TaskCount = params.get("TaskCount")
if params.get("CommonResourceSpec") is not None:
self.CommonResourceSpec = Resource()
self.CommonResourceSpec._deserialize(params.get("CommonResourceSpec"))
self.CommonCount = params.get("CommonCount")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class NodeDetailPriceResult(AbstractModel):
"""用于创建集群价格清单 节点价格详情
"""
def __init__(self):
r"""
:param NodeType: 节点类型 master core task common router mysql
注意：此字段可能返回 null，表示取不到有效值。
:type NodeType: str
:param PartDetailPrice: 节点组成部分价格详情
:type PartDetailPrice: list of PartDetailPriceItem
"""
self.NodeType = None
self.PartDetailPrice = None
def _deserialize(self, params):
self.NodeType = params.get("NodeType")
if params.get("PartDetailPrice") is not None:
self.PartDetailPrice = []
for item in params.get("PartDetailPrice"):
obj = PartDetailPriceItem()
obj._deserialize(item)
self.PartDetailPrice.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class NodeHardwareInfo(AbstractModel):
"""节点硬件信息
"""
def __init__(self):
r"""
:param AppId: 用户APPID
注意：此字段可能返回 null，表示取不到有效值。
:type AppId: int
:param SerialNo: 序列号
注意：此字段可能返回 null，表示取不到有效值。
:type SerialNo: str
:param OrderNo: 机器实例ID
注意：此字段可能返回 null，表示取不到有效值。
:type OrderNo: str
:param WanIp: master节点绑定外网IP
注意：此字段可能返回 null，表示取不到有效值。
:type WanIp: str
:param Flag: 节点类型。0:common节点；1:master节点
；2:core节点；3:task节点
注意：此字段可能返回 null，表示取不到有效值。
:type Flag: int
:param Spec: 节点规格
注意：此字段可能返回 null，表示取不到有效值。
:type Spec: str
:param CpuNum: 节点核数
注意：此字段可能返回 null，表示取不到有效值。
:type CpuNum: int
:param MemSize: 节点内存
注意：此字段可能返回 null，表示取不到有效值。
:type MemSize: int
:param MemDesc: 节点内存描述
注意：此字段可能返回 null，表示取不到有效值。
:type MemDesc: str
:param RegionId: 节点所在region
注意：此字段可能返回 null，表示取不到有效值。
:type RegionId: int
:param ZoneId: 节点所在Zone
注意：此字段可能返回 null，表示取不到有效值。
:type ZoneId: int
:param ApplyTime: 申请时间
注意：此字段可能返回 null，表示取不到有效值。
:type ApplyTime: str
:param FreeTime: 释放时间
注意：此字段可能返回 null，表示取不到有效值。
:type FreeTime: str
:param DiskSize: 硬盘大小
注意：此字段可能返回 null，表示取不到有效值。
:type DiskSize: str
:param NameTag: 节点描述
注意：此字段可能返回 null，表示取不到有效值。
:type NameTag: str
:param Services: 节点部署服务
注意：此字段可能返回 null，表示取不到有效值。
:type Services: str
:param StorageType: 磁盘类型
注意：此字段可能返回 null，表示取不到有效值。
:type StorageType: int
:param RootSize: 系统盘大小
注意：此字段可能返回 null，表示取不到有效值。
:type RootSize: int
:param ChargeType: 付费类型
注意：此字段可能返回 null，表示取不到有效值。
:type ChargeType: int
:param CdbIp: 数据库IP
注意：此字段可能返回 null，表示取不到有效值。
:type CdbIp: str
:param CdbPort: 数据库端口
注意：此字段可能返回 null，表示取不到有效值。
:type CdbPort: int
:param HwDiskSize: 硬盘容量
注意：此字段可能返回 null，表示取不到有效值。
:type HwDiskSize: int
:param HwDiskSizeDesc: 硬盘容量描述
注意：此字段可能返回 null，表示取不到有效值。
:type HwDiskSizeDesc: str
:param HwMemSize: 内存容量
注意：此字段可能返回 null，表示取不到有效值。
:type HwMemSize: int
:param HwMemSizeDesc: 内存容量描述
注意：此字段可能返回 null，表示取不到有效值。
:type HwMemSizeDesc: str
:param ExpireTime: 过期时间
注意：此字段可能返回 null，表示取不到有效值。
:type ExpireTime: str
:param EmrResourceId: 节点资源ID
注意：此字段可能返回 null，表示取不到有效值。
:type EmrResourceId: str
:param IsAutoRenew: 续费标志
注意：此字段可能返回 null，表示取不到有效值。
:type IsAutoRenew: int
:param DeviceClass: 设备标识
注意：此字段可能返回 null，表示取不到有效值。
:type DeviceClass: str
:param Mutable: 支持变配
注意：此字段可能返回 null，表示取不到有效值。
:type Mutable: int
:param MCMultiDisk: 多云盘
注意：此字段可能返回 null，表示取不到有效值。
:type MCMultiDisk: list of MultiDiskMC
:param CdbNodeInfo: 数据库信息
注意：此字段可能返回 null，表示取不到有效值。
:type CdbNodeInfo: :class:`tencentcloud.emr.v20190103.models.CdbInfo`
:param Ip: 内网IP
注意：此字段可能返回 null，表示取不到有效值。
:type Ip: str
:param Destroyable: 此节点是否可销毁，1可销毁，0不可销毁
注意：此字段可能返回 null，表示取不到有效值。
:type Destroyable: int
:param Tags: 节点绑定的标签
注意：此字段可能返回 null，表示取不到有效值。
:type Tags: list of Tag
:param AutoFlag: 是否是自动扩缩容节点，0为普通节点，1为自动扩缩容节点。
注意：此字段可能返回 null，表示取不到有效值。
:type AutoFlag: int
:param HardwareResourceType: 资源类型, host/pod
注意：此字段可能返回 null，表示取不到有效值。
:type HardwareResourceType: str
:param IsDynamicSpec: 是否浮动规格，1是，0否
注意：此字段可能返回 null，表示取不到有效值。
:type IsDynamicSpec: int
:param DynamicPodSpec: 浮动规格值json字符串
注意：此字段可能返回 null，表示取不到有效值。
:type DynamicPodSpec: str
:param SupportModifyPayMode: 是否支持变更计费类型 1是，0否
注意：此字段可能返回 null，表示取不到有效值。
:type SupportModifyPayMode: int
:param RootStorageType: 系统盘类型
注意：此字段可能返回 null，表示取不到有效值。
:type RootStorageType: int
:param Zone: 可用区信息
注意：此字段可能返回 null，表示取不到有效值。
:type Zone: str
:param SubnetInfo: 子网
注意：此字段可能返回 null，表示取不到有效值。
:type SubnetInfo: :class:`tencentcloud.emr.v20190103.models.SubnetInfo`
:param Clients: 客户端
注意：此字段可能返回 null，表示取不到有效值。
:type Clients: str
:param CurrentTime: 系统当前时间
注意：此字段可能返回 null，表示取不到有效值。
:type CurrentTime: str
:param IsFederation: 是否用于联邦 ,1是，0否
注意：此字段可能返回 null，表示取不到有效值。
:type IsFederation: int
:param DeviceName: 设备名称
注意：此字段可能返回 null，表示取不到有效值。
:type DeviceName: str
:param ServiceClient: 服务
注意：此字段可能返回 null，表示取不到有效值。
:type ServiceClient: str
:param DisableApiTermination: 该实例是否开启实例保护，true为开启 false为关闭
注意：此字段可能返回 null，表示取不到有效值。
:type DisableApiTermination: bool
:param TradeVersion: 0表示老计费，1表示新计费
注意：此字段可能返回 null，表示取不到有效值。
:type TradeVersion: int
"""
self.AppId = None
self.SerialNo = None
self.OrderNo = None
self.WanIp = None
self.Flag = None
self.Spec = None
self.CpuNum = None
self.MemSize = None
self.MemDesc = None
self.RegionId = None
self.ZoneId = None
self.ApplyTime = None
self.FreeTime = None
self.DiskSize = None
self.NameTag = None
self.Services = None
self.StorageType = None
self.RootSize = None
self.ChargeType = None
self.CdbIp = None
self.CdbPort = None
self.HwDiskSize = None
self.HwDiskSizeDesc = None
self.HwMemSize = None
self.HwMemSizeDesc = None
self.ExpireTime = None
self.EmrResourceId = None
self.IsAutoRenew = None
self.DeviceClass = None
self.Mutable = None
self.MCMultiDisk = None
self.CdbNodeInfo = None
self.Ip = None
self.Destroyable = None
self.Tags = None
self.AutoFlag = None
self.HardwareResourceType = None
self.IsDynamicSpec = None
self.DynamicPodSpec = None
self.SupportModifyPayMode = None
self.RootStorageType = None
self.Zone = None
self.SubnetInfo = None
self.Clients = None
self.CurrentTime = None
self.IsFederation = None
self.DeviceName = None
self.ServiceClient = None
self.DisableApiTermination = None
self.TradeVersion = None
def _deserialize(self, params):
self.AppId = params.get("AppId")
self.SerialNo = params.get("SerialNo")
self.OrderNo = params.get("OrderNo")
self.WanIp = params.get("WanIp")
self.Flag = params.get("Flag")
self.Spec = params.get("Spec")
self.CpuNum = params.get("CpuNum")
self.MemSize = params.get("MemSize")
self.MemDesc = params.get("MemDesc")
self.RegionId = params.get("RegionId")
self.ZoneId = params.get("ZoneId")
self.ApplyTime = params.get("ApplyTime")
self.FreeTime = params.get("FreeTime")
self.DiskSize = params.get("DiskSize")
self.NameTag = params.get("NameTag")
self.Services = params.get("Services")
self.StorageType = params.get("StorageType")
self.RootSize = params.get("RootSize")
self.ChargeType = params.get("ChargeType")
self.CdbIp = params.get("CdbIp")
self.CdbPort = params.get("CdbPort")
self.HwDiskSize = params.get("HwDiskSize")
self.HwDiskSizeDesc = params.get("HwDiskSizeDesc")
self.HwMemSize = params.get("HwMemSize")
self.HwMemSizeDesc = params.get("HwMemSizeDesc")
self.ExpireTime = params.get("ExpireTime")
self.EmrResourceId = params.get("EmrResourceId")
self.IsAutoRenew = params.get("IsAutoRenew")
self.DeviceClass = params.get("DeviceClass")
self.Mutable = params.get("Mutable")
if params.get("MCMultiDisk") is not None:
self.MCMultiDisk = []
for item in params.get("MCMultiDisk"):
obj = MultiDiskMC()
obj._deserialize(item)
self.MCMultiDisk.append(obj)
if params.get("CdbNodeInfo") is not None:
self.CdbNodeInfo = CdbInfo()
self.CdbNodeInfo._deserialize(params.get("CdbNodeInfo"))
self.Ip = params.get("Ip")
self.Destroyable = params.get("Destroyable")
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
self.AutoFlag = params.get("AutoFlag")
self.HardwareResourceType = params.get("HardwareResourceType")
self.IsDynamicSpec = params.get("IsDynamicSpec")
self.DynamicPodSpec = params.get("DynamicPodSpec")
self.SupportModifyPayMode = params.get("SupportModifyPayMode")
self.RootStorageType = params.get("RootStorageType")
self.Zone = params.get("Zone")
if params.get("SubnetInfo") is not None:
self.SubnetInfo = SubnetInfo()
self.SubnetInfo._deserialize(params.get("SubnetInfo"))
self.Clients = params.get("Clients")
self.CurrentTime = params.get("CurrentTime")
self.IsFederation = params.get("IsFederation")
self.DeviceName = params.get("DeviceName")
self.ServiceClient = params.get("ServiceClient")
self.DisableApiTermination = params.get("DisableApiTermination")
self.TradeVersion = params.get("TradeVersion")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class NodeResourceSpec(AbstractModel):
"""资源详情
"""
def __init__(self):
r"""
:param InstanceType: 规格类型，如S2.MEDIUM8
注意：此字段可能返回 null，表示取不到有效值。
:type InstanceType: str
:param SystemDisk: 系统盘，系统盘个数不超过1块
注意：此字段可能返回 null，表示取不到有效值。
:type SystemDisk: list of DiskSpecInfo
:param Tags: 需要绑定的标签列表
注意：此字段可能返回 null，表示取不到有效值。
:type Tags: list of Tag
:param DataDisk: 云数据盘，云数据盘总个数不超过15块
注意：此字段可能返回 null，表示取不到有效值。
:type DataDisk: list of DiskSpecInfo
:param LocalDataDisk: 本地数据盘
注意：此字段可能返回 null，表示取不到有效值。
:type LocalDataDisk: list of DiskSpecInfo
"""
self.InstanceType = None
self.SystemDisk = None
self.Tags = None
self.DataDisk = None
self.LocalDataDisk = None
def _deserialize(self, params):
self.InstanceType = params.get("InstanceType")
if params.get("SystemDisk") is not None:
self.SystemDisk = []
for item in params.get("SystemDisk"):
obj = DiskSpecInfo()
obj._deserialize(item)
self.SystemDisk.append(obj)
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
if params.get("DataDisk") is not None:
self.DataDisk = []
for item in params.get("DataDisk"):
obj = DiskSpecInfo()
obj._deserialize(item)
self.DataDisk.append(obj)
if params.get("LocalDataDisk") is not None:
self.LocalDataDisk = []
for item in params.get("LocalDataDisk"):
obj = DiskSpecInfo()
obj._deserialize(item)
self.LocalDataDisk.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class OpScope(AbstractModel):
"""操作范围
"""
def __init__(self):
r"""
:param ServiceInfoList: 操作范围，要操作的服务信息
注意：此字段可能返回 null，表示取不到有效值。
:type ServiceInfoList: list of ServiceBasicRestartInfo
"""
self.ServiceInfoList = None
def _deserialize(self, params):
if params.get("ServiceInfoList") is not None:
self.ServiceInfoList = []
for item in params.get("ServiceInfoList"):
obj = ServiceBasicRestartInfo()
obj._deserialize(item)
self.ServiceInfoList.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class OutterResource(AbstractModel):
"""资源详情
"""
def __init__(self):
r"""
:param Spec: 规格
注意：此字段可能返回 null，表示取不到有效值。
:type Spec: str
:param SpecName: 规格名
注意：此字段可能返回 null，表示取不到有效值。
:type SpecName: str
:param StorageType: 硬盘类型
注意：此字段可能返回 null，表示取不到有效值。
:type StorageType: int
:param DiskType: 硬盘类型
注意：此字段可能返回 null，表示取不到有效值。
:type DiskType: str
:param RootSize: 系统盘大小
注意：此字段可能返回 null，表示取不到有效值。
:type RootSize: int
:param MemSize: 内存大小
注意：此字段可能返回 null，表示取不到有效值。
:type MemSize: int
:param Cpu: CPU个数
注意：此字段可能返回 null，表示取不到有效值。
:type Cpu: int
:param DiskSize: 硬盘大小
注意：此字段可能返回 null，表示取不到有效值。
:type DiskSize: int
:param InstanceType: 规格
注意：此字段可能返回 null，表示取不到有效值。
:type InstanceType: str
"""
self.Spec = None
self.SpecName = None
self.StorageType = None
self.DiskType = None
self.RootSize = None
self.MemSize = None
self.Cpu = None
self.DiskSize = None
self.InstanceType = None
def _deserialize(self, params):
self.Spec = params.get("Spec")
self.SpecName = params.get("SpecName")
self.StorageType = params.get("StorageType")
self.DiskType = params.get("DiskType")
self.RootSize = params.get("RootSize")
self.MemSize = params.get("MemSize")
self.Cpu = params.get("Cpu")
self.DiskSize = params.get("DiskSize")
self.InstanceType = params.get("InstanceType")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PartDetailPriceItem(AbstractModel):
"""用于创建集群价格清单-节点组成部分价格
"""
def __init__(self):
r"""
:param InstanceType: 类型包括：节点->node、系统盘->rootDisk、云数据盘->dataDisk、metaDB
注意：此字段可能返回 null，表示取不到有效值。
:type InstanceType: str
:param Price: 单价（原价）
注意：此字段可能返回 null，表示取不到有效值。
:type Price: float
:param RealCost: 单价（折扣价）
注意：此字段可能返回 null，表示取不到有效值。
:type RealCost: float
:param RealTotalCost: 总价（折扣价）
注意：此字段可能返回 null，表示取不到有效值。
:type RealTotalCost: float
:param Policy: 折扣
注意：此字段可能返回 null，表示取不到有效值。
:type Policy: float
:param GoodsNum: 数量
注意：此字段可能返回 null，表示取不到有效值。
:type GoodsNum: int
"""
self.InstanceType = None
self.Price = None
self.RealCost = None
self.RealTotalCost = None
self.Policy = None
self.GoodsNum = None
def _deserialize(self, params):
self.InstanceType = params.get("InstanceType")
self.Price = params.get("Price")
self.RealCost = params.get("RealCost")
self.RealTotalCost = params.get("RealTotalCost")
self.Policy = params.get("Policy")
self.GoodsNum = params.get("GoodsNum")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PersistentVolumeContext(AbstractModel):
"""Pod PVC存储方式描述
"""
def __init__(self):
r"""
:param DiskSize: 磁盘大小，单位为GB。
注意：此字段可能返回 null，表示取不到有效值。
:type DiskSize: int
:param DiskType: 磁盘类型。CLOUD_PREMIUM;CLOUD_SSD
注意：此字段可能返回 null，表示取不到有效值。
:type DiskType: str
:param DiskNum: 磁盘数量
注意：此字段可能返回 null，表示取不到有效值。
:type DiskNum: int
"""
self.DiskSize = None
self.DiskType = None
self.DiskNum = None
def _deserialize(self, params):
self.DiskSize = params.get("DiskSize")
self.DiskType = params.get("DiskType")
self.DiskNum = params.get("DiskNum")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class Placement(AbstractModel):
"""描述集群实例位置信息
"""
def __init__(self):
r"""
:param Zone: 实例所属的可用区，例如ap-guangzhou-1。该参数也可以通过调用[DescribeZones](https://cloud.tencent.com/document/product/213/15707) 的返回值中的Zone字段来获取。
:type Zone: str
:param ProjectId: 实例所属项目ID。该参数可以通过调用[DescribeProject](https://cloud.tencent.com/document/api/651/78725) 的返回值中的 projectId 字段来获取。不填为默认项目。
:type ProjectId: int
"""
self.Zone = None
self.ProjectId = None
def _deserialize(self, params):
self.Zone = params.get("Zone")
self.ProjectId = params.get("ProjectId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PodNewParameter(AbstractModel):
"""POD自定义权限和自定义参数
"""
def __init__(self):
r"""
:param InstanceId: TKE或EKS集群ID
:type InstanceId: str
:param Config: 自定义权限
如：
{
"apiVersion": "v1",
"clusters": [
{
"cluster": {
"certificate-authority-data": "xxxxxx==",
"server": "https://xxxxx.com"
},
"name": "cls-xxxxx"
}
],
"contexts": [
{
"context": {
"cluster": "cls-xxxxx",
"user": "100014xxxxx"
},
"name": "cls-a44yhcxxxxxxxxxx"
}
],
"current-context": "cls-a4xxxx-context-default",
"kind": "Config",
"preferences": {},
"users": [
{
"name": "100014xxxxx",
"user": {
"client-certificate-data": "xxxxxx",
"client-key-data": "xxxxxx"
}
}
]
}
:type Config: str
:param Parameter: 自定义参数
如：
{
"apiVersion": "apps/v1",
"kind": "Deployment",
"metadata": {
"name": "test-deployment",
"labels": {
"app": "test"
}
},
"spec": {
"replicas": 3,
"selector": {
"matchLabels": {
"app": "test-app"
}
},
"template": {
"metadata": {
"annotations": {
"your-organization.com/department-v1": "test-example-v1",
"your-organization.com/department-v2": "test-example-v2"
},
"labels": {
"app": "test-app",
"environment": "production"
}
},
"spec": {
"nodeSelector": {
"your-organization/node-test": "test-node"
},
"containers": [
{
"name": "nginx",
"image": "nginx:1.14.2",
"ports": [
{
"containerPort": 80
}
]
}
],
"affinity": {
"nodeAffinity": {
"requiredDuringSchedulingIgnoredDuringExecution": {
"nodeSelectorTerms": [
{
"matchExpressions": [
{
"key": "disk-type",
"operator": "In",
"values": [
"ssd",
"sas"
]
},
{
"key": "cpu-num",
"operator": "Gt",
"values": [
"6"
]
}
]
}
]
}
}
}
}
}
}
}
:type Parameter: str
"""
self.InstanceId = None
self.Config = None
self.Parameter = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.Config = params.get("Config")
self.Parameter = params.get("Parameter")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PodNewSpec(AbstractModel):
"""扩容容器资源时的资源描述
"""
def __init__(self):
r"""
:param ResourceProviderIdentifier: 外部资源提供者的标识符，例如"cls-a1cd23fa"。
:type ResourceProviderIdentifier: str
:param ResourceProviderType: 外部资源提供者类型，例如"tke",当前仅支持"tke"。
:type ResourceProviderType: str
:param NodeFlag: 资源的用途，即节点类型，当前仅支持"TASK"。
:type NodeFlag: str
:param Cpu: CPU核数。
:type Cpu: int
:param Memory: 内存大小，单位为GB。
:type Memory: int
:param CpuType: Eks集群-CPU类型，当前支持"intel"和"amd"
:type CpuType: str
:param PodVolumes: Pod节点数据目录挂载信息。
:type PodVolumes: list of PodVolume
:param EnableDynamicSpecFlag: 是否浮动规格，默认否
true：代表是
false：代表否
:type EnableDynamicSpecFlag: bool
:param DynamicPodSpec: 浮动规格
注意：此字段可能返回 null，表示取不到有效值。
:type DynamicPodSpec: :class:`tencentcloud.emr.v20190103.models.DynamicPodSpec`
:param VpcId: 代表vpc网络唯一id
注意：此字段可能返回 null，表示取不到有效值。
:type VpcId: str
:param SubnetId: 代表vpc子网唯一id
注意：此字段可能返回 null，表示取不到有效值。
:type SubnetId: str
:param PodName: pod name
注意：此字段可能返回 null，表示取不到有效值。
:type PodName: str
"""
self.ResourceProviderIdentifier = None
self.ResourceProviderType = None
self.NodeFlag = None
self.Cpu = None
self.Memory = None
self.CpuType = None
self.PodVolumes = None
self.EnableDynamicSpecFlag = None
self.DynamicPodSpec = None
self.VpcId = None
self.SubnetId = None
self.PodName = None
def _deserialize(self, params):
self.ResourceProviderIdentifier = params.get("ResourceProviderIdentifier")
self.ResourceProviderType = params.get("ResourceProviderType")
self.NodeFlag = params.get("NodeFlag")
self.Cpu = params.get("Cpu")
self.Memory = params.get("Memory")
self.CpuType = params.get("CpuType")
if params.get("PodVolumes") is not None:
self.PodVolumes = []
for item in params.get("PodVolumes"):
obj = PodVolume()
obj._deserialize(item)
self.PodVolumes.append(obj)
self.EnableDynamicSpecFlag = params.get("EnableDynamicSpecFlag")
if params.get("DynamicPodSpec") is not None:
self.DynamicPodSpec = DynamicPodSpec()
self.DynamicPodSpec._deserialize(params.get("DynamicPodSpec"))
self.VpcId = params.get("VpcId")
self.SubnetId = params.get("SubnetId")
self.PodName = params.get("PodName")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PodParameter(AbstractModel):
"""POD自定义权限和自定义参数
"""
def __init__(self):
r"""
:param ClusterId: TKE或EKS集群ID
:type ClusterId: str
:param Config: 自定义权限
如：
{
"apiVersion": "v1",
"clusters": [
{
"cluster": {
"certificate-authority-data": "xxxxxx==",
"server": "https://xxxxx.com"
},
"name": "cls-xxxxx"
}
],
"contexts": [
{
"context": {
"cluster": "cls-xxxxx",
"user": "100014xxxxx"
},
"name": "cls-a44yhcxxxxxxxxxx"
}
],
"current-context": "cls-a4xxxx-context-default",
"kind": "Config",
"preferences": {},
"users": [
{
"name": "100014xxxxx",
"user": {
"client-certificate-data": "xxxxxx",
"client-key-data": "xxxxxx"
}
}
]
}
:type Config: str
:param Parameter: 自定义参数
如：
{
"apiVersion": "apps/v1",
"kind": "Deployment",
"metadata": {
"name": "test-deployment",
"labels": {
"app": "test"
}
},
"spec": {
"replicas": 3,
"selector": {
"matchLabels": {
"app": "test-app"
}
},
"template": {
"metadata": {
"annotations": {
"your-organization.com/department-v1": "test-example-v1",
"your-organization.com/department-v2": "test-example-v2"
},
"labels": {
"app": "test-app",
"environment": "production"
}
},
"spec": {
"nodeSelector": {
"your-organization/node-test": "test-node"
},
"containers": [
{
"name": "nginx",
"image": "nginx:1.14.2",
"ports": [
{
"containerPort": 80
}
]
}
],
"affinity": {
"nodeAffinity": {
"requiredDuringSchedulingIgnoredDuringExecution": {
"nodeSelectorTerms": [
{
"matchExpressions": [
{
"key": "disk-type",
"operator": "In",
"values": [
"ssd",
"sas"
]
},
{
"key": "cpu-num",
"operator": "Gt",
"values": [
"6"
]
}
]
}
]
}
}
}
}
}
}
}
:type Parameter: str
"""
self.ClusterId = None
self.Config = None
self.Parameter = None
def _deserialize(self, params):
self.ClusterId = params.get("ClusterId")
self.Config = params.get("Config")
self.Parameter = params.get("Parameter")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PodSaleSpec(AbstractModel):
"""Pod资源售卖规格
"""
def __init__(self):
r"""
:param NodeType: 可售卖的资源规格，仅为以下值:"TASK","CORE","MASTER","ROUTER"。
:type NodeType: str
:param Cpu: Cpu核数。
:type Cpu: int
:param Memory: 内存数量，单位为GB。
:type Memory: int
:param Number: 该规格资源可申请的最大数量。
:type Number: int
"""
self.NodeType = None
self.Cpu = None
self.Memory = None
self.Number = None
def _deserialize(self, params):
self.NodeType = params.get("NodeType")
self.Cpu = params.get("Cpu")
self.Memory = params.get("Memory")
self.Number = params.get("Number")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PodSpec(AbstractModel):
"""扩容容器资源时的资源描述
"""
def __init__(self):
r"""
:param ResourceProviderIdentifier: 外部资源提供者的标识符，例如"cls-a1cd23fa"。
:type ResourceProviderIdentifier: str
:param ResourceProviderType: 外部资源提供者类型，例如"tke",当前仅支持"tke"。
:type ResourceProviderType: str
:param NodeType: 资源的用途，即节点类型，当前仅支持"TASK"。
:type NodeType: str
:param Cpu: CPU核数。
:type Cpu: int
:param Memory: 内存大小，单位为GB。
:type Memory: int
:param DataVolumes: 资源对宿主机的挂载点，指定的挂载点对应了宿主机的路径，该挂载点在Pod中作为数据存储目录使用。弃用
:type DataVolumes: list of str
:param CpuType: Eks集群-CPU类型，当前支持"intel"和"amd"
:type CpuType: str
:param PodVolumes: Pod节点数据目录挂载信息。
:type PodVolumes: list of PodVolume
:param IsDynamicSpec: 是否浮动规格，1是，0否
:type IsDynamicSpec: int
:param DynamicPodSpec: 浮动规格
注意：此字段可能返回 null，表示取不到有效值。
:type DynamicPodSpec: :class:`tencentcloud.emr.v20190103.models.DynamicPodSpec`
:param VpcId: 代表vpc网络唯一id
注意：此字段可能返回 null，表示取不到有效值。
:type VpcId: str
:param SubnetId: 代表vpc子网唯一id
注意：此字段可能返回 null，表示取不到有效值。
:type SubnetId: str
:param PodName: pod name
注意：此字段可能返回 null，表示取不到有效值。
:type PodName: str
"""
self.ResourceProviderIdentifier = None
self.ResourceProviderType = None
self.NodeType = None
self.Cpu = None
self.Memory = None
self.DataVolumes = None
self.CpuType = None
self.PodVolumes = None
self.IsDynamicSpec = None
self.DynamicPodSpec = None
self.VpcId = None
self.SubnetId = None
self.PodName = None
def _deserialize(self, params):
self.ResourceProviderIdentifier = params.get("ResourceProviderIdentifier")
self.ResourceProviderType = params.get("ResourceProviderType")
self.NodeType = params.get("NodeType")
self.Cpu = params.get("Cpu")
self.Memory = params.get("Memory")
self.DataVolumes = params.get("DataVolumes")
self.CpuType = params.get("CpuType")
if params.get("PodVolumes") is not None:
self.PodVolumes = []
for item in params.get("PodVolumes"):
obj = PodVolume()
obj._deserialize(item)
self.PodVolumes.append(obj)
self.IsDynamicSpec = params.get("IsDynamicSpec")
if params.get("DynamicPodSpec") is not None:
self.DynamicPodSpec = DynamicPodSpec()
self.DynamicPodSpec._deserialize(params.get("DynamicPodSpec"))
self.VpcId = params.get("VpcId")
self.SubnetId = params.get("SubnetId")
self.PodName = params.get("PodName")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PodSpecInfo(AbstractModel):
"""Pod相关信息
"""
def __init__(self):
r"""
:param PodSpec: 使用Pod资源扩容时，指定的Pod规格以及来源等信息
:type PodSpec: :class:`tencentcloud.emr.v20190103.models.PodNewSpec`
:param PodParameter: POD自定义权限和自定义参数
:type PodParameter: :class:`tencentcloud.emr.v20190103.models.PodNewParameter`
"""
self.PodSpec = None
self.PodParameter = None
def _deserialize(self, params):
if params.get("PodSpec") is not None:
self.PodSpec = PodNewSpec()
self.PodSpec._deserialize(params.get("PodSpec"))
if params.get("PodParameter") is not None:
self.PodParameter = PodNewParameter()
self.PodParameter._deserialize(params.get("PodParameter"))
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PodState(AbstractModel):
"""单个pod状态
"""
def __init__(self):
r"""
:param Name: pod的名称
:type Name: str
:param Uuid: pod uuid
:type Uuid: str
:param State: pod的状态
:type State: str
:param Reason: pod处于该状态原因
:type Reason: str
:param OwnerCluster: pod所属集群
:type OwnerCluster: str
:param Memory: pod内存大小
:type Memory: int
"""
self.Name = None
self.Uuid = None
self.State = None
self.Reason = None
self.OwnerCluster = None
self.Memory = None
def _deserialize(self, params):
self.Name = params.get("Name")
self.Uuid = params.get("Uuid")
self.State = params.get("State")
self.Reason = params.get("Reason")
self.OwnerCluster = params.get("OwnerCluster")
self.Memory = params.get("Memory")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PodVolume(AbstractModel):
"""Pod的存储设备描述信息。
"""
def __init__(self):
r"""
:param VolumeType: 存储类型，可为"pvc"，"hostpath"。
注意：此字段可能返回 null，表示取不到有效值。
:type VolumeType: str
:param PVCVolume: 当VolumeType为"pvc"时，该字段生效。
注意：此字段可能返回 null，表示取不到有效值。
:type PVCVolume: :class:`tencentcloud.emr.v20190103.models.PersistentVolumeContext`
:param HostVolume: 当VolumeType为"hostpath"时，该字段生效。
注意：此字段可能返回 null，表示取不到有效值。
:type HostVolume: :class:`tencentcloud.emr.v20190103.models.HostVolumeContext`
"""
self.VolumeType = None
self.PVCVolume = None
self.HostVolume = None
def _deserialize(self, params):
self.VolumeType = params.get("VolumeType")
if params.get("PVCVolume") is not None:
self.PVCVolume = PersistentVolumeContext()
self.PVCVolume._deserialize(params.get("PVCVolume"))
if params.get("HostVolume") is not None:
self.HostVolume = HostVolumeContext()
self.HostVolume._deserialize(params.get("HostVolume"))
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PreExecuteFileSettings(AbstractModel):
"""预执行脚本配置
"""
def __init__(self):
r"""
:param Path: 脚本在COS上路径，已废弃
:type Path: str
:param Args: 执行脚本参数
:type Args: list of str
:param Bucket: COS的Bucket名称，已废弃
:type Bucket: str
:param Region: COS的Region名称，已废弃
:type Region: str
:param Domain: COS的Domain数据，已废弃
:type Domain: str
:param RunOrder: 执行顺序
:type RunOrder: int
:param WhenRun: resourceAfter 或 clusterAfter
:type WhenRun: str
:param CosFileName: 脚本文件名，已废弃
:type CosFileName: str
:param CosFileURI: 脚本的cos地址
:type CosFileURI: str
:param CosSecretId: cos的SecretId
:type CosSecretId: str
:param CosSecretKey: Cos的SecretKey
:type CosSecretKey: str
:param AppId: cos的appid，已废弃
:type AppId: str
"""
self.Path = None
self.Args = None
self.Bucket = None
self.Region = None
self.Domain = None
self.RunOrder = None
self.WhenRun = None
self.CosFileName = None
self.CosFileURI = None
self.CosSecretId = None
self.CosSecretKey = None
self.AppId = None
def _deserialize(self, params):
self.Path = params.get("Path")
self.Args = params.get("Args")
self.Bucket = params.get("Bucket")
self.Region = params.get("Region")
self.Domain = params.get("Domain")
self.RunOrder = params.get("RunOrder")
self.WhenRun = params.get("WhenRun")
self.CosFileName = params.get("CosFileName")
self.CosFileURI = params.get("CosFileURI")
self.CosSecretId = params.get("CosSecretId")
self.CosSecretKey = params.get("CosSecretKey")
self.AppId = params.get("AppId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PriceDetail(AbstractModel):
"""价格详情
"""
def __init__(self):
r"""
:param ResourceId: 节点ID
:type ResourceId: str
:param Formula: 价格计算公式
:type Formula: str
:param OriginalCost: 原价
:type OriginalCost: float
:param DiscountCost: 折扣价
:type DiscountCost: float
"""
self.ResourceId = None
self.Formula = None
self.OriginalCost = None
self.DiscountCost = None
def _deserialize(self, params):
self.ResourceId = params.get("ResourceId")
self.Formula = params.get("Formula")
self.OriginalCost = params.get("OriginalCost")
self.DiscountCost = params.get("DiscountCost")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class PriceResource(AbstractModel):
"""询价资源
"""
def __init__(self):
r"""
:param Spec: 需要的规格
注意：此字段可能返回 null，表示取不到有效值。
:type Spec: str
:param StorageType: 硬盘类型
注意：此字段可能返回 null，表示取不到有效值。
:type StorageType: int
:param DiskType: 硬盘类型
注意：此字段可能返回 null，表示取不到有效值。
:type DiskType: str
:param RootSize: 系统盘大小
注意：此字段可能返回 null，表示取不到有效值。
:type RootSize: int
:param MemSize: 内存大小
注意：此字段可能返回 null，表示取不到有效值。
:type MemSize: int
:param Cpu: 核心数量
注意：此字段可能返回 null，表示取不到有效值。
:type Cpu: int
:param DiskSize: 硬盘大小
注意：此字段可能返回 null，表示取不到有效值。
:type DiskSize: int
:param MultiDisks: 云盘列表
注意：此字段可能返回 null，表示取不到有效值。
:type MultiDisks: list of MultiDisk
:param DiskCnt: 磁盘数量
注意：此字段可能返回 null，表示取不到有效值。
:type DiskCnt: int
:param InstanceType: 规格
注意：此字段可能返回 null，表示取不到有效值。
:type InstanceType: str
:param Tags: 标签
注意：此字段可能返回 null，表示取不到有效值。
:type Tags: list of Tag
:param DiskNum: 磁盘数量
注意：此字段可能返回 null，表示取不到有效值。
:type DiskNum: int
:param LocalDiskNum: 本地盘的数量
注意：此字段可能返回 null，表示取不到有效值。
:type LocalDiskNum: int
"""
self.Spec = None
self.StorageType = None
self.DiskType = None
self.RootSize = None
self.MemSize = None
self.Cpu = None
self.DiskSize = None
self.MultiDisks = None
self.DiskCnt = None
self.InstanceType = None
self.Tags = None
self.DiskNum = None
self.LocalDiskNum = None
def _deserialize(self, params):
self.Spec = params.get("Spec")
self.StorageType = params.get("StorageType")
self.DiskType = params.get("DiskType")
self.RootSize = params.get("RootSize")
self.MemSize = params.get("MemSize")
self.Cpu = params.get("Cpu")
self.DiskSize = params.get("DiskSize")
if params.get("MultiDisks") is not None:
self.MultiDisks = []
for item in params.get("MultiDisks"):
obj = MultiDisk()
obj._deserialize(item)
self.MultiDisks.append(obj)
self.DiskCnt = params.get("DiskCnt")
self.InstanceType = params.get("InstanceType")
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
self.DiskNum = params.get("DiskNum")
self.LocalDiskNum = params.get("LocalDiskNum")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class QuotaEntity(AbstractModel):
"""获取CVM配额
"""
def __init__(self):
r"""
:param UsedQuota: 已使用配额
注意：此字段可能返回 null，表示取不到有效值。
:type UsedQuota: int
:param RemainingQuota: 剩余配额
注意：此字段可能返回 null，表示取不到有效值。
:type RemainingQuota: int
:param TotalQuota: 总配额
注意：此字段可能返回 null，表示取不到有效值。
:type TotalQuota: int
:param Zone: 可用区
注意：此字段可能返回 null，表示取不到有效值。
:type Zone: str
"""
self.UsedQuota = None
self.RemainingQuota = None
self.TotalQuota = None
self.Zone = None
def _deserialize(self, params):
self.UsedQuota = params.get("UsedQuota")
self.RemainingQuota = params.get("RemainingQuota")
self.TotalQuota = params.get("TotalQuota")
self.Zone = params.get("Zone")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class RenewInstancesInfo(AbstractModel):
"""集群续费实例信息
"""
def __init__(self):
r"""
:param EmrResourceId: 节点资源ID
:type EmrResourceId: str
:param Flag: 节点类型。0:common节点；1:master节点
；2:core节点；3:task节点
:type Flag: int
:param Ip: 内网IP
:type Ip: str
:param MemDesc: 节点内存描述
:type MemDesc: str
:param CpuNum: 节点核数
:type CpuNum: int
:param DiskSize: 硬盘大小
:type DiskSize: str
:param ExpireTime: 过期时间
:type ExpireTime: str
:param Spec: 节点规格
:type Spec: str
:param StorageType: 磁盘类型
:type StorageType: int
"""
self.EmrResourceId = None
self.Flag = None
self.Ip = None
self.MemDesc = None
self.CpuNum = None
self.DiskSize = None
self.ExpireTime = None
self.Spec = None
self.StorageType = None
def _deserialize(self, params):
self.EmrResourceId = params.get("EmrResourceId")
self.Flag = params.get("Flag")
self.Ip = params.get("Ip")
self.MemDesc = params.get("MemDesc")
self.CpuNum = params.get("CpuNum")
self.DiskSize = params.get("DiskSize")
self.ExpireTime = params.get("ExpireTime")
self.Spec = params.get("Spec")
self.StorageType = params.get("StorageType")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class Resource(AbstractModel):
"""资源详情
"""
def __init__(self):
r"""
:param Spec: 节点规格描述，如CVM.SA2。
注意：此字段可能返回 null，表示取不到有效值。
:type Spec: str
:param StorageType: 存储类型
取值范围：
4：表示云SSD。
5：表示高效云盘。
6：表示增强型SSD云硬盘。
11：表示吞吐型云硬盘。
12：表示极速型SSD云硬盘。
注意：此字段可能返回 null，表示取不到有效值。
:type StorageType: int
:param DiskType: 磁盘类型
取值范围：
CLOUD_SSD：表示云SSD。
CLOUD_PREMIUM：表示高效云盘。
CLOUD_BASIC：表示云硬盘。
注意：此字段可能返回 null，表示取不到有效值。
:type DiskType: str
:param MemSize: 内存容量,单位为M
注意：此字段可能返回 null，表示取不到有效值。
:type MemSize: int
:param Cpu: CPU核数
注意：此字段可能返回 null，表示取不到有效值。
:type Cpu: int
:param DiskSize: 数据盘容量
注意：此字段可能返回 null，表示取不到有效值。
:type DiskSize: int
:param RootSize: 系统盘容量
注意：此字段可能返回 null，表示取不到有效值。
:type RootSize: int
:param MultiDisks: 云盘列表，当数据盘为一块云盘时，直接使用DiskType和DiskSize参数，超出部分使用MultiDisks
注意：此字段可能返回 null，表示取不到有效值。
:type MultiDisks: list of MultiDisk
:param Tags: 需要绑定的标签列表
注意：此字段可能返回 null，表示取不到有效值。
:type Tags: list of Tag
:param InstanceType: 规格类型，如S2.MEDIUM8
注意：此字段可能返回 null，表示取不到有效值。
:type InstanceType: str
:param LocalDiskNum: 本地盘数量，该字段已废弃
注意：此字段可能返回 null，表示取不到有效值。
:type LocalDiskNum: int
:param DiskNum: 本地盘数量，如2
注意：此字段可能返回 null，表示取不到有效值。
:type DiskNum: int
"""
self.Spec = None
self.StorageType = None
self.DiskType = None
self.MemSize = None
self.Cpu = None
self.DiskSize = None
self.RootSize = None
self.MultiDisks = None
self.Tags = None
self.InstanceType = None
self.LocalDiskNum = None
self.DiskNum = None
def _deserialize(self, params):
self.Spec = params.get("Spec")
self.StorageType = params.get("StorageType")
self.DiskType = params.get("DiskType")
self.MemSize = params.get("MemSize")
self.Cpu = params.get("Cpu")
self.DiskSize = params.get("DiskSize")
self.RootSize = params.get("RootSize")
if params.get("MultiDisks") is not None:
self.MultiDisks = []
for item in params.get("MultiDisks"):
obj = MultiDisk()
obj._deserialize(item)
self.MultiDisks.append(obj)
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
self.InstanceType = params.get("InstanceType")
self.LocalDiskNum = params.get("LocalDiskNum")
self.DiskNum = params.get("DiskNum")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class RunJobFlowRequest(AbstractModel):
"""RunJobFlow请求参数结构体
"""
def __init__(self):
r"""
:param Name: 作业名称。
:type Name: str
:param CreateCluster: 是否新创建集群。
true，新创建集群，则使用Instance中的参数进行集群创建。
false，使用已有集群，则通过InstanceId传入。
:type CreateCluster: bool
:param Steps: 作业流程执行步骤。
:type Steps: list of Step
:param InstancePolicy: 作业流程正常完成时，集群的处理方式，可选择:
Terminate 销毁集群。
Reserve 保留集群。
:type InstancePolicy: str
:param ProductVersion: 只有CreateCluster为true时生效，目前只支持EMR版本，例如EMR-2.2.0，不支持ClickHouse和Druid版本。
:type ProductVersion: str
:param SecurityClusterFlag: 只在CreateCluster为true时生效。
true 表示安装kerberos，false表示不安装kerberos。
:type SecurityClusterFlag: bool
:param Software: 只在CreateCluster为true时生效。
新建集群时，要安装的软件列表。
:type Software: list of str
:param BootstrapActions: 引导脚本。
:type BootstrapActions: list of BootstrapAction
:param Configurations: 指定配置创建集群。
:type Configurations: list of Configuration
:param LogUri: 作业日志保存地址。
:type LogUri: str
:param InstanceId: 只在CreateCluster为false时生效。
:type InstanceId: str
:param ApplicationRole: 自定义应用角色，大数据应用访问外部服务时使用的角色，默认为"EME_QCSRole"。
:type ApplicationRole: str
:param ClientToken: 重入标签，用来可重入检查，防止在一段时间内，创建相同的流程作业。
:type ClientToken: str
:param Instance: 只在CreateCluster为true时生效，使用该配置创建集群。
:type Instance: :class:`tencentcloud.emr.v20190103.models.ClusterSetting`
"""
self.Name = None
self.CreateCluster = None
self.Steps = None
self.InstancePolicy = None
self.ProductVersion = None
self.SecurityClusterFlag = None
self.Software = None
self.BootstrapActions = None
self.Configurations = None
self.LogUri = None
self.InstanceId = None
self.ApplicationRole = None
self.ClientToken = None
self.Instance = None
def _deserialize(self, params):
self.Name = params.get("Name")
self.CreateCluster = params.get("CreateCluster")
if params.get("Steps") is not None:
self.Steps = []
for item in params.get("Steps"):
obj = Step()
obj._deserialize(item)
self.Steps.append(obj)
self.InstancePolicy = params.get("InstancePolicy")
self.ProductVersion = params.get("ProductVersion")
self.SecurityClusterFlag = params.get("SecurityClusterFlag")
self.Software = params.get("Software")
if params.get("BootstrapActions") is not None:
self.BootstrapActions = []
for item in params.get("BootstrapActions"):
obj = BootstrapAction()
obj._deserialize(item)
self.BootstrapActions.append(obj)
if params.get("Configurations") is not None:
self.Configurations = []
for item in params.get("Configurations"):
obj = Configuration()
obj._deserialize(item)
self.Configurations.append(obj)
self.LogUri = params.get("LogUri")
self.InstanceId = params.get("InstanceId")
self.ApplicationRole = params.get("ApplicationRole")
self.ClientToken = params.get("ClientToken")
if params.get("Instance") is not None:
self.Instance = ClusterSetting()
self.Instance._deserialize(params.get("Instance"))
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class RunJobFlowResponse(AbstractModel):
"""RunJobFlow返回参数结构体
"""
def __init__(self):
r"""
:param JobFlowId: 作业流程ID。
:type JobFlowId: int
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.JobFlowId = None
self.RequestId = None
def _deserialize(self, params):
self.JobFlowId = params.get("JobFlowId")
self.RequestId = params.get("RequestId")
class ScaleOutClusterRequest(AbstractModel):
"""ScaleOutCluster请求参数结构体
"""
def __init__(self):
r"""
:param InstanceChargeType: 节点计费模式。取值范围：
PREPAID：预付费，即包年包月。
POSTPAID_BY_HOUR：按小时后付费。
SPOTPAID：竞价付费（仅支持TASK节点）。
:type InstanceChargeType: str
:param InstanceId: 集群实例ID。
:type InstanceId: str
:param ScaleOutNodeConfig: 扩容节点类型以及数量
:type ScaleOutNodeConfig: :class:`tencentcloud.emr.v20190103.models.ScaleOutNodeConfig`
:param ClientToken: 唯一随机标识，时效5分钟，需要调用者指定 防止客户端重新创建资源，例如 a9a90aa6-751a-41b6-aad6-fae36063280
:type ClientToken: str
:param InstanceChargePrepaid: 即包年包月相关参数设置。通过该参数可以指定包年包月实例的购买时长、是否设置自动续费等属性。若指定实例的付费模式为预付费则该参数必传。
:type InstanceChargePrepaid: :class:`tencentcloud.emr.v20190103.models.InstanceChargePrepaid`
:param ScriptBootstrapActionConfig: [引导操作](https://cloud.tencent.com/document/product/589/35656)脚本设置。
:type ScriptBootstrapActionConfig: list of ScriptBootstrapActionConfig
:param SoftDeployInfo: 扩容部署服务，新增节点将默认继承当前节点类型中所部署服务，部署服务含默认可选服务，该参数仅支持可选服务填写，如：存量task节点已部署HDFS、YARN、impala；使用api扩容task节不部署impala时，此参数仅填写HDFS、YARN
:type SoftDeployInfo: list of int
:param ServiceNodeInfo: 部署进程，默认部署扩容服务的全部进程，支持修改部署进程，如：当前task节点部署服务为：HDFS、YARN、impala，默认部署服务为：DataNode,NodeManager,ImpalaServer，若用户需修改部署进程信息，此参数信息可填写： DataNode,NodeManager,ImpalaServerCoordinator或DataNode,NodeManager,ImpalaServerExecutor
:type ServiceNodeInfo: list of int
:param DisasterRecoverGroupIds: 分散置放群组ID列表，当前只支持指定一个。
该参数可以通过调用 [DescribeDisasterRecoverGroups](https://cloud.tencent.com/document/product/213/17810)的返回值中的DisasterRecoverGroupId字段来获取。
:type DisasterRecoverGroupIds: list of str
:param Tags: 扩容节点绑定标签列表。
:type Tags: list of Tag
:param HardwareSourceType: 扩容所选资源类型，可选范围为"host","pod"，host为普通的CVM资源，Pod为TKE集群或EKS集群提供的资源
:type HardwareSourceType: str
:param PodSpecInfo: Pod相关资源信息
:type PodSpecInfo: :class:`tencentcloud.emr.v20190103.models.PodSpecInfo`
:param ClickHouseClusterName: 使用clickhouse集群扩容时，选择的机器分组名称
:type ClickHouseClusterName: str
:param ClickHouseClusterType: 使用clickhouse集群扩容时，选择的机器分组类型。new为新增，old为选择旧分组
:type ClickHouseClusterType: str
:param YarnNodeLabel: 扩容指定 Yarn Node Label
:type YarnNodeLabel: str
:param EnableStartServiceFlag: 扩容后是否启动服务，默认取值否
true：是
false：否
:type EnableStartServiceFlag: bool
:param ResourceSpec: 规格设置
:type ResourceSpec: :class:`tencentcloud.emr.v20190103.models.NodeResourceSpec`
:param Zone: 实例所属的可用区，例如ap-guangzhou-1。该参数也可以通过调用[DescribeZones](https://cloud.tencent.com/document/product/213/15707) 的返回值中的Zone字段来获取。
:type Zone: str
:param SubnetId: 子网，默认是集群创建时的子网
:type SubnetId: str
"""
self.InstanceChargeType = None
self.InstanceId = None
self.ScaleOutNodeConfig = None
self.ClientToken = None
self.InstanceChargePrepaid = None
self.ScriptBootstrapActionConfig = None
self.SoftDeployInfo = None
self.ServiceNodeInfo = None
self.DisasterRecoverGroupIds = None
self.Tags = None
self.HardwareSourceType = None
self.PodSpecInfo = None
self.ClickHouseClusterName = None
self.ClickHouseClusterType = None
self.YarnNodeLabel = None
self.EnableStartServiceFlag = None
self.ResourceSpec = None
self.Zone = None
self.SubnetId = None
def _deserialize(self, params):
self.InstanceChargeType = params.get("InstanceChargeType")
self.InstanceId = params.get("InstanceId")
if params.get("ScaleOutNodeConfig") is not None:
self.ScaleOutNodeConfig = ScaleOutNodeConfig()
self.ScaleOutNodeConfig._deserialize(params.get("ScaleOutNodeConfig"))
self.ClientToken = params.get("ClientToken")
if params.get("InstanceChargePrepaid") is not None:
self.InstanceChargePrepaid = InstanceChargePrepaid()
self.InstanceChargePrepaid._deserialize(params.get("InstanceChargePrepaid"))
if params.get("ScriptBootstrapActionConfig") is not None:
self.ScriptBootstrapActionConfig = []
for item in params.get("ScriptBootstrapActionConfig"):
obj = ScriptBootstrapActionConfig()
obj._deserialize(item)
self.ScriptBootstrapActionConfig.append(obj)
self.SoftDeployInfo = params.get("SoftDeployInfo")
self.ServiceNodeInfo = params.get("ServiceNodeInfo")
self.DisasterRecoverGroupIds = params.get("DisasterRecoverGroupIds")
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
self.HardwareSourceType = params.get("HardwareSourceType")
if params.get("PodSpecInfo") is not None:
self.PodSpecInfo = PodSpecInfo()
self.PodSpecInfo._deserialize(params.get("PodSpecInfo"))
self.ClickHouseClusterName = params.get("ClickHouseClusterName")
self.ClickHouseClusterType = params.get("ClickHouseClusterType")
self.YarnNodeLabel = params.get("YarnNodeLabel")
self.EnableStartServiceFlag = params.get("EnableStartServiceFlag")
if params.get("ResourceSpec") is not None:
self.ResourceSpec = NodeResourceSpec()
self.ResourceSpec._deserialize(params.get("ResourceSpec"))
self.Zone = params.get("Zone")
self.SubnetId = params.get("SubnetId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ScaleOutClusterResponse(AbstractModel):
"""ScaleOutCluster返回参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 实例ID。
:type InstanceId: str
:param ClientToken: 客户端Token。
注意：此字段可能返回 null，表示取不到有效值。
:type ClientToken: str
:param FlowId: 扩容流程ID。
注意：此字段可能返回 null，表示取不到有效值。
:type FlowId: int
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.InstanceId = None
self.ClientToken = None
self.FlowId = None
self.RequestId = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.ClientToken = params.get("ClientToken")
self.FlowId = params.get("FlowId")
self.RequestId = params.get("RequestId")
class ScaleOutInstanceRequest(AbstractModel):
"""ScaleOutInstance请求参数结构体
"""
def __init__(self):
r"""
:param TimeUnit: 扩容的时间单位。取值范围：
s：表示秒。PayMode取值为0时，TimeUnit只能取值为s。
m：表示月份。PayMode取值为1时，TimeUnit只能取值为m。
:type TimeUnit: str
:param TimeSpan: 扩容的时长。结合TimeUnit一起使用。
TimeUnit为s时，该参数只能填写3600，表示按量计费实例。
TimeUnit为m时，该参数填写的数字表示包年包月实例的购买时长，如1表示购买一个月
:type TimeSpan: int
:param InstanceId: 实例ID。
:type InstanceId: str
:param PayMode: 实例计费模式。取值范围：
0：表示按量计费。
1：表示包年包月。
:type PayMode: int
:param ClientToken: 客户端Token。
:type ClientToken: str
:param PreExecutedFileSettings: 引导操作脚本设置。
:type PreExecutedFileSettings: list of PreExecuteFileSettings
:param TaskCount: 扩容的Task节点数量。
:type TaskCount: int
:param CoreCount: 扩容的Core节点数量。
:type CoreCount: int
:param UnNecessaryNodeList: 扩容时不需要安装的进程。
:type UnNecessaryNodeList: list of int non-negative
:param RouterCount: 扩容的Router节点数量。
:type RouterCount: int
:param SoftDeployInfo: 部署的服务。
SoftDeployInfo和ServiceNodeInfo是同组参数，和UnNecessaryNodeList参数互斥。
建议使用SoftDeployInfo和ServiceNodeInfo组合。
:type SoftDeployInfo: list of int non-negative
:param ServiceNodeInfo: 启动的进程。
:type ServiceNodeInfo: list of int non-negative
:param DisasterRecoverGroupIds: 分散置放群组ID列表，当前仅支持指定一个。
:type DisasterRecoverGroupIds: list of str
:param Tags: 扩容节点绑定标签列表。
:type Tags: list of Tag
:param HardwareResourceType: 扩容所选资源类型，可选范围为"host","pod"，host为普通的CVM资源，Pod为TKE集群或EKS集群提供的资源
:type HardwareResourceType: str
:param PodSpec: 使用Pod资源扩容时，指定的Pod规格以及来源等信息
:type PodSpec: :class:`tencentcloud.emr.v20190103.models.PodSpec`
:param ClickHouseClusterName: 使用clickhouse集群扩容时，选择的机器分组名称
:type ClickHouseClusterName: str
:param ClickHouseClusterType: 使用clickhouse集群扩容时，选择的机器分组类型。new为新增，old为选择旧分组
:type ClickHouseClusterType: str
:param YarnNodeLabel: 规则扩容指定 yarn node label
:type YarnNodeLabel: str
:param PodParameter: POD自定义权限和自定义参数
:type PodParameter: :class:`tencentcloud.emr.v20190103.models.PodParameter`
:param MasterCount: 扩容的Master节点的数量。
使用clickhouse集群扩容时，该参数不生效。
使用kafka集群扩容时，该参数不生效。
当HardwareResourceType=POD时，该参数不生效。
:type MasterCount: int
:param StartServiceAfterScaleOut: 扩容后是否启动服务，true：启动，false：不启动
:type StartServiceAfterScaleOut: str
:param ZoneId: 可用区，默认是集群的主可用区
:type ZoneId: int
:param SubnetId: 子网，默认是集群创建时的子网
:type SubnetId: str
:param ScaleOutServiceConfAssign: 预设配置组
:type ScaleOutServiceConfAssign: str
:param AutoRenew: 0表示关闭自动续费，1表示开启自动续费
:type AutoRenew: int
"""
self.TimeUnit = None
self.TimeSpan = None
self.InstanceId = None
self.PayMode = None
self.ClientToken = None
self.PreExecutedFileSettings = None
self.TaskCount = None
self.CoreCount = None
self.UnNecessaryNodeList = None
self.RouterCount = None
self.SoftDeployInfo = None
self.ServiceNodeInfo = None
self.DisasterRecoverGroupIds = None
self.Tags = None
self.HardwareResourceType = None
self.PodSpec = None
self.ClickHouseClusterName = None
self.ClickHouseClusterType = None
self.YarnNodeLabel = None
self.PodParameter = None
self.MasterCount = None
self.StartServiceAfterScaleOut = None
self.ZoneId = None
self.SubnetId = None
self.ScaleOutServiceConfAssign = None
self.AutoRenew = None
def _deserialize(self, params):
self.TimeUnit = params.get("TimeUnit")
self.TimeSpan = params.get("TimeSpan")
self.InstanceId = params.get("InstanceId")
self.PayMode = params.get("PayMode")
self.ClientToken = params.get("ClientToken")
if params.get("PreExecutedFileSettings") is not None:
self.PreExecutedFileSettings = []
for item in params.get("PreExecutedFileSettings"):
obj = PreExecuteFileSettings()
obj._deserialize(item)
self.PreExecutedFileSettings.append(obj)
self.TaskCount = params.get("TaskCount")
self.CoreCount = params.get("CoreCount")
self.UnNecessaryNodeList = params.get("UnNecessaryNodeList")
self.RouterCount = params.get("RouterCount")
self.SoftDeployInfo = params.get("SoftDeployInfo")
self.ServiceNodeInfo = params.get("ServiceNodeInfo")
self.DisasterRecoverGroupIds = params.get("DisasterRecoverGroupIds")
if params.get("Tags") is not None:
self.Tags = []
for item in params.get("Tags"):
obj = Tag()
obj._deserialize(item)
self.Tags.append(obj)
self.HardwareResourceType = params.get("HardwareResourceType")
if params.get("PodSpec") is not None:
self.PodSpec = PodSpec()
self.PodSpec._deserialize(params.get("PodSpec"))
self.ClickHouseClusterName = params.get("ClickHouseClusterName")
self.ClickHouseClusterType = params.get("ClickHouseClusterType")
self.YarnNodeLabel = params.get("YarnNodeLabel")
if params.get("PodParameter") is not None:
self.PodParameter = PodParameter()
self.PodParameter._deserialize(params.get("PodParameter"))
self.MasterCount = params.get("MasterCount")
self.StartServiceAfterScaleOut = params.get("StartServiceAfterScaleOut")
self.ZoneId = params.get("ZoneId")
self.SubnetId = params.get("SubnetId")
self.ScaleOutServiceConfAssign = params.get("ScaleOutServiceConfAssign")
self.AutoRenew = params.get("AutoRenew")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ScaleOutInstanceResponse(AbstractModel):
"""ScaleOutInstance返回参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 实例ID。
:type InstanceId: str
:param DealNames: 订单号。
注意：此字段可能返回 null，表示取不到有效值。
:type DealNames: list of str
:param ClientToken: 客户端Token。
注意：此字段可能返回 null，表示取不到有效值。
:type ClientToken: str
:param FlowId: 扩容流程ID。
注意：此字段可能返回 null，表示取不到有效值。
:type FlowId: int
:param BillId: 大订单号。
注意：此字段可能返回 null，表示取不到有效值。
:type BillId: str
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.InstanceId = None
self.DealNames = None
self.ClientToken = None
self.FlowId = None
self.BillId = None
self.RequestId = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.DealNames = params.get("DealNames")
self.ClientToken = params.get("ClientToken")
self.FlowId = params.get("FlowId")
self.BillId = params.get("BillId")
self.RequestId = params.get("RequestId")
class ScaleOutNodeConfig(AbstractModel):
"""扩容节点类型以及数量
"""
def __init__(self):
r"""
:param NodeFlag: 扩容节点类型取值范围：
MASTER
TASK
CORE
ROUTER
:type NodeFlag: str
:param NodeCount: 扩容节点数量
:type NodeCount: int
"""
self.NodeFlag = None
self.NodeCount = None
def _deserialize(self, params):
self.NodeFlag = params.get("NodeFlag")
self.NodeCount = params.get("NodeCount")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class SceneSoftwareConfig(AbstractModel):
"""集群应用场景以及支持部署组件信息
"""
def __init__(self):
r"""
:param Software: 部署的组件列表。不同的EMR产品版本ProductVersion 对应不同可选组件列表，不同产品版本可选组件列表查询：[组件版本](https://cloud.tencent.com/document/product/589/20279) ；
填写实例值：hive、flink。
:type Software: list of str
:param SceneName: 默认Hadoop-Default,[场景查询](https://cloud.tencent.com/document/product/589/14624)场景化取值范围：
Hadoop-Kudu
Hadoop-Zookeeper
Hadoop-Presto
Hadoop-Hbase
Hadoop-Default
:type SceneName: str
"""
self.Software = None
self.SceneName = None
def _deserialize(self, params):
self.Software = params.get("Software")
self.SceneName = params.get("SceneName")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ScriptBootstrapActionConfig(AbstractModel):
"""添加引导操作
"""
def __init__(self):
r"""
:param CosFileURI: 脚本的cos地址，参照格式：https://beijing-111111.cos.ap-beijing.myqcloud.com/data/test.sh查询cos存储桶列表：[存储桶列表](https://console.cloud.tencent.com/cos/bucket)
:type CosFileURI: str
:param ExecutionMoment: 引导脚步执行时机范围
resourceAfter：节点初始化后
clusterAfter：集群启动后
clusterBefore：集群启动前
:type ExecutionMoment: str
:param Args: 执行脚本参数，参数格式请遵循标准Shell规范
:type Args: list of str
:param CosFileName: 脚本文件名
:type CosFileName: str
"""
self.CosFileURI = None
self.ExecutionMoment = None
self.Args = None
self.CosFileName = None
def _deserialize(self, params):
self.CosFileURI = params.get("CosFileURI")
self.ExecutionMoment = params.get("ExecutionMoment")
self.Args = params.get("Args")
self.CosFileName = params.get("CosFileName")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class SearchItem(AbstractModel):
"""搜索字段
"""
def __init__(self):
r"""
:param SearchType: 支持搜索的类型
:type SearchType: str
:param SearchValue: 支持搜索的值
:type SearchValue: str
"""
self.SearchType = None
self.SearchValue = None
def _deserialize(self, params):
self.SearchType = params.get("SearchType")
self.SearchValue = params.get("SearchValue")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ServiceBasicRestartInfo(AbstractModel):
"""操作的服务范围
"""
def __init__(self):
r"""
:param ServiceName: 服务名，必填，如HDFS
:type ServiceName: str
:param ComponentInfoList: 如果没传，则表示所有进程
:type ComponentInfoList: list of ComponentBasicRestartInfo
"""
self.ServiceName = None
self.ComponentInfoList = None
def _deserialize(self, params):
self.ServiceName = params.get("ServiceName")
if params.get("ComponentInfoList") is not None:
self.ComponentInfoList = []
for item in params.get("ComponentInfoList"):
obj = ComponentBasicRestartInfo()
obj._deserialize(item)
self.ComponentInfoList.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ShortNodeInfo(AbstractModel):
"""节点信息
"""
def __init__(self):
r"""
:param NodeType: 节点类型，Master/Core/Task/Router/Common
注意：此字段可能返回 null，表示取不到有效值。
:type NodeType: str
:param NodeSize: 节点数量
注意：此字段可能返回 null，表示取不到有效值。
:type NodeSize: int
"""
self.NodeType = None
self.NodeSize = None
def _deserialize(self, params):
self.NodeType = params.get("NodeType")
self.NodeSize = params.get("NodeSize")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class SoftDependInfo(AbstractModel):
"""体外客户端组件依赖信息
"""
def __init__(self):
r"""
:param SoftName: 组件名称
:type SoftName: str
:param Required: 是否必选
:type Required: bool
"""
self.SoftName = None
self.Required = None
def _deserialize(self, params):
self.SoftName = params.get("SoftName")
self.Required = params.get("Required")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class StartStopServiceOrMonitorRequest(AbstractModel):
"""StartStopServiceOrMonitor请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 集群ID
:type InstanceId: str
:param OpType: 操作类型，当前支持
StartService：启动服务
StopService：停止服务
StartMonitor：退出维护
StopMonitor：进入维护
:type OpType: str
:param OpScope: 操作范围
:type OpScope: :class:`tencentcloud.emr.v20190103.models.OpScope`
"""
self.InstanceId = None
self.OpType = None
self.OpScope = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.OpType = params.get("OpType")
if params.get("OpScope") is not None:
self.OpScope = OpScope()
self.OpScope._deserialize(params.get("OpScope"))
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class StartStopServiceOrMonitorResponse(AbstractModel):
"""StartStopServiceOrMonitor返回参数结构体
"""
def __init__(self):
r"""
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.RequestId = None
def _deserialize(self, params):
self.RequestId = params.get("RequestId")
class Step(AbstractModel):
"""执行步骤
"""
def __init__(self):
r"""
:param Name: 执行步骤名称。
:type Name: str
:param ExecutionStep: 执行动作。
:type ExecutionStep: :class:`tencentcloud.emr.v20190103.models.Execution`
:param ActionOnFailure: 执行失败策略。
1. TERMINATE_CLUSTER 执行失败时退出并销毁集群。
2. CONTINUE 执行失败时跳过并执行后续步骤。
:type ActionOnFailure: str
:param User: 指定执行Step时的用户名，非必须，默认为hadoop。
:type User: str
"""
self.Name = None
self.ExecutionStep = None
self.ActionOnFailure = None
self.User = None
def _deserialize(self, params):
self.Name = params.get("Name")
if params.get("ExecutionStep") is not None:
self.ExecutionStep = Execution()
self.ExecutionStep._deserialize(params.get("ExecutionStep"))
self.ActionOnFailure = params.get("ActionOnFailure")
self.User = params.get("User")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class SubnetInfo(AbstractModel):
"""子网信息
"""
def __init__(self):
r"""
:param SubnetName: 子网信息（名字）
注意：此字段可能返回 null，表示取不到有效值。
:type SubnetName: str
:param SubnetId: 子网信息（ID）
注意：此字段可能返回 null，表示取不到有效值。
:type SubnetId: str
"""
self.SubnetName = None
self.SubnetId = None
def _deserialize(self, params):
self.SubnetName = params.get("SubnetName")
self.SubnetId = params.get("SubnetId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class SyncPodStateRequest(AbstractModel):
"""SyncPodState请求参数结构体
"""
def __init__(self):
r"""
:param Message: EmrService中pod状态信息
:type Message: :class:`tencentcloud.emr.v20190103.models.PodState`
"""
self.Message = None
def _deserialize(self, params):
if params.get("Message") is not None:
self.Message = PodState()
self.Message._deserialize(params.get("Message"))
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class SyncPodStateResponse(AbstractModel):
"""SyncPodState返回参数结构体
"""
def __init__(self):
r"""
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.RequestId = None
def _deserialize(self, params):
self.RequestId = params.get("RequestId")
class Tag(AbstractModel):
"""标签
"""
def __init__(self):
r"""
:param TagKey: 标签键
:type TagKey: str
:param TagValue: 标签值
:type TagValue: str
"""
self.TagKey = None
self.TagValue = None
def _deserialize(self, params):
self.TagKey = params.get("TagKey")
self.TagValue = params.get("TagValue")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class TerminateClusterNodesRequest(AbstractModel):
"""TerminateClusterNodes请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 实例ID
:type InstanceId: str
:param CvmInstanceIds: 销毁资源列表
:type CvmInstanceIds: list of str
:param NodeFlag: 销毁节点类型取值范围：
MASTER
TASK
CORE
ROUTER
:type NodeFlag: str
:param GraceDownFlag: 优雅缩容开关
true:开启
false:不开启
:type GraceDownFlag: bool
:param GraceDownTime: 优雅缩容等待时间,时间范围60到1800 单位秒
:type GraceDownTime: int
"""
self.InstanceId = None
self.CvmInstanceIds = None
self.NodeFlag = None
self.GraceDownFlag = None
self.GraceDownTime = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.CvmInstanceIds = params.get("CvmInstanceIds")
self.NodeFlag = params.get("NodeFlag")
self.GraceDownFlag = params.get("GraceDownFlag")
self.GraceDownTime = params.get("GraceDownTime")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class TerminateClusterNodesResponse(AbstractModel):
"""TerminateClusterNodes返回参数结构体
"""
def __init__(self):
r"""
:param FlowId: 缩容流程ID。
:type FlowId: int
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.FlowId = None
self.RequestId = None
def _deserialize(self, params):
self.FlowId = params.get("FlowId")
self.RequestId = params.get("RequestId")
class TerminateInstanceRequest(AbstractModel):
"""TerminateInstance请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 实例ID。
:type InstanceId: str
:param ResourceIds: 销毁节点ID。该参数为预留参数，用户无需配置。
:type ResourceIds: list of str
"""
self.InstanceId = None
self.ResourceIds = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.ResourceIds = params.get("ResourceIds")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class TerminateInstanceResponse(AbstractModel):
"""TerminateInstance返回参数结构体
"""
def __init__(self):
r"""
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.RequestId = None
def _deserialize(self, params):
self.RequestId = params.get("RequestId")
class TerminateTasksRequest(AbstractModel):
"""TerminateTasks请求参数结构体
"""
def __init__(self):
r"""
:param InstanceId: 实例ID。
:type InstanceId: str
:param ResourceIds: 待销毁节点的资源ID列表。资源ID形如：emr-vm-xxxxxxxx。有效的资源ID可通过登录[控制台](https://console.cloud.tencent.com/emr/static/hardware)查询。
:type ResourceIds: list of str
"""
self.InstanceId = None
self.ResourceIds = None
def _deserialize(self, params):
self.InstanceId = params.get("InstanceId")
self.ResourceIds = params.get("ResourceIds")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class TerminateTasksResponse(AbstractModel):
"""TerminateTasks返回参数结构体
"""
def __init__(self):
r"""
:param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
:type RequestId: str
"""
self.RequestId = None
def _deserialize(self, params):
self.RequestId = params.get("RequestId")
class TopologyInfo(AbstractModel):
"""集群节点拓扑信息
"""
def __init__(self):
r"""
:param ZoneId: 可用区ID
注意：此字段可能返回 null，表示取不到有效值。
:type ZoneId: int
:param Zone: 可用区信息
注意：此字段可能返回 null，表示取不到有效值。
:type Zone: str
:param SubnetInfoList: 子网信息
注意：此字段可能返回 null，表示取不到有效值。
:type SubnetInfoList: list of SubnetInfo
:param NodeInfoList: 节点信息
注意：此字段可能返回 null，表示取不到有效值。
:type NodeInfoList: list of ShortNodeInfo
"""
self.ZoneId = None
self.Zone = None
self.SubnetInfoList = None
self.NodeInfoList = None
def _deserialize(self, params):
self.ZoneId = params.get("ZoneId")
self.Zone = params.get("Zone")
if params.get("SubnetInfoList") is not None:
self.SubnetInfoList = []
for item in params.get("SubnetInfoList"):
obj = SubnetInfo()
obj._deserialize(item)
self.SubnetInfoList.append(obj)
if params.get("NodeInfoList") is not None:
self.NodeInfoList = []
for item in params.get("NodeInfoList"):
obj = ShortNodeInfo()
obj._deserialize(item)
self.NodeInfoList.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class UpdateInstanceSettings(AbstractModel):
"""变配资源规格
"""
def __init__(self):
r"""
:param Memory: 内存容量，单位为G
:type Memory: int
:param CPUCores: CPU核数
:type CPUCores: int
:param ResourceId: 机器资源ID（EMR测资源标识）
:type ResourceId: str
:param InstanceType: 变配机器规格
:type InstanceType: str
"""
self.Memory = None
self.CPUCores = None
self.ResourceId = None
self.InstanceType = None
def _deserialize(self, params):
self.Memory = params.get("Memory")
self.CPUCores = params.get("CPUCores")
self.ResourceId = params.get("ResourceId")
self.InstanceType = params.get("InstanceType")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class UserInfoForUserManager(AbstractModel):
"""添加的用户信息列表
"""
def __init__(self):
r"""
:param UserName: 用户名
:type UserName: str
:param UserGroup: 用户所属的组
:type UserGroup: str
:param PassWord: 密码
:type PassWord: str
:param ReMark: 备注
:type ReMark: str
"""
self.UserName = None
self.UserGroup = None
self.PassWord = None
self.ReMark = None
def _deserialize(self, params):
self.UserName = params.get("UserName")
self.UserGroup = params.get("UserGroup")
self.PassWord = params.get("PassWord")
self.ReMark = params.get("ReMark")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class UserManagerFilter(AbstractModel):
"""用户管理列表过滤器
"""
def __init__(self):
r"""
:param UserName: 用户名
注意：此字段可能返回 null，表示取不到有效值。
:type UserName: str
"""
self.UserName = None
def _deserialize(self, params):
self.UserName = params.get("UserName")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class UserManagerUserBriefInfo(AbstractModel):
"""用户管理中用户的简要信息
"""
def __init__(self):
r"""
:param UserName: 用户名
:type UserName: str
:param UserGroup: 用户所属的组
:type UserGroup: str
:param UserType: Manager表示管理员、NormalUser表示普通用户
:type UserType: str
:param CreateTime: 用户创建时间
注意：此字段可能返回 null，表示取不到有效值。
:type CreateTime: str
:param SupportDownLoadKeyTab: 是否可以下载用户对应的keytab文件，对开启kerberos的集群才有意义
:type SupportDownLoadKeyTab: bool
:param DownLoadKeyTabUrl: keytab文件的下载地址
注意：此字段可能返回 null，表示取不到有效值。
:type DownLoadKeyTabUrl: str
"""
self.UserName = None
self.UserGroup = None
self.UserType = None
self.CreateTime = None
self.SupportDownLoadKeyTab = None
self.DownLoadKeyTabUrl = None
def _deserialize(self, params):
self.UserName = params.get("UserName")
self.UserGroup = params.get("UserGroup")
self.UserType = params.get("UserType")
self.CreateTime = params.get("CreateTime")
self.SupportDownLoadKeyTab = params.get("SupportDownLoadKeyTab")
self.DownLoadKeyTabUrl = params.get("DownLoadKeyTabUrl")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class VPCSettings(AbstractModel):
"""VPC 参数
"""
def __init__(self):
r"""
:param VpcId: VPC ID
:type VpcId: str
:param SubnetId: Subnet ID
:type SubnetId: str
"""
self.VpcId = None
self.SubnetId = None
def _deserialize(self, params):
self.VpcId = params.get("VpcId")
self.SubnetId = params.get("SubnetId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class VirtualPrivateCloud(AbstractModel):
"""VPC 参数
"""
def __init__(self):
r"""
:param VpcId: VPC ID
:type VpcId: str
:param SubnetId: Subnet ID
:type SubnetId: str
"""
self.VpcId = None
self.SubnetId = None
def _deserialize(self, params):
self.VpcId = params.get("VpcId")
self.SubnetId = params.get("SubnetId")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ZoneDetailPriceResult(AbstractModel):
"""用于创建集群价格清单 不同可用区下价格详情
"""
def __init__(self):
r"""
:param ZoneId: 可用区Id
注意：此字段可能返回 null，表示取不到有效值。
:type ZoneId: str
:param NodeDetailPrice: 不同节点的价格详情
:type NodeDetailPrice: list of NodeDetailPriceResult
"""
self.ZoneId = None
self.NodeDetailPrice = None
def _deserialize(self, params):
self.ZoneId = params.get("ZoneId")
if params.get("NodeDetailPrice") is not None:
self.NodeDetailPrice = []
for item in params.get("NodeDetailPrice"):
obj = NodeDetailPriceResult()
obj._deserialize(item)
self.NodeDetailPrice.append(obj)
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))
class ZoneResourceConfiguration(AbstractModel):
"""可用区配置信息
"""
def __init__(self):
r"""
:param VirtualPrivateCloud: 私有网络相关信息配置。通过该参数可以指定私有网络的ID，子网ID等信息。
注意：此字段可能返回 null，表示取不到有效值。
:type VirtualPrivateCloud: :class:`tencentcloud.emr.v20190103.models.VirtualPrivateCloud`
:param Placement: 实例所在的位置。通过该参数可以指定实例所属可用区，所属项目等属性。
注意：此字段可能返回 null，表示取不到有效值。
:type Placement: :class:`tencentcloud.emr.v20190103.models.Placement`
:param AllNodeResourceSpec: 所有节点资源的规格
注意：此字段可能返回 null，表示取不到有效值。
:type AllNodeResourceSpec: :class:`tencentcloud.emr.v20190103.models.AllNodeResourceSpec`
:param ZoneTag: 如果是单可用区，ZoneTag可以不用填， 如果是双AZ部署，第一个可用区ZoneTag选择master，第二个可用区ZoneTag选择standby，如果是三AZ部署，第一个可用区ZoneTag选择master，第二个可用区ZoneTag选择standby，第三个可用区ZoneTag选择third-party，取值范围：
master
standby
third-party
注意：此字段可能返回 null，表示取不到有效值。
:type ZoneTag: str
"""
self.VirtualPrivateCloud = None
self.Placement = None
self.AllNodeResourceSpec = None
self.ZoneTag = None
def _deserialize(self, params):
if params.get("VirtualPrivateCloud") is not None:
self.VirtualPrivateCloud = VirtualPrivateCloud()
self.VirtualPrivateCloud._deserialize(params.get("VirtualPrivateCloud"))
if params.get("Placement") is not None:
self.Placement = Placement()
self.Placement._deserialize(params.get("Placement"))
if params.get("AllNodeResourceSpec") is not None:
self.AllNodeResourceSpec = AllNodeResourceSpec()
self.AllNodeResourceSpec._deserialize(params.get("AllNodeResourceSpec"))
self.ZoneTag = params.get("ZoneTag")
memeber_set = set(params.keys())
for name, value in vars(self).items():
if name in memeber_set:
memeber_set.remove(name)
if len(memeber_set) > 0:
warnings.warn("%s fileds are useless." % ",".join(memeber_set))