ddi-20200617/alibabacloud_ddi20200617/models.py (6,663 lines of code) (raw):
# -*- coding: utf-8 -*-
# This file is auto-generated, don't edit it. Thanks.
from Tea.model import TeaModel
class CloneFlowJobRequest(TeaModel):
def __init__(self, id=None, name=None, project_id=None, region_id=None):
self.id = id # type: str
self.name = name # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(CloneFlowJobRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.name is not None:
result['Name'] = self.name
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class CloneFlowJobResponseBody(TeaModel):
def __init__(self, id=None, request_id=None):
self.id = id # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(CloneFlowJobResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class CloneFlowJobResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: CloneFlowJobResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(CloneFlowJobResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = CloneFlowJobResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class CreateClusterV2RequestBootstrapAction(TeaModel):
def __init__(self, arg=None, name=None, path=None):
self.arg = arg # type: str
self.name = name # type: str
self.path = path # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateClusterV2RequestBootstrapAction, self).to_map()
if _map is not None:
return _map
result = dict()
if self.arg is not None:
result['Arg'] = self.arg
if self.name is not None:
result['Name'] = self.name
if self.path is not None:
result['Path'] = self.path
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Arg') is not None:
self.arg = m.get('Arg')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('Path') is not None:
self.path = m.get('Path')
return self
class CreateClusterV2RequestConfig(TeaModel):
def __init__(self, config_key=None, config_value=None, encrypt=None, file_name=None, replace=None,
service_name=None):
self.config_key = config_key # type: str
self.config_value = config_value # type: str
self.encrypt = encrypt # type: str
self.file_name = file_name # type: str
self.replace = replace # type: str
self.service_name = service_name # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateClusterV2RequestConfig, self).to_map()
if _map is not None:
return _map
result = dict()
if self.config_key is not None:
result['ConfigKey'] = self.config_key
if self.config_value is not None:
result['ConfigValue'] = self.config_value
if self.encrypt is not None:
result['Encrypt'] = self.encrypt
if self.file_name is not None:
result['FileName'] = self.file_name
if self.replace is not None:
result['Replace'] = self.replace
if self.service_name is not None:
result['ServiceName'] = self.service_name
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ConfigKey') is not None:
self.config_key = m.get('ConfigKey')
if m.get('ConfigValue') is not None:
self.config_value = m.get('ConfigValue')
if m.get('Encrypt') is not None:
self.encrypt = m.get('Encrypt')
if m.get('FileName') is not None:
self.file_name = m.get('FileName')
if m.get('Replace') is not None:
self.replace = m.get('Replace')
if m.get('ServiceName') is not None:
self.service_name = m.get('ServiceName')
return self
class CreateClusterV2RequestHostComponentInfo(TeaModel):
def __init__(self, component_name_list=None, host_name=None, service_name=None):
self.component_name_list = component_name_list # type: list[str]
self.host_name = host_name # type: str
self.service_name = service_name # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateClusterV2RequestHostComponentInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.component_name_list is not None:
result['ComponentNameList'] = self.component_name_list
if self.host_name is not None:
result['HostName'] = self.host_name
if self.service_name is not None:
result['ServiceName'] = self.service_name
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ComponentNameList') is not None:
self.component_name_list = m.get('ComponentNameList')
if m.get('HostName') is not None:
self.host_name = m.get('HostName')
if m.get('ServiceName') is not None:
self.service_name = m.get('ServiceName')
return self
class CreateClusterV2RequestHostGroup(TeaModel):
def __init__(self, auto_renew=None, charge_type=None, cluster_id=None, comment=None, create_type=None,
disk_capacity=None, disk_count=None, disk_type=None, gpu_driver=None, host_group_id=None, host_group_name=None,
host_group_type=None, instance_type=None, node_count=None, period=None, sys_disk_capacity=None, sys_disk_type=None,
v_switch_id=None):
self.auto_renew = auto_renew # type: bool
self.charge_type = charge_type # type: str
self.cluster_id = cluster_id # type: str
self.comment = comment # type: str
self.create_type = create_type # type: str
self.disk_capacity = disk_capacity # type: int
self.disk_count = disk_count # type: int
self.disk_type = disk_type # type: str
self.gpu_driver = gpu_driver # type: str
self.host_group_id = host_group_id # type: str
self.host_group_name = host_group_name # type: str
self.host_group_type = host_group_type # type: str
self.instance_type = instance_type # type: str
self.node_count = node_count # type: int
self.period = period # type: int
self.sys_disk_capacity = sys_disk_capacity # type: int
self.sys_disk_type = sys_disk_type # type: str
self.v_switch_id = v_switch_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateClusterV2RequestHostGroup, self).to_map()
if _map is not None:
return _map
result = dict()
if self.auto_renew is not None:
result['AutoRenew'] = self.auto_renew
if self.charge_type is not None:
result['ChargeType'] = self.charge_type
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.comment is not None:
result['Comment'] = self.comment
if self.create_type is not None:
result['CreateType'] = self.create_type
if self.disk_capacity is not None:
result['DiskCapacity'] = self.disk_capacity
if self.disk_count is not None:
result['DiskCount'] = self.disk_count
if self.disk_type is not None:
result['DiskType'] = self.disk_type
if self.gpu_driver is not None:
result['GpuDriver'] = self.gpu_driver
if self.host_group_id is not None:
result['HostGroupId'] = self.host_group_id
if self.host_group_name is not None:
result['HostGroupName'] = self.host_group_name
if self.host_group_type is not None:
result['HostGroupType'] = self.host_group_type
if self.instance_type is not None:
result['InstanceType'] = self.instance_type
if self.node_count is not None:
result['NodeCount'] = self.node_count
if self.period is not None:
result['Period'] = self.period
if self.sys_disk_capacity is not None:
result['SysDiskCapacity'] = self.sys_disk_capacity
if self.sys_disk_type is not None:
result['SysDiskType'] = self.sys_disk_type
if self.v_switch_id is not None:
result['VSwitchId'] = self.v_switch_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('AutoRenew') is not None:
self.auto_renew = m.get('AutoRenew')
if m.get('ChargeType') is not None:
self.charge_type = m.get('ChargeType')
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('Comment') is not None:
self.comment = m.get('Comment')
if m.get('CreateType') is not None:
self.create_type = m.get('CreateType')
if m.get('DiskCapacity') is not None:
self.disk_capacity = m.get('DiskCapacity')
if m.get('DiskCount') is not None:
self.disk_count = m.get('DiskCount')
if m.get('DiskType') is not None:
self.disk_type = m.get('DiskType')
if m.get('GpuDriver') is not None:
self.gpu_driver = m.get('GpuDriver')
if m.get('HostGroupId') is not None:
self.host_group_id = m.get('HostGroupId')
if m.get('HostGroupName') is not None:
self.host_group_name = m.get('HostGroupName')
if m.get('HostGroupType') is not None:
self.host_group_type = m.get('HostGroupType')
if m.get('InstanceType') is not None:
self.instance_type = m.get('InstanceType')
if m.get('NodeCount') is not None:
self.node_count = m.get('NodeCount')
if m.get('Period') is not None:
self.period = m.get('Period')
if m.get('SysDiskCapacity') is not None:
self.sys_disk_capacity = m.get('SysDiskCapacity')
if m.get('SysDiskType') is not None:
self.sys_disk_type = m.get('SysDiskType')
if m.get('VSwitchId') is not None:
self.v_switch_id = m.get('VSwitchId')
return self
class CreateClusterV2RequestPromotionInfo(TeaModel):
def __init__(self, product_code=None, promotion_option_code=None, promotion_option_no=None):
self.product_code = product_code # type: str
self.promotion_option_code = promotion_option_code # type: str
self.promotion_option_no = promotion_option_no # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateClusterV2RequestPromotionInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.product_code is not None:
result['ProductCode'] = self.product_code
if self.promotion_option_code is not None:
result['PromotionOptionCode'] = self.promotion_option_code
if self.promotion_option_no is not None:
result['PromotionOptionNo'] = self.promotion_option_no
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ProductCode') is not None:
self.product_code = m.get('ProductCode')
if m.get('PromotionOptionCode') is not None:
self.promotion_option_code = m.get('PromotionOptionCode')
if m.get('PromotionOptionNo') is not None:
self.promotion_option_no = m.get('PromotionOptionNo')
return self
class CreateClusterV2RequestServiceInfo(TeaModel):
def __init__(self, service_name=None, service_version=None):
self.service_name = service_name # type: str
self.service_version = service_version # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateClusterV2RequestServiceInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.service_name is not None:
result['ServiceName'] = self.service_name
if self.service_version is not None:
result['ServiceVersion'] = self.service_version
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ServiceName') is not None:
self.service_name = m.get('ServiceName')
if m.get('ServiceVersion') is not None:
self.service_version = m.get('ServiceVersion')
return self
class CreateClusterV2RequestTag(TeaModel):
def __init__(self, key=None, value=None):
self.key = key # type: str
self.value = value # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateClusterV2RequestTag, self).to_map()
if _map is not None:
return _map
result = dict()
if self.key is not None:
result['Key'] = self.key
if self.value is not None:
result['Value'] = self.value
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Key') is not None:
self.key = m.get('Key')
if m.get('Value') is not None:
self.value = m.get('Value')
return self
class CreateClusterV2RequestUserInfo(TeaModel):
def __init__(self, password=None, user_id=None, user_name=None):
self.password = password # type: str
self.user_id = user_id # type: str
self.user_name = user_name # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateClusterV2RequestUserInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.password is not None:
result['Password'] = self.password
if self.user_id is not None:
result['UserId'] = self.user_id
if self.user_name is not None:
result['UserName'] = self.user_name
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Password') is not None:
self.password = m.get('Password')
if m.get('UserId') is not None:
self.user_id = m.get('UserId')
if m.get('UserName') is not None:
self.user_name = m.get('UserName')
return self
class CreateClusterV2Request(TeaModel):
def __init__(self, authorize_content=None, auto=None, auto_pay_order=None, bootstrap_action=None,
charge_type=None, click_house_conf=None, client_token=None, cluster_type=None, config=None,
configurations=None, deposit_type=None, emr_ver=None, enable_eas=None, enable_high_availability=None,
enable_ssh=None, extra_attributes=None, host_component_info=None, host_group=None,
init_custom_hive_meta_db=None, instance_generation=None, is_open_public_ip=None, key_pair_name=None, log_path=None,
machine_type=None, master_pwd=None, meta_store_conf=None, meta_store_type=None, name=None, net_type=None,
period=None, promotion_info=None, region_id=None, related_cluster_id=None, resource_group_id=None,
resource_owner_id=None, security_group_id=None, security_group_name=None, service_info=None, tag=None,
use_custom_hive_meta_db=None, use_local_meta_db=None, user_defined_emr_ecs_role=None, user_info=None, v_switch_id=None,
vpc_id=None, white_list_type=None, zone_id=None):
self.authorize_content = authorize_content # type: str
self.auto = auto # type: bool
self.auto_pay_order = auto_pay_order # type: bool
self.bootstrap_action = bootstrap_action # type: list[CreateClusterV2RequestBootstrapAction]
self.charge_type = charge_type # type: str
self.click_house_conf = click_house_conf # type: str
self.client_token = client_token # type: str
self.cluster_type = cluster_type # type: str
self.config = config # type: list[CreateClusterV2RequestConfig]
self.configurations = configurations # type: str
self.deposit_type = deposit_type # type: str
self.emr_ver = emr_ver # type: str
self.enable_eas = enable_eas # type: bool
self.enable_high_availability = enable_high_availability # type: bool
self.enable_ssh = enable_ssh # type: bool
self.extra_attributes = extra_attributes # type: str
self.host_component_info = host_component_info # type: list[CreateClusterV2RequestHostComponentInfo]
self.host_group = host_group # type: list[CreateClusterV2RequestHostGroup]
self.init_custom_hive_meta_db = init_custom_hive_meta_db # type: bool
self.instance_generation = instance_generation # type: str
self.is_open_public_ip = is_open_public_ip # type: bool
self.key_pair_name = key_pair_name # type: str
self.log_path = log_path # type: str
self.machine_type = machine_type # type: str
self.master_pwd = master_pwd # type: str
self.meta_store_conf = meta_store_conf # type: str
self.meta_store_type = meta_store_type # type: str
self.name = name # type: str
self.net_type = net_type # type: str
self.period = period # type: int
self.promotion_info = promotion_info # type: list[CreateClusterV2RequestPromotionInfo]
self.region_id = region_id # type: str
self.related_cluster_id = related_cluster_id # type: str
self.resource_group_id = resource_group_id # type: str
self.resource_owner_id = resource_owner_id # type: long
self.security_group_id = security_group_id # type: str
self.security_group_name = security_group_name # type: str
self.service_info = service_info # type: list[CreateClusterV2RequestServiceInfo]
self.tag = tag # type: list[CreateClusterV2RequestTag]
self.use_custom_hive_meta_db = use_custom_hive_meta_db # type: bool
self.use_local_meta_db = use_local_meta_db # type: bool
self.user_defined_emr_ecs_role = user_defined_emr_ecs_role # type: str
self.user_info = user_info # type: list[CreateClusterV2RequestUserInfo]
self.v_switch_id = v_switch_id # type: str
self.vpc_id = vpc_id # type: str
self.white_list_type = white_list_type # type: str
self.zone_id = zone_id # type: str
def validate(self):
if self.bootstrap_action:
for k in self.bootstrap_action:
if k:
k.validate()
if self.config:
for k in self.config:
if k:
k.validate()
if self.host_component_info:
for k in self.host_component_info:
if k:
k.validate()
if self.host_group:
for k in self.host_group:
if k:
k.validate()
if self.promotion_info:
for k in self.promotion_info:
if k:
k.validate()
if self.service_info:
for k in self.service_info:
if k:
k.validate()
if self.tag:
for k in self.tag:
if k:
k.validate()
if self.user_info:
for k in self.user_info:
if k:
k.validate()
def to_map(self):
_map = super(CreateClusterV2Request, self).to_map()
if _map is not None:
return _map
result = dict()
if self.authorize_content is not None:
result['AuthorizeContent'] = self.authorize_content
if self.auto is not None:
result['Auto'] = self.auto
if self.auto_pay_order is not None:
result['AutoPayOrder'] = self.auto_pay_order
result['BootstrapAction'] = []
if self.bootstrap_action is not None:
for k in self.bootstrap_action:
result['BootstrapAction'].append(k.to_map() if k else None)
if self.charge_type is not None:
result['ChargeType'] = self.charge_type
if self.click_house_conf is not None:
result['ClickHouseConf'] = self.click_house_conf
if self.client_token is not None:
result['ClientToken'] = self.client_token
if self.cluster_type is not None:
result['ClusterType'] = self.cluster_type
result['Config'] = []
if self.config is not None:
for k in self.config:
result['Config'].append(k.to_map() if k else None)
if self.configurations is not None:
result['Configurations'] = self.configurations
if self.deposit_type is not None:
result['DepositType'] = self.deposit_type
if self.emr_ver is not None:
result['EmrVer'] = self.emr_ver
if self.enable_eas is not None:
result['EnableEas'] = self.enable_eas
if self.enable_high_availability is not None:
result['EnableHighAvailability'] = self.enable_high_availability
if self.enable_ssh is not None:
result['EnableSsh'] = self.enable_ssh
if self.extra_attributes is not None:
result['ExtraAttributes'] = self.extra_attributes
result['HostComponentInfo'] = []
if self.host_component_info is not None:
for k in self.host_component_info:
result['HostComponentInfo'].append(k.to_map() if k else None)
result['HostGroup'] = []
if self.host_group is not None:
for k in self.host_group:
result['HostGroup'].append(k.to_map() if k else None)
if self.init_custom_hive_meta_db is not None:
result['InitCustomHiveMetaDB'] = self.init_custom_hive_meta_db
if self.instance_generation is not None:
result['InstanceGeneration'] = self.instance_generation
if self.is_open_public_ip is not None:
result['IsOpenPublicIp'] = self.is_open_public_ip
if self.key_pair_name is not None:
result['KeyPairName'] = self.key_pair_name
if self.log_path is not None:
result['LogPath'] = self.log_path
if self.machine_type is not None:
result['MachineType'] = self.machine_type
if self.master_pwd is not None:
result['MasterPwd'] = self.master_pwd
if self.meta_store_conf is not None:
result['MetaStoreConf'] = self.meta_store_conf
if self.meta_store_type is not None:
result['MetaStoreType'] = self.meta_store_type
if self.name is not None:
result['Name'] = self.name
if self.net_type is not None:
result['NetType'] = self.net_type
if self.period is not None:
result['Period'] = self.period
result['PromotionInfo'] = []
if self.promotion_info is not None:
for k in self.promotion_info:
result['PromotionInfo'].append(k.to_map() if k else None)
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.related_cluster_id is not None:
result['RelatedClusterId'] = self.related_cluster_id
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
if self.resource_owner_id is not None:
result['ResourceOwnerId'] = self.resource_owner_id
if self.security_group_id is not None:
result['SecurityGroupId'] = self.security_group_id
if self.security_group_name is not None:
result['SecurityGroupName'] = self.security_group_name
result['ServiceInfo'] = []
if self.service_info is not None:
for k in self.service_info:
result['ServiceInfo'].append(k.to_map() if k else None)
result['Tag'] = []
if self.tag is not None:
for k in self.tag:
result['Tag'].append(k.to_map() if k else None)
if self.use_custom_hive_meta_db is not None:
result['UseCustomHiveMetaDB'] = self.use_custom_hive_meta_db
if self.use_local_meta_db is not None:
result['UseLocalMetaDb'] = self.use_local_meta_db
if self.user_defined_emr_ecs_role is not None:
result['UserDefinedEmrEcsRole'] = self.user_defined_emr_ecs_role
result['UserInfo'] = []
if self.user_info is not None:
for k in self.user_info:
result['UserInfo'].append(k.to_map() if k else None)
if self.v_switch_id is not None:
result['VSwitchId'] = self.v_switch_id
if self.vpc_id is not None:
result['VpcId'] = self.vpc_id
if self.white_list_type is not None:
result['WhiteListType'] = self.white_list_type
if self.zone_id is not None:
result['ZoneId'] = self.zone_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('AuthorizeContent') is not None:
self.authorize_content = m.get('AuthorizeContent')
if m.get('Auto') is not None:
self.auto = m.get('Auto')
if m.get('AutoPayOrder') is not None:
self.auto_pay_order = m.get('AutoPayOrder')
self.bootstrap_action = []
if m.get('BootstrapAction') is not None:
for k in m.get('BootstrapAction'):
temp_model = CreateClusterV2RequestBootstrapAction()
self.bootstrap_action.append(temp_model.from_map(k))
if m.get('ChargeType') is not None:
self.charge_type = m.get('ChargeType')
if m.get('ClickHouseConf') is not None:
self.click_house_conf = m.get('ClickHouseConf')
if m.get('ClientToken') is not None:
self.client_token = m.get('ClientToken')
if m.get('ClusterType') is not None:
self.cluster_type = m.get('ClusterType')
self.config = []
if m.get('Config') is not None:
for k in m.get('Config'):
temp_model = CreateClusterV2RequestConfig()
self.config.append(temp_model.from_map(k))
if m.get('Configurations') is not None:
self.configurations = m.get('Configurations')
if m.get('DepositType') is not None:
self.deposit_type = m.get('DepositType')
if m.get('EmrVer') is not None:
self.emr_ver = m.get('EmrVer')
if m.get('EnableEas') is not None:
self.enable_eas = m.get('EnableEas')
if m.get('EnableHighAvailability') is not None:
self.enable_high_availability = m.get('EnableHighAvailability')
if m.get('EnableSsh') is not None:
self.enable_ssh = m.get('EnableSsh')
if m.get('ExtraAttributes') is not None:
self.extra_attributes = m.get('ExtraAttributes')
self.host_component_info = []
if m.get('HostComponentInfo') is not None:
for k in m.get('HostComponentInfo'):
temp_model = CreateClusterV2RequestHostComponentInfo()
self.host_component_info.append(temp_model.from_map(k))
self.host_group = []
if m.get('HostGroup') is not None:
for k in m.get('HostGroup'):
temp_model = CreateClusterV2RequestHostGroup()
self.host_group.append(temp_model.from_map(k))
if m.get('InitCustomHiveMetaDB') is not None:
self.init_custom_hive_meta_db = m.get('InitCustomHiveMetaDB')
if m.get('InstanceGeneration') is not None:
self.instance_generation = m.get('InstanceGeneration')
if m.get('IsOpenPublicIp') is not None:
self.is_open_public_ip = m.get('IsOpenPublicIp')
if m.get('KeyPairName') is not None:
self.key_pair_name = m.get('KeyPairName')
if m.get('LogPath') is not None:
self.log_path = m.get('LogPath')
if m.get('MachineType') is not None:
self.machine_type = m.get('MachineType')
if m.get('MasterPwd') is not None:
self.master_pwd = m.get('MasterPwd')
if m.get('MetaStoreConf') is not None:
self.meta_store_conf = m.get('MetaStoreConf')
if m.get('MetaStoreType') is not None:
self.meta_store_type = m.get('MetaStoreType')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('NetType') is not None:
self.net_type = m.get('NetType')
if m.get('Period') is not None:
self.period = m.get('Period')
self.promotion_info = []
if m.get('PromotionInfo') is not None:
for k in m.get('PromotionInfo'):
temp_model = CreateClusterV2RequestPromotionInfo()
self.promotion_info.append(temp_model.from_map(k))
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('RelatedClusterId') is not None:
self.related_cluster_id = m.get('RelatedClusterId')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
if m.get('ResourceOwnerId') is not None:
self.resource_owner_id = m.get('ResourceOwnerId')
if m.get('SecurityGroupId') is not None:
self.security_group_id = m.get('SecurityGroupId')
if m.get('SecurityGroupName') is not None:
self.security_group_name = m.get('SecurityGroupName')
self.service_info = []
if m.get('ServiceInfo') is not None:
for k in m.get('ServiceInfo'):
temp_model = CreateClusterV2RequestServiceInfo()
self.service_info.append(temp_model.from_map(k))
self.tag = []
if m.get('Tag') is not None:
for k in m.get('Tag'):
temp_model = CreateClusterV2RequestTag()
self.tag.append(temp_model.from_map(k))
if m.get('UseCustomHiveMetaDB') is not None:
self.use_custom_hive_meta_db = m.get('UseCustomHiveMetaDB')
if m.get('UseLocalMetaDb') is not None:
self.use_local_meta_db = m.get('UseLocalMetaDb')
if m.get('UserDefinedEmrEcsRole') is not None:
self.user_defined_emr_ecs_role = m.get('UserDefinedEmrEcsRole')
self.user_info = []
if m.get('UserInfo') is not None:
for k in m.get('UserInfo'):
temp_model = CreateClusterV2RequestUserInfo()
self.user_info.append(temp_model.from_map(k))
if m.get('VSwitchId') is not None:
self.v_switch_id = m.get('VSwitchId')
if m.get('VpcId') is not None:
self.vpc_id = m.get('VpcId')
if m.get('WhiteListType') is not None:
self.white_list_type = m.get('WhiteListType')
if m.get('ZoneId') is not None:
self.zone_id = m.get('ZoneId')
return self
class CreateClusterV2ResponseBody(TeaModel):
def __init__(self, cluster_id=None, core_order_id=None, emr_order_id=None, master_order_id=None,
request_id=None):
self.cluster_id = cluster_id # type: str
self.core_order_id = core_order_id # type: str
self.emr_order_id = emr_order_id # type: str
self.master_order_id = master_order_id # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateClusterV2ResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.core_order_id is not None:
result['CoreOrderId'] = self.core_order_id
if self.emr_order_id is not None:
result['EmrOrderId'] = self.emr_order_id
if self.master_order_id is not None:
result['MasterOrderId'] = self.master_order_id
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('CoreOrderId') is not None:
self.core_order_id = m.get('CoreOrderId')
if m.get('EmrOrderId') is not None:
self.emr_order_id = m.get('EmrOrderId')
if m.get('MasterOrderId') is not None:
self.master_order_id = m.get('MasterOrderId')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class CreateClusterV2Response(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: CreateClusterV2ResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(CreateClusterV2Response, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = CreateClusterV2ResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class CreateFlowRequest(TeaModel):
def __init__(self, alert_conf=None, alert_ding_ding_group_biz_id=None, alert_user_group_biz_id=None,
application=None, client_token=None, cluster_id=None, create_cluster=None, cron_expression=None,
description=None, end_schedule=None, host_name=None, name=None, namespace=None, parent_category=None,
parent_flow_list=None, project_id=None, region_id=None, start_schedule=None):
self.alert_conf = alert_conf # type: str
self.alert_ding_ding_group_biz_id = alert_ding_ding_group_biz_id # type: str
self.alert_user_group_biz_id = alert_user_group_biz_id # type: str
self.application = application # type: str
self.client_token = client_token # type: str
self.cluster_id = cluster_id # type: str
self.create_cluster = create_cluster # type: bool
self.cron_expression = cron_expression # type: str
self.description = description # type: str
self.end_schedule = end_schedule # type: long
self.host_name = host_name # type: str
self.name = name # type: str
self.namespace = namespace # type: str
self.parent_category = parent_category # type: str
self.parent_flow_list = parent_flow_list # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.start_schedule = start_schedule # type: long
def validate(self):
pass
def to_map(self):
_map = super(CreateFlowRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.alert_conf is not None:
result['AlertConf'] = self.alert_conf
if self.alert_ding_ding_group_biz_id is not None:
result['AlertDingDingGroupBizId'] = self.alert_ding_ding_group_biz_id
if self.alert_user_group_biz_id is not None:
result['AlertUserGroupBizId'] = self.alert_user_group_biz_id
if self.application is not None:
result['Application'] = self.application
if self.client_token is not None:
result['ClientToken'] = self.client_token
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.create_cluster is not None:
result['CreateCluster'] = self.create_cluster
if self.cron_expression is not None:
result['CronExpression'] = self.cron_expression
if self.description is not None:
result['Description'] = self.description
if self.end_schedule is not None:
result['EndSchedule'] = self.end_schedule
if self.host_name is not None:
result['HostName'] = self.host_name
if self.name is not None:
result['Name'] = self.name
if self.namespace is not None:
result['Namespace'] = self.namespace
if self.parent_category is not None:
result['ParentCategory'] = self.parent_category
if self.parent_flow_list is not None:
result['ParentFlowList'] = self.parent_flow_list
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.start_schedule is not None:
result['StartSchedule'] = self.start_schedule
return result
def from_map(self, m=None):
m = m or dict()
if m.get('AlertConf') is not None:
self.alert_conf = m.get('AlertConf')
if m.get('AlertDingDingGroupBizId') is not None:
self.alert_ding_ding_group_biz_id = m.get('AlertDingDingGroupBizId')
if m.get('AlertUserGroupBizId') is not None:
self.alert_user_group_biz_id = m.get('AlertUserGroupBizId')
if m.get('Application') is not None:
self.application = m.get('Application')
if m.get('ClientToken') is not None:
self.client_token = m.get('ClientToken')
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('CreateCluster') is not None:
self.create_cluster = m.get('CreateCluster')
if m.get('CronExpression') is not None:
self.cron_expression = m.get('CronExpression')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('EndSchedule') is not None:
self.end_schedule = m.get('EndSchedule')
if m.get('HostName') is not None:
self.host_name = m.get('HostName')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('Namespace') is not None:
self.namespace = m.get('Namespace')
if m.get('ParentCategory') is not None:
self.parent_category = m.get('ParentCategory')
if m.get('ParentFlowList') is not None:
self.parent_flow_list = m.get('ParentFlowList')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('StartSchedule') is not None:
self.start_schedule = m.get('StartSchedule')
return self
class CreateFlowResponseBody(TeaModel):
def __init__(self, id=None, request_id=None):
self.id = id # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateFlowResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class CreateFlowResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: CreateFlowResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(CreateFlowResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = CreateFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class CreateFlowCategoryRequest(TeaModel):
def __init__(self, client_token=None, name=None, parent_id=None, project_id=None, region_id=None, type=None):
self.client_token = client_token # type: str
self.name = name # type: str
self.parent_id = parent_id # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.type = type # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateFlowCategoryRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.client_token is not None:
result['ClientToken'] = self.client_token
if self.name is not None:
result['Name'] = self.name
if self.parent_id is not None:
result['ParentId'] = self.parent_id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClientToken') is not None:
self.client_token = m.get('ClientToken')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('ParentId') is not None:
self.parent_id = m.get('ParentId')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class CreateFlowCategoryResponseBody(TeaModel):
def __init__(self, id=None, request_id=None):
self.id = id # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateFlowCategoryResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class CreateFlowCategoryResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: CreateFlowCategoryResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(CreateFlowCategoryResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = CreateFlowCategoryResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class CreateFlowJobRequestResourceList(TeaModel):
def __init__(self, alias=None, path=None):
self.alias = alias # type: str
self.path = path # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateFlowJobRequestResourceList, self).to_map()
if _map is not None:
return _map
result = dict()
if self.alias is not None:
result['Alias'] = self.alias
if self.path is not None:
result['Path'] = self.path
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Alias') is not None:
self.alias = m.get('Alias')
if m.get('Path') is not None:
self.path = m.get('Path')
return self
class CreateFlowJobRequest(TeaModel):
def __init__(self, adhoc=None, alert_conf=None, client_token=None, cluster_id=None, custom_variables=None,
description=None, env_conf=None, fail_act=None, mode=None, monitor_conf=None, name=None, param_conf=None,
params=None, parent_category=None, project_id=None, region_id=None, resource_list=None, retry_policy=None,
run_conf=None, type=None):
self.adhoc = adhoc # type: bool
self.alert_conf = alert_conf # type: str
self.client_token = client_token # type: str
self.cluster_id = cluster_id # type: str
self.custom_variables = custom_variables # type: str
self.description = description # type: str
self.env_conf = env_conf # type: str
self.fail_act = fail_act # type: str
self.mode = mode # type: str
self.monitor_conf = monitor_conf # type: str
self.name = name # type: str
self.param_conf = param_conf # type: str
self.params = params # type: str
self.parent_category = parent_category # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.resource_list = resource_list # type: list[CreateFlowJobRequestResourceList]
self.retry_policy = retry_policy # type: str
self.run_conf = run_conf # type: str
self.type = type # type: str
def validate(self):
if self.resource_list:
for k in self.resource_list:
if k:
k.validate()
def to_map(self):
_map = super(CreateFlowJobRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.adhoc is not None:
result['Adhoc'] = self.adhoc
if self.alert_conf is not None:
result['AlertConf'] = self.alert_conf
if self.client_token is not None:
result['ClientToken'] = self.client_token
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.custom_variables is not None:
result['CustomVariables'] = self.custom_variables
if self.description is not None:
result['Description'] = self.description
if self.env_conf is not None:
result['EnvConf'] = self.env_conf
if self.fail_act is not None:
result['FailAct'] = self.fail_act
if self.mode is not None:
result['Mode'] = self.mode
if self.monitor_conf is not None:
result['MonitorConf'] = self.monitor_conf
if self.name is not None:
result['Name'] = self.name
if self.param_conf is not None:
result['ParamConf'] = self.param_conf
if self.params is not None:
result['Params'] = self.params
if self.parent_category is not None:
result['ParentCategory'] = self.parent_category
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
result['ResourceList'] = []
if self.resource_list is not None:
for k in self.resource_list:
result['ResourceList'].append(k.to_map() if k else None)
if self.retry_policy is not None:
result['RetryPolicy'] = self.retry_policy
if self.run_conf is not None:
result['RunConf'] = self.run_conf
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Adhoc') is not None:
self.adhoc = m.get('Adhoc')
if m.get('AlertConf') is not None:
self.alert_conf = m.get('AlertConf')
if m.get('ClientToken') is not None:
self.client_token = m.get('ClientToken')
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('CustomVariables') is not None:
self.custom_variables = m.get('CustomVariables')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('EnvConf') is not None:
self.env_conf = m.get('EnvConf')
if m.get('FailAct') is not None:
self.fail_act = m.get('FailAct')
if m.get('Mode') is not None:
self.mode = m.get('Mode')
if m.get('MonitorConf') is not None:
self.monitor_conf = m.get('MonitorConf')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('ParamConf') is not None:
self.param_conf = m.get('ParamConf')
if m.get('Params') is not None:
self.params = m.get('Params')
if m.get('ParentCategory') is not None:
self.parent_category = m.get('ParentCategory')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
self.resource_list = []
if m.get('ResourceList') is not None:
for k in m.get('ResourceList'):
temp_model = CreateFlowJobRequestResourceList()
self.resource_list.append(temp_model.from_map(k))
if m.get('RetryPolicy') is not None:
self.retry_policy = m.get('RetryPolicy')
if m.get('RunConf') is not None:
self.run_conf = m.get('RunConf')
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class CreateFlowJobResponseBody(TeaModel):
def __init__(self, id=None, request_id=None):
self.id = id # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateFlowJobResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class CreateFlowJobResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: CreateFlowJobResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(CreateFlowJobResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = CreateFlowJobResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class CreateFlowProjectRequest(TeaModel):
def __init__(self, client_token=None, description=None, name=None, product_type=None, region_id=None,
resource_group_id=None):
self.client_token = client_token # type: str
self.description = description # type: str
self.name = name # type: str
self.product_type = product_type # type: str
self.region_id = region_id # type: str
self.resource_group_id = resource_group_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateFlowProjectRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.client_token is not None:
result['ClientToken'] = self.client_token
if self.description is not None:
result['Description'] = self.description
if self.name is not None:
result['Name'] = self.name
if self.product_type is not None:
result['ProductType'] = self.product_type
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClientToken') is not None:
self.client_token = m.get('ClientToken')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('ProductType') is not None:
self.product_type = m.get('ProductType')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
return self
class CreateFlowProjectResponseBody(TeaModel):
def __init__(self, id=None, request_id=None):
self.id = id # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateFlowProjectResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class CreateFlowProjectResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: CreateFlowProjectResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(CreateFlowProjectResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = CreateFlowProjectResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class CreateFlowProjectUserRequestUser(TeaModel):
def __init__(self, user_id=None, user_name=None):
self.user_id = user_id # type: str
self.user_name = user_name # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateFlowProjectUserRequestUser, self).to_map()
if _map is not None:
return _map
result = dict()
if self.user_id is not None:
result['UserId'] = self.user_id
if self.user_name is not None:
result['UserName'] = self.user_name
return result
def from_map(self, m=None):
m = m or dict()
if m.get('UserId') is not None:
self.user_id = m.get('UserId')
if m.get('UserName') is not None:
self.user_name = m.get('UserName')
return self
class CreateFlowProjectUserRequest(TeaModel):
def __init__(self, client_token=None, project_id=None, region_id=None, user=None):
self.client_token = client_token # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.user = user # type: list[CreateFlowProjectUserRequestUser]
def validate(self):
if self.user:
for k in self.user:
if k:
k.validate()
def to_map(self):
_map = super(CreateFlowProjectUserRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.client_token is not None:
result['ClientToken'] = self.client_token
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
result['User'] = []
if self.user is not None:
for k in self.user:
result['User'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClientToken') is not None:
self.client_token = m.get('ClientToken')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
self.user = []
if m.get('User') is not None:
for k in m.get('User'):
temp_model = CreateFlowProjectUserRequestUser()
self.user.append(temp_model.from_map(k))
return self
class CreateFlowProjectUserResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(CreateFlowProjectUserResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class CreateFlowProjectUserResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: CreateFlowProjectUserResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(CreateFlowProjectUserResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = CreateFlowProjectUserResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DeleteFlowRequest(TeaModel):
def __init__(self, id=None, project_id=None, region_id=None):
self.id = id # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DeleteFlowRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class DeleteFlowResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DeleteFlowResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class DeleteFlowResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DeleteFlowResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(DeleteFlowResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DeleteFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DeleteFlowCategoryRequest(TeaModel):
def __init__(self, id=None, project_id=None, region_id=None):
self.id = id # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DeleteFlowCategoryRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class DeleteFlowCategoryResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DeleteFlowCategoryResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class DeleteFlowCategoryResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DeleteFlowCategoryResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(DeleteFlowCategoryResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DeleteFlowCategoryResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DeleteFlowProjectRequest(TeaModel):
def __init__(self, project_id=None, region_id=None):
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DeleteFlowProjectRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class DeleteFlowProjectResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DeleteFlowProjectResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class DeleteFlowProjectResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DeleteFlowProjectResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(DeleteFlowProjectResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DeleteFlowProjectResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DeleteFlowProjectUserRequest(TeaModel):
def __init__(self, project_id=None, region_id=None, user_name=None):
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.user_name = user_name # type: str
def validate(self):
pass
def to_map(self):
_map = super(DeleteFlowProjectUserRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.user_name is not None:
result['UserName'] = self.user_name
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('UserName') is not None:
self.user_name = m.get('UserName')
return self
class DeleteFlowProjectUserResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DeleteFlowProjectUserResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class DeleteFlowProjectUserResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DeleteFlowProjectUserResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(DeleteFlowProjectUserResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DeleteFlowProjectUserResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeClusterV2Request(TeaModel):
def __init__(self, id=None, region_id=None, resource_owner_id=None):
self.id = id # type: str
self.region_id = region_id # type: str
self.resource_owner_id = resource_owner_id # type: long
def validate(self):
pass
def to_map(self):
_map = super(DescribeClusterV2Request, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.resource_owner_id is not None:
result['ResourceOwnerId'] = self.resource_owner_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('ResourceOwnerId') is not None:
self.resource_owner_id = m.get('ResourceOwnerId')
return self
class DescribeClusterV2ResponseBodyClusterInfoAccessInfoZKLinksZKLink(TeaModel):
def __init__(self, link=None, port=None):
self.link = link # type: str
self.port = port # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoAccessInfoZKLinksZKLink, self).to_map()
if _map is not None:
return _map
result = dict()
if self.link is not None:
result['Link'] = self.link
if self.port is not None:
result['Port'] = self.port
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Link') is not None:
self.link = m.get('Link')
if m.get('Port') is not None:
self.port = m.get('Port')
return self
class DescribeClusterV2ResponseBodyClusterInfoAccessInfoZKLinks(TeaModel):
def __init__(self, zklink=None):
self.zklink = zklink # type: list[DescribeClusterV2ResponseBodyClusterInfoAccessInfoZKLinksZKLink]
def validate(self):
if self.zklink:
for k in self.zklink:
if k:
k.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoAccessInfoZKLinks, self).to_map()
if _map is not None:
return _map
result = dict()
result['ZKLink'] = []
if self.zklink is not None:
for k in self.zklink:
result['ZKLink'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.zklink = []
if m.get('ZKLink') is not None:
for k in m.get('ZKLink'):
temp_model = DescribeClusterV2ResponseBodyClusterInfoAccessInfoZKLinksZKLink()
self.zklink.append(temp_model.from_map(k))
return self
class DescribeClusterV2ResponseBodyClusterInfoAccessInfo(TeaModel):
def __init__(self, zklinks=None):
self.zklinks = zklinks # type: DescribeClusterV2ResponseBodyClusterInfoAccessInfoZKLinks
def validate(self):
if self.zklinks:
self.zklinks.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoAccessInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.zklinks is not None:
result['ZKLinks'] = self.zklinks.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ZKLinks') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoAccessInfoZKLinks()
self.zklinks = temp_model.from_map(m['ZKLinks'])
return self
class DescribeClusterV2ResponseBodyClusterInfoBootstrapActionListBootstrapAction(TeaModel):
def __init__(self, arg=None, name=None, path=None):
self.arg = arg # type: str
self.name = name # type: str
self.path = path # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoBootstrapActionListBootstrapAction, self).to_map()
if _map is not None:
return _map
result = dict()
if self.arg is not None:
result['Arg'] = self.arg
if self.name is not None:
result['Name'] = self.name
if self.path is not None:
result['Path'] = self.path
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Arg') is not None:
self.arg = m.get('Arg')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('Path') is not None:
self.path = m.get('Path')
return self
class DescribeClusterV2ResponseBodyClusterInfoBootstrapActionList(TeaModel):
def __init__(self, bootstrap_action=None):
self.bootstrap_action = bootstrap_action # type: list[DescribeClusterV2ResponseBodyClusterInfoBootstrapActionListBootstrapAction]
def validate(self):
if self.bootstrap_action:
for k in self.bootstrap_action:
if k:
k.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoBootstrapActionList, self).to_map()
if _map is not None:
return _map
result = dict()
result['BootstrapAction'] = []
if self.bootstrap_action is not None:
for k in self.bootstrap_action:
result['BootstrapAction'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.bootstrap_action = []
if m.get('BootstrapAction') is not None:
for k in m.get('BootstrapAction'):
temp_model = DescribeClusterV2ResponseBodyClusterInfoBootstrapActionListBootstrapAction()
self.bootstrap_action.append(temp_model.from_map(k))
return self
class DescribeClusterV2ResponseBodyClusterInfoFailReason(TeaModel):
def __init__(self, error_code=None, error_msg=None, request_id=None):
self.error_code = error_code # type: str
self.error_msg = error_msg # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoFailReason, self).to_map()
if _map is not None:
return _map
result = dict()
if self.error_code is not None:
result['ErrorCode'] = self.error_code
if self.error_msg is not None:
result['ErrorMsg'] = self.error_msg
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ErrorCode') is not None:
self.error_code = m.get('ErrorCode')
if m.get('ErrorMsg') is not None:
self.error_msg = m.get('ErrorMsg')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class DescribeClusterV2ResponseBodyClusterInfoGatewayClusterInfoListGatewayClusterInfo(TeaModel):
def __init__(self, cluster_id=None, cluster_name=None, status=None):
self.cluster_id = cluster_id # type: str
self.cluster_name = cluster_name # type: str
self.status = status # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoGatewayClusterInfoListGatewayClusterInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.cluster_name is not None:
result['ClusterName'] = self.cluster_name
if self.status is not None:
result['Status'] = self.status
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('ClusterName') is not None:
self.cluster_name = m.get('ClusterName')
if m.get('Status') is not None:
self.status = m.get('Status')
return self
class DescribeClusterV2ResponseBodyClusterInfoGatewayClusterInfoList(TeaModel):
def __init__(self, gateway_cluster_info=None):
self.gateway_cluster_info = gateway_cluster_info # type: list[DescribeClusterV2ResponseBodyClusterInfoGatewayClusterInfoListGatewayClusterInfo]
def validate(self):
if self.gateway_cluster_info:
for k in self.gateway_cluster_info:
if k:
k.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoGatewayClusterInfoList, self).to_map()
if _map is not None:
return _map
result = dict()
result['GatewayClusterInfo'] = []
if self.gateway_cluster_info is not None:
for k in self.gateway_cluster_info:
result['GatewayClusterInfo'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.gateway_cluster_info = []
if m.get('GatewayClusterInfo') is not None:
for k in m.get('GatewayClusterInfo'):
temp_model = DescribeClusterV2ResponseBodyClusterInfoGatewayClusterInfoListGatewayClusterInfo()
self.gateway_cluster_info.append(temp_model.from_map(k))
return self
class DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDaemonInfosDaemonInfo(TeaModel):
def __init__(self, name=None):
self.name = name # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDaemonInfosDaemonInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.name is not None:
result['Name'] = self.name
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Name') is not None:
self.name = m.get('Name')
return self
class DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDaemonInfos(TeaModel):
def __init__(self, daemon_info=None):
self.daemon_info = daemon_info # type: list[DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDaemonInfosDaemonInfo]
def validate(self):
if self.daemon_info:
for k in self.daemon_info:
if k:
k.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDaemonInfos, self).to_map()
if _map is not None:
return _map
result = dict()
result['DaemonInfo'] = []
if self.daemon_info is not None:
for k in self.daemon_info:
result['DaemonInfo'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.daemon_info = []
if m.get('DaemonInfo') is not None:
for k in m.get('DaemonInfo'):
temp_model = DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDaemonInfosDaemonInfo()
self.daemon_info.append(temp_model.from_map(k))
return self
class DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDiskInfosDiskInfo(TeaModel):
def __init__(self, device=None, disk_id=None, disk_name=None, size=None, type=None):
self.device = device # type: str
self.disk_id = disk_id # type: str
self.disk_name = disk_name # type: str
self.size = size # type: int
self.type = type # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDiskInfosDiskInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.device is not None:
result['Device'] = self.device
if self.disk_id is not None:
result['DiskId'] = self.disk_id
if self.disk_name is not None:
result['DiskName'] = self.disk_name
if self.size is not None:
result['Size'] = self.size
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Device') is not None:
self.device = m.get('Device')
if m.get('DiskId') is not None:
self.disk_id = m.get('DiskId')
if m.get('DiskName') is not None:
self.disk_name = m.get('DiskName')
if m.get('Size') is not None:
self.size = m.get('Size')
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDiskInfos(TeaModel):
def __init__(self, disk_info=None):
self.disk_info = disk_info # type: list[DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDiskInfosDiskInfo]
def validate(self):
if self.disk_info:
for k in self.disk_info:
if k:
k.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDiskInfos, self).to_map()
if _map is not None:
return _map
result = dict()
result['DiskInfo'] = []
if self.disk_info is not None:
for k in self.disk_info:
result['DiskInfo'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.disk_info = []
if m.get('DiskInfo') is not None:
for k in m.get('DiskInfo'):
temp_model = DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDiskInfosDiskInfo()
self.disk_info.append(temp_model.from_map(k))
return self
class DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNode(TeaModel):
def __init__(self, create_time=None, daemon_infos=None, disk_infos=None, emr_expired_time=None,
expired_time=None, inner_ip=None, instance_id=None, pub_ip=None, status=None, support_ip_v6=None, zone_id=None):
self.create_time = create_time # type: str
self.daemon_infos = daemon_infos # type: DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDaemonInfos
self.disk_infos = disk_infos # type: DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDiskInfos
self.emr_expired_time = emr_expired_time # type: str
self.expired_time = expired_time # type: str
self.inner_ip = inner_ip # type: str
self.instance_id = instance_id # type: str
self.pub_ip = pub_ip # type: str
self.status = status # type: str
self.support_ip_v6 = support_ip_v6 # type: bool
self.zone_id = zone_id # type: str
def validate(self):
if self.daemon_infos:
self.daemon_infos.validate()
if self.disk_infos:
self.disk_infos.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNode, self).to_map()
if _map is not None:
return _map
result = dict()
if self.create_time is not None:
result['CreateTime'] = self.create_time
if self.daemon_infos is not None:
result['DaemonInfos'] = self.daemon_infos.to_map()
if self.disk_infos is not None:
result['DiskInfos'] = self.disk_infos.to_map()
if self.emr_expired_time is not None:
result['EmrExpiredTime'] = self.emr_expired_time
if self.expired_time is not None:
result['ExpiredTime'] = self.expired_time
if self.inner_ip is not None:
result['InnerIp'] = self.inner_ip
if self.instance_id is not None:
result['InstanceId'] = self.instance_id
if self.pub_ip is not None:
result['PubIp'] = self.pub_ip
if self.status is not None:
result['Status'] = self.status
if self.support_ip_v6 is not None:
result['SupportIpV6'] = self.support_ip_v6
if self.zone_id is not None:
result['ZoneId'] = self.zone_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('DaemonInfos') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDaemonInfos()
self.daemon_infos = temp_model.from_map(m['DaemonInfos'])
if m.get('DiskInfos') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNodeDiskInfos()
self.disk_infos = temp_model.from_map(m['DiskInfos'])
if m.get('EmrExpiredTime') is not None:
self.emr_expired_time = m.get('EmrExpiredTime')
if m.get('ExpiredTime') is not None:
self.expired_time = m.get('ExpiredTime')
if m.get('InnerIp') is not None:
self.inner_ip = m.get('InnerIp')
if m.get('InstanceId') is not None:
self.instance_id = m.get('InstanceId')
if m.get('PubIp') is not None:
self.pub_ip = m.get('PubIp')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('SupportIpV6') is not None:
self.support_ip_v6 = m.get('SupportIpV6')
if m.get('ZoneId') is not None:
self.zone_id = m.get('ZoneId')
return self
class DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodes(TeaModel):
def __init__(self, node=None):
self.node = node # type: list[DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNode]
def validate(self):
if self.node:
for k in self.node:
if k:
k.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodes, self).to_map()
if _map is not None:
return _map
result = dict()
result['Node'] = []
if self.node is not None:
for k in self.node:
result['Node'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.node = []
if m.get('Node') is not None:
for k in m.get('Node'):
temp_model = DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodesNode()
self.node.append(temp_model.from_map(k))
return self
class DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroup(TeaModel):
def __init__(self, band_width=None, charge_type=None, cpu_core=None, disk_capacity=None, disk_count=None,
disk_type=None, host_group_change_status=None, host_group_change_type=None, host_group_id=None,
host_group_name=None, host_group_sub_type=None, host_group_type=None, instance_type=None, lock_reason=None,
lock_type=None, memory_capacity=None, node_count=None, nodes=None, period=None):
self.band_width = band_width # type: str
self.charge_type = charge_type # type: str
self.cpu_core = cpu_core # type: int
self.disk_capacity = disk_capacity # type: int
self.disk_count = disk_count # type: int
self.disk_type = disk_type # type: str
self.host_group_change_status = host_group_change_status # type: str
self.host_group_change_type = host_group_change_type # type: str
self.host_group_id = host_group_id # type: str
self.host_group_name = host_group_name # type: str
self.host_group_sub_type = host_group_sub_type # type: str
self.host_group_type = host_group_type # type: str
self.instance_type = instance_type # type: str
self.lock_reason = lock_reason # type: str
self.lock_type = lock_type # type: str
self.memory_capacity = memory_capacity # type: int
self.node_count = node_count # type: int
self.nodes = nodes # type: DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodes
self.period = period # type: str
def validate(self):
if self.nodes:
self.nodes.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroup, self).to_map()
if _map is not None:
return _map
result = dict()
if self.band_width is not None:
result['BandWidth'] = self.band_width
if self.charge_type is not None:
result['ChargeType'] = self.charge_type
if self.cpu_core is not None:
result['CpuCore'] = self.cpu_core
if self.disk_capacity is not None:
result['DiskCapacity'] = self.disk_capacity
if self.disk_count is not None:
result['DiskCount'] = self.disk_count
if self.disk_type is not None:
result['DiskType'] = self.disk_type
if self.host_group_change_status is not None:
result['HostGroupChangeStatus'] = self.host_group_change_status
if self.host_group_change_type is not None:
result['HostGroupChangeType'] = self.host_group_change_type
if self.host_group_id is not None:
result['HostGroupId'] = self.host_group_id
if self.host_group_name is not None:
result['HostGroupName'] = self.host_group_name
if self.host_group_sub_type is not None:
result['HostGroupSubType'] = self.host_group_sub_type
if self.host_group_type is not None:
result['HostGroupType'] = self.host_group_type
if self.instance_type is not None:
result['InstanceType'] = self.instance_type
if self.lock_reason is not None:
result['LockReason'] = self.lock_reason
if self.lock_type is not None:
result['LockType'] = self.lock_type
if self.memory_capacity is not None:
result['MemoryCapacity'] = self.memory_capacity
if self.node_count is not None:
result['NodeCount'] = self.node_count
if self.nodes is not None:
result['Nodes'] = self.nodes.to_map()
if self.period is not None:
result['Period'] = self.period
return result
def from_map(self, m=None):
m = m or dict()
if m.get('BandWidth') is not None:
self.band_width = m.get('BandWidth')
if m.get('ChargeType') is not None:
self.charge_type = m.get('ChargeType')
if m.get('CpuCore') is not None:
self.cpu_core = m.get('CpuCore')
if m.get('DiskCapacity') is not None:
self.disk_capacity = m.get('DiskCapacity')
if m.get('DiskCount') is not None:
self.disk_count = m.get('DiskCount')
if m.get('DiskType') is not None:
self.disk_type = m.get('DiskType')
if m.get('HostGroupChangeStatus') is not None:
self.host_group_change_status = m.get('HostGroupChangeStatus')
if m.get('HostGroupChangeType') is not None:
self.host_group_change_type = m.get('HostGroupChangeType')
if m.get('HostGroupId') is not None:
self.host_group_id = m.get('HostGroupId')
if m.get('HostGroupName') is not None:
self.host_group_name = m.get('HostGroupName')
if m.get('HostGroupSubType') is not None:
self.host_group_sub_type = m.get('HostGroupSubType')
if m.get('HostGroupType') is not None:
self.host_group_type = m.get('HostGroupType')
if m.get('InstanceType') is not None:
self.instance_type = m.get('InstanceType')
if m.get('LockReason') is not None:
self.lock_reason = m.get('LockReason')
if m.get('LockType') is not None:
self.lock_type = m.get('LockType')
if m.get('MemoryCapacity') is not None:
self.memory_capacity = m.get('MemoryCapacity')
if m.get('NodeCount') is not None:
self.node_count = m.get('NodeCount')
if m.get('Nodes') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroupNodes()
self.nodes = temp_model.from_map(m['Nodes'])
if m.get('Period') is not None:
self.period = m.get('Period')
return self
class DescribeClusterV2ResponseBodyClusterInfoHostGroupList(TeaModel):
def __init__(self, host_group=None):
self.host_group = host_group # type: list[DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroup]
def validate(self):
if self.host_group:
for k in self.host_group:
if k:
k.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoHostGroupList, self).to_map()
if _map is not None:
return _map
result = dict()
result['HostGroup'] = []
if self.host_group is not None:
for k in self.host_group:
result['HostGroup'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.host_group = []
if m.get('HostGroup') is not None:
for k in m.get('HostGroup'):
temp_model = DescribeClusterV2ResponseBodyClusterInfoHostGroupListHostGroup()
self.host_group.append(temp_model.from_map(k))
return self
class DescribeClusterV2ResponseBodyClusterInfoHostPoolInfo(TeaModel):
def __init__(self, hp_biz_id=None, hp_name=None):
self.hp_biz_id = hp_biz_id # type: str
self.hp_name = hp_name # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoHostPoolInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.hp_biz_id is not None:
result['HpBizId'] = self.hp_biz_id
if self.hp_name is not None:
result['HpName'] = self.hp_name
return result
def from_map(self, m=None):
m = m or dict()
if m.get('HpBizId') is not None:
self.hp_biz_id = m.get('HpBizId')
if m.get('HpName') is not None:
self.hp_name = m.get('HpName')
return self
class DescribeClusterV2ResponseBodyClusterInfoRelateClusterInfo(TeaModel):
def __init__(self, cluster_id=None, cluster_name=None, status=None):
self.cluster_id = cluster_id # type: str
self.cluster_name = cluster_name # type: str
self.status = status # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoRelateClusterInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.cluster_name is not None:
result['ClusterName'] = self.cluster_name
if self.status is not None:
result['Status'] = self.status
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('ClusterName') is not None:
self.cluster_name = m.get('ClusterName')
if m.get('Status') is not None:
self.status = m.get('Status')
return self
class DescribeClusterV2ResponseBodyClusterInfoSoftwareInfoSoftwaresSoftware(TeaModel):
def __init__(self, display_name=None, name=None, only_display=None, start_tpe=None, version=None):
self.display_name = display_name # type: str
self.name = name # type: str
self.only_display = only_display # type: bool
self.start_tpe = start_tpe # type: int
self.version = version # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoSoftwareInfoSoftwaresSoftware, self).to_map()
if _map is not None:
return _map
result = dict()
if self.display_name is not None:
result['DisplayName'] = self.display_name
if self.name is not None:
result['Name'] = self.name
if self.only_display is not None:
result['OnlyDisplay'] = self.only_display
if self.start_tpe is not None:
result['StartTpe'] = self.start_tpe
if self.version is not None:
result['Version'] = self.version
return result
def from_map(self, m=None):
m = m or dict()
if m.get('DisplayName') is not None:
self.display_name = m.get('DisplayName')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('OnlyDisplay') is not None:
self.only_display = m.get('OnlyDisplay')
if m.get('StartTpe') is not None:
self.start_tpe = m.get('StartTpe')
if m.get('Version') is not None:
self.version = m.get('Version')
return self
class DescribeClusterV2ResponseBodyClusterInfoSoftwareInfoSoftwares(TeaModel):
def __init__(self, software=None):
self.software = software # type: list[DescribeClusterV2ResponseBodyClusterInfoSoftwareInfoSoftwaresSoftware]
def validate(self):
if self.software:
for k in self.software:
if k:
k.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoSoftwareInfoSoftwares, self).to_map()
if _map is not None:
return _map
result = dict()
result['Software'] = []
if self.software is not None:
for k in self.software:
result['Software'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.software = []
if m.get('Software') is not None:
for k in m.get('Software'):
temp_model = DescribeClusterV2ResponseBodyClusterInfoSoftwareInfoSoftwaresSoftware()
self.software.append(temp_model.from_map(k))
return self
class DescribeClusterV2ResponseBodyClusterInfoSoftwareInfo(TeaModel):
def __init__(self, cluster_type=None, emr_ver=None, softwares=None):
self.cluster_type = cluster_type # type: str
self.emr_ver = emr_ver # type: str
self.softwares = softwares # type: DescribeClusterV2ResponseBodyClusterInfoSoftwareInfoSoftwares
def validate(self):
if self.softwares:
self.softwares.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfoSoftwareInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.cluster_type is not None:
result['ClusterType'] = self.cluster_type
if self.emr_ver is not None:
result['EmrVer'] = self.emr_ver
if self.softwares is not None:
result['Softwares'] = self.softwares.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClusterType') is not None:
self.cluster_type = m.get('ClusterType')
if m.get('EmrVer') is not None:
self.emr_ver = m.get('EmrVer')
if m.get('Softwares') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoSoftwareInfoSoftwares()
self.softwares = temp_model.from_map(m['Softwares'])
return self
class DescribeClusterV2ResponseBodyClusterInfo(TeaModel):
def __init__(self, access_info=None, auto_scaling_allowed=None, auto_scaling_by_load_allowed=None,
auto_scaling_enable=None, auto_scaling_spot_with_limit_allowed=None, auto_scaling_version=None,
auto_scaling_with_grace_allowed=None, bootstrap_action_list=None, bootstrap_failed=None, charge_type=None, configurations=None,
core_node_in_service=None, core_node_total=None, create_resource=None, create_type=None, deposit_type=None,
eas_enable=None, expired_time=None, extra_info=None, fail_reason=None, gateway_cluster_ids=None,
gateway_cluster_info_list=None, high_availability_enable=None, host_group_list=None, host_pool_info=None, id=None,
image_id=None, instance_generation=None, io_optimized=None, k_8s_cluster_id=None, local_meta_db=None,
log_enable=None, log_path=None, machine_type=None, master_node_in_service=None, master_node_total=None,
meta_store_type=None, name=None, net_type=None, period=None, region_id=None, relate_cluster_id=None,
relate_cluster_info=None, resize_disk_enable=None, running_time=None, security_group_id=None,
security_group_name=None, show_software_interface=None, software_info=None, start_time=None, status=None,
stop_time=None, task_node_in_service=None, task_node_total=None, user_defined_emr_ecs_role=None,
user_id=None, v_switch_id=None, vpc_id=None, zone_id=None):
self.access_info = access_info # type: DescribeClusterV2ResponseBodyClusterInfoAccessInfo
self.auto_scaling_allowed = auto_scaling_allowed # type: bool
self.auto_scaling_by_load_allowed = auto_scaling_by_load_allowed # type: bool
self.auto_scaling_enable = auto_scaling_enable # type: bool
self.auto_scaling_spot_with_limit_allowed = auto_scaling_spot_with_limit_allowed # type: bool
self.auto_scaling_version = auto_scaling_version # type: str
self.auto_scaling_with_grace_allowed = auto_scaling_with_grace_allowed # type: bool
self.bootstrap_action_list = bootstrap_action_list # type: DescribeClusterV2ResponseBodyClusterInfoBootstrapActionList
self.bootstrap_failed = bootstrap_failed # type: bool
self.charge_type = charge_type # type: str
self.configurations = configurations # type: str
self.core_node_in_service = core_node_in_service # type: int
self.core_node_total = core_node_total # type: int
self.create_resource = create_resource # type: str
self.create_type = create_type # type: str
self.deposit_type = deposit_type # type: str
self.eas_enable = eas_enable # type: bool
self.expired_time = expired_time # type: long
self.extra_info = extra_info # type: str
self.fail_reason = fail_reason # type: DescribeClusterV2ResponseBodyClusterInfoFailReason
self.gateway_cluster_ids = gateway_cluster_ids # type: str
self.gateway_cluster_info_list = gateway_cluster_info_list # type: DescribeClusterV2ResponseBodyClusterInfoGatewayClusterInfoList
self.high_availability_enable = high_availability_enable # type: bool
self.host_group_list = host_group_list # type: DescribeClusterV2ResponseBodyClusterInfoHostGroupList
self.host_pool_info = host_pool_info # type: DescribeClusterV2ResponseBodyClusterInfoHostPoolInfo
self.id = id # type: str
self.image_id = image_id # type: str
self.instance_generation = instance_generation # type: str
self.io_optimized = io_optimized # type: bool
self.k_8s_cluster_id = k_8s_cluster_id # type: str
self.local_meta_db = local_meta_db # type: bool
self.log_enable = log_enable # type: bool
self.log_path = log_path # type: str
self.machine_type = machine_type # type: str
self.master_node_in_service = master_node_in_service # type: int
self.master_node_total = master_node_total # type: int
self.meta_store_type = meta_store_type # type: str
self.name = name # type: str
self.net_type = net_type # type: str
self.period = period # type: int
self.region_id = region_id # type: str
self.relate_cluster_id = relate_cluster_id # type: str
self.relate_cluster_info = relate_cluster_info # type: DescribeClusterV2ResponseBodyClusterInfoRelateClusterInfo
self.resize_disk_enable = resize_disk_enable # type: bool
self.running_time = running_time # type: int
self.security_group_id = security_group_id # type: str
self.security_group_name = security_group_name # type: str
self.show_software_interface = show_software_interface # type: bool
self.software_info = software_info # type: DescribeClusterV2ResponseBodyClusterInfoSoftwareInfo
self.start_time = start_time # type: long
self.status = status # type: str
self.stop_time = stop_time # type: long
self.task_node_in_service = task_node_in_service # type: int
self.task_node_total = task_node_total # type: int
self.user_defined_emr_ecs_role = user_defined_emr_ecs_role # type: str
self.user_id = user_id # type: str
self.v_switch_id = v_switch_id # type: str
self.vpc_id = vpc_id # type: str
self.zone_id = zone_id # type: str
def validate(self):
if self.access_info:
self.access_info.validate()
if self.bootstrap_action_list:
self.bootstrap_action_list.validate()
if self.fail_reason:
self.fail_reason.validate()
if self.gateway_cluster_info_list:
self.gateway_cluster_info_list.validate()
if self.host_group_list:
self.host_group_list.validate()
if self.host_pool_info:
self.host_pool_info.validate()
if self.relate_cluster_info:
self.relate_cluster_info.validate()
if self.software_info:
self.software_info.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBodyClusterInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.access_info is not None:
result['AccessInfo'] = self.access_info.to_map()
if self.auto_scaling_allowed is not None:
result['AutoScalingAllowed'] = self.auto_scaling_allowed
if self.auto_scaling_by_load_allowed is not None:
result['AutoScalingByLoadAllowed'] = self.auto_scaling_by_load_allowed
if self.auto_scaling_enable is not None:
result['AutoScalingEnable'] = self.auto_scaling_enable
if self.auto_scaling_spot_with_limit_allowed is not None:
result['AutoScalingSpotWithLimitAllowed'] = self.auto_scaling_spot_with_limit_allowed
if self.auto_scaling_version is not None:
result['AutoScalingVersion'] = self.auto_scaling_version
if self.auto_scaling_with_grace_allowed is not None:
result['AutoScalingWithGraceAllowed'] = self.auto_scaling_with_grace_allowed
if self.bootstrap_action_list is not None:
result['BootstrapActionList'] = self.bootstrap_action_list.to_map()
if self.bootstrap_failed is not None:
result['BootstrapFailed'] = self.bootstrap_failed
if self.charge_type is not None:
result['ChargeType'] = self.charge_type
if self.configurations is not None:
result['Configurations'] = self.configurations
if self.core_node_in_service is not None:
result['CoreNodeInService'] = self.core_node_in_service
if self.core_node_total is not None:
result['CoreNodeTotal'] = self.core_node_total
if self.create_resource is not None:
result['CreateResource'] = self.create_resource
if self.create_type is not None:
result['CreateType'] = self.create_type
if self.deposit_type is not None:
result['DepositType'] = self.deposit_type
if self.eas_enable is not None:
result['EasEnable'] = self.eas_enable
if self.expired_time is not None:
result['ExpiredTime'] = self.expired_time
if self.extra_info is not None:
result['ExtraInfo'] = self.extra_info
if self.fail_reason is not None:
result['FailReason'] = self.fail_reason.to_map()
if self.gateway_cluster_ids is not None:
result['GatewayClusterIds'] = self.gateway_cluster_ids
if self.gateway_cluster_info_list is not None:
result['GatewayClusterInfoList'] = self.gateway_cluster_info_list.to_map()
if self.high_availability_enable is not None:
result['HighAvailabilityEnable'] = self.high_availability_enable
if self.host_group_list is not None:
result['HostGroupList'] = self.host_group_list.to_map()
if self.host_pool_info is not None:
result['HostPoolInfo'] = self.host_pool_info.to_map()
if self.id is not None:
result['Id'] = self.id
if self.image_id is not None:
result['ImageId'] = self.image_id
if self.instance_generation is not None:
result['InstanceGeneration'] = self.instance_generation
if self.io_optimized is not None:
result['IoOptimized'] = self.io_optimized
if self.k_8s_cluster_id is not None:
result['K8sClusterId'] = self.k_8s_cluster_id
if self.local_meta_db is not None:
result['LocalMetaDb'] = self.local_meta_db
if self.log_enable is not None:
result['LogEnable'] = self.log_enable
if self.log_path is not None:
result['LogPath'] = self.log_path
if self.machine_type is not None:
result['MachineType'] = self.machine_type
if self.master_node_in_service is not None:
result['MasterNodeInService'] = self.master_node_in_service
if self.master_node_total is not None:
result['MasterNodeTotal'] = self.master_node_total
if self.meta_store_type is not None:
result['MetaStoreType'] = self.meta_store_type
if self.name is not None:
result['Name'] = self.name
if self.net_type is not None:
result['NetType'] = self.net_type
if self.period is not None:
result['Period'] = self.period
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.relate_cluster_id is not None:
result['RelateClusterId'] = self.relate_cluster_id
if self.relate_cluster_info is not None:
result['RelateClusterInfo'] = self.relate_cluster_info.to_map()
if self.resize_disk_enable is not None:
result['ResizeDiskEnable'] = self.resize_disk_enable
if self.running_time is not None:
result['RunningTime'] = self.running_time
if self.security_group_id is not None:
result['SecurityGroupId'] = self.security_group_id
if self.security_group_name is not None:
result['SecurityGroupName'] = self.security_group_name
if self.show_software_interface is not None:
result['ShowSoftwareInterface'] = self.show_software_interface
if self.software_info is not None:
result['SoftwareInfo'] = self.software_info.to_map()
if self.start_time is not None:
result['StartTime'] = self.start_time
if self.status is not None:
result['Status'] = self.status
if self.stop_time is not None:
result['StopTime'] = self.stop_time
if self.task_node_in_service is not None:
result['TaskNodeInService'] = self.task_node_in_service
if self.task_node_total is not None:
result['TaskNodeTotal'] = self.task_node_total
if self.user_defined_emr_ecs_role is not None:
result['UserDefinedEmrEcsRole'] = self.user_defined_emr_ecs_role
if self.user_id is not None:
result['UserId'] = self.user_id
if self.v_switch_id is not None:
result['VSwitchId'] = self.v_switch_id
if self.vpc_id is not None:
result['VpcId'] = self.vpc_id
if self.zone_id is not None:
result['ZoneId'] = self.zone_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('AccessInfo') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoAccessInfo()
self.access_info = temp_model.from_map(m['AccessInfo'])
if m.get('AutoScalingAllowed') is not None:
self.auto_scaling_allowed = m.get('AutoScalingAllowed')
if m.get('AutoScalingByLoadAllowed') is not None:
self.auto_scaling_by_load_allowed = m.get('AutoScalingByLoadAllowed')
if m.get('AutoScalingEnable') is not None:
self.auto_scaling_enable = m.get('AutoScalingEnable')
if m.get('AutoScalingSpotWithLimitAllowed') is not None:
self.auto_scaling_spot_with_limit_allowed = m.get('AutoScalingSpotWithLimitAllowed')
if m.get('AutoScalingVersion') is not None:
self.auto_scaling_version = m.get('AutoScalingVersion')
if m.get('AutoScalingWithGraceAllowed') is not None:
self.auto_scaling_with_grace_allowed = m.get('AutoScalingWithGraceAllowed')
if m.get('BootstrapActionList') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoBootstrapActionList()
self.bootstrap_action_list = temp_model.from_map(m['BootstrapActionList'])
if m.get('BootstrapFailed') is not None:
self.bootstrap_failed = m.get('BootstrapFailed')
if m.get('ChargeType') is not None:
self.charge_type = m.get('ChargeType')
if m.get('Configurations') is not None:
self.configurations = m.get('Configurations')
if m.get('CoreNodeInService') is not None:
self.core_node_in_service = m.get('CoreNodeInService')
if m.get('CoreNodeTotal') is not None:
self.core_node_total = m.get('CoreNodeTotal')
if m.get('CreateResource') is not None:
self.create_resource = m.get('CreateResource')
if m.get('CreateType') is not None:
self.create_type = m.get('CreateType')
if m.get('DepositType') is not None:
self.deposit_type = m.get('DepositType')
if m.get('EasEnable') is not None:
self.eas_enable = m.get('EasEnable')
if m.get('ExpiredTime') is not None:
self.expired_time = m.get('ExpiredTime')
if m.get('ExtraInfo') is not None:
self.extra_info = m.get('ExtraInfo')
if m.get('FailReason') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoFailReason()
self.fail_reason = temp_model.from_map(m['FailReason'])
if m.get('GatewayClusterIds') is not None:
self.gateway_cluster_ids = m.get('GatewayClusterIds')
if m.get('GatewayClusterInfoList') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoGatewayClusterInfoList()
self.gateway_cluster_info_list = temp_model.from_map(m['GatewayClusterInfoList'])
if m.get('HighAvailabilityEnable') is not None:
self.high_availability_enable = m.get('HighAvailabilityEnable')
if m.get('HostGroupList') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoHostGroupList()
self.host_group_list = temp_model.from_map(m['HostGroupList'])
if m.get('HostPoolInfo') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoHostPoolInfo()
self.host_pool_info = temp_model.from_map(m['HostPoolInfo'])
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('ImageId') is not None:
self.image_id = m.get('ImageId')
if m.get('InstanceGeneration') is not None:
self.instance_generation = m.get('InstanceGeneration')
if m.get('IoOptimized') is not None:
self.io_optimized = m.get('IoOptimized')
if m.get('K8sClusterId') is not None:
self.k_8s_cluster_id = m.get('K8sClusterId')
if m.get('LocalMetaDb') is not None:
self.local_meta_db = m.get('LocalMetaDb')
if m.get('LogEnable') is not None:
self.log_enable = m.get('LogEnable')
if m.get('LogPath') is not None:
self.log_path = m.get('LogPath')
if m.get('MachineType') is not None:
self.machine_type = m.get('MachineType')
if m.get('MasterNodeInService') is not None:
self.master_node_in_service = m.get('MasterNodeInService')
if m.get('MasterNodeTotal') is not None:
self.master_node_total = m.get('MasterNodeTotal')
if m.get('MetaStoreType') is not None:
self.meta_store_type = m.get('MetaStoreType')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('NetType') is not None:
self.net_type = m.get('NetType')
if m.get('Period') is not None:
self.period = m.get('Period')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('RelateClusterId') is not None:
self.relate_cluster_id = m.get('RelateClusterId')
if m.get('RelateClusterInfo') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoRelateClusterInfo()
self.relate_cluster_info = temp_model.from_map(m['RelateClusterInfo'])
if m.get('ResizeDiskEnable') is not None:
self.resize_disk_enable = m.get('ResizeDiskEnable')
if m.get('RunningTime') is not None:
self.running_time = m.get('RunningTime')
if m.get('SecurityGroupId') is not None:
self.security_group_id = m.get('SecurityGroupId')
if m.get('SecurityGroupName') is not None:
self.security_group_name = m.get('SecurityGroupName')
if m.get('ShowSoftwareInterface') is not None:
self.show_software_interface = m.get('ShowSoftwareInterface')
if m.get('SoftwareInfo') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfoSoftwareInfo()
self.software_info = temp_model.from_map(m['SoftwareInfo'])
if m.get('StartTime') is not None:
self.start_time = m.get('StartTime')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('StopTime') is not None:
self.stop_time = m.get('StopTime')
if m.get('TaskNodeInService') is not None:
self.task_node_in_service = m.get('TaskNodeInService')
if m.get('TaskNodeTotal') is not None:
self.task_node_total = m.get('TaskNodeTotal')
if m.get('UserDefinedEmrEcsRole') is not None:
self.user_defined_emr_ecs_role = m.get('UserDefinedEmrEcsRole')
if m.get('UserId') is not None:
self.user_id = m.get('UserId')
if m.get('VSwitchId') is not None:
self.v_switch_id = m.get('VSwitchId')
if m.get('VpcId') is not None:
self.vpc_id = m.get('VpcId')
if m.get('ZoneId') is not None:
self.zone_id = m.get('ZoneId')
return self
class DescribeClusterV2ResponseBody(TeaModel):
def __init__(self, cluster_info=None, request_id=None):
self.cluster_info = cluster_info # type: DescribeClusterV2ResponseBodyClusterInfo
self.request_id = request_id # type: str
def validate(self):
if self.cluster_info:
self.cluster_info.validate()
def to_map(self):
_map = super(DescribeClusterV2ResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.cluster_info is not None:
result['ClusterInfo'] = self.cluster_info.to_map()
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClusterInfo') is not None:
temp_model = DescribeClusterV2ResponseBodyClusterInfo()
self.cluster_info = temp_model.from_map(m['ClusterInfo'])
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class DescribeClusterV2Response(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeClusterV2ResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeClusterV2Response, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeClusterV2ResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeFlowRequest(TeaModel):
def __init__(self, id=None, project_id=None, region_id=None):
self.id = id # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeFlowRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class DescribeFlowResponseBodyParentFlowListParentFlow(TeaModel):
def __init__(self, parent_flow_id=None, parent_flow_name=None, project_id=None, project_name=None):
self.parent_flow_id = parent_flow_id # type: str
self.parent_flow_name = parent_flow_name # type: str
self.project_id = project_id # type: str
self.project_name = project_name # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeFlowResponseBodyParentFlowListParentFlow, self).to_map()
if _map is not None:
return _map
result = dict()
if self.parent_flow_id is not None:
result['ParentFlowId'] = self.parent_flow_id
if self.parent_flow_name is not None:
result['ParentFlowName'] = self.parent_flow_name
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.project_name is not None:
result['ProjectName'] = self.project_name
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ParentFlowId') is not None:
self.parent_flow_id = m.get('ParentFlowId')
if m.get('ParentFlowName') is not None:
self.parent_flow_name = m.get('ParentFlowName')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('ProjectName') is not None:
self.project_name = m.get('ProjectName')
return self
class DescribeFlowResponseBodyParentFlowList(TeaModel):
def __init__(self, parent_flow=None):
self.parent_flow = parent_flow # type: list[DescribeFlowResponseBodyParentFlowListParentFlow]
def validate(self):
if self.parent_flow:
for k in self.parent_flow:
if k:
k.validate()
def to_map(self):
_map = super(DescribeFlowResponseBodyParentFlowList, self).to_map()
if _map is not None:
return _map
result = dict()
result['ParentFlow'] = []
if self.parent_flow is not None:
for k in self.parent_flow:
result['ParentFlow'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.parent_flow = []
if m.get('ParentFlow') is not None:
for k in m.get('ParentFlow'):
temp_model = DescribeFlowResponseBodyParentFlowListParentFlow()
self.parent_flow.append(temp_model.from_map(k))
return self
class DescribeFlowResponseBody(TeaModel):
def __init__(self, alert_conf=None, alert_ding_ding_group_biz_id=None, alert_user_group_biz_id=None,
application=None, category_id=None, cluster_id=None, create_cluster=None, cron_expr=None, description=None,
edit_lock_detail=None, end_schedule=None, gmt_create=None, gmt_modified=None, graph=None, host_name=None, id=None,
name=None, namespace=None, parent_flow_list=None, periodic=None, request_id=None, start_schedule=None,
status=None, type=None):
self.alert_conf = alert_conf # type: str
self.alert_ding_ding_group_biz_id = alert_ding_ding_group_biz_id # type: str
self.alert_user_group_biz_id = alert_user_group_biz_id # type: str
self.application = application # type: str
self.category_id = category_id # type: str
self.cluster_id = cluster_id # type: str
self.create_cluster = create_cluster # type: bool
self.cron_expr = cron_expr # type: str
self.description = description # type: str
self.edit_lock_detail = edit_lock_detail # type: str
self.end_schedule = end_schedule # type: long
self.gmt_create = gmt_create # type: long
self.gmt_modified = gmt_modified # type: long
self.graph = graph # type: str
self.host_name = host_name # type: str
self.id = id # type: str
self.name = name # type: str
self.namespace = namespace # type: str
self.parent_flow_list = parent_flow_list # type: DescribeFlowResponseBodyParentFlowList
self.periodic = periodic # type: bool
self.request_id = request_id # type: str
self.start_schedule = start_schedule # type: long
self.status = status # type: str
self.type = type # type: str
def validate(self):
if self.parent_flow_list:
self.parent_flow_list.validate()
def to_map(self):
_map = super(DescribeFlowResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.alert_conf is not None:
result['AlertConf'] = self.alert_conf
if self.alert_ding_ding_group_biz_id is not None:
result['AlertDingDingGroupBizId'] = self.alert_ding_ding_group_biz_id
if self.alert_user_group_biz_id is not None:
result['AlertUserGroupBizId'] = self.alert_user_group_biz_id
if self.application is not None:
result['Application'] = self.application
if self.category_id is not None:
result['CategoryId'] = self.category_id
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.create_cluster is not None:
result['CreateCluster'] = self.create_cluster
if self.cron_expr is not None:
result['CronExpr'] = self.cron_expr
if self.description is not None:
result['Description'] = self.description
if self.edit_lock_detail is not None:
result['EditLockDetail'] = self.edit_lock_detail
if self.end_schedule is not None:
result['EndSchedule'] = self.end_schedule
if self.gmt_create is not None:
result['GmtCreate'] = self.gmt_create
if self.gmt_modified is not None:
result['GmtModified'] = self.gmt_modified
if self.graph is not None:
result['Graph'] = self.graph
if self.host_name is not None:
result['HostName'] = self.host_name
if self.id is not None:
result['Id'] = self.id
if self.name is not None:
result['Name'] = self.name
if self.namespace is not None:
result['Namespace'] = self.namespace
if self.parent_flow_list is not None:
result['ParentFlowList'] = self.parent_flow_list.to_map()
if self.periodic is not None:
result['Periodic'] = self.periodic
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.start_schedule is not None:
result['StartSchedule'] = self.start_schedule
if self.status is not None:
result['Status'] = self.status
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('AlertConf') is not None:
self.alert_conf = m.get('AlertConf')
if m.get('AlertDingDingGroupBizId') is not None:
self.alert_ding_ding_group_biz_id = m.get('AlertDingDingGroupBizId')
if m.get('AlertUserGroupBizId') is not None:
self.alert_user_group_biz_id = m.get('AlertUserGroupBizId')
if m.get('Application') is not None:
self.application = m.get('Application')
if m.get('CategoryId') is not None:
self.category_id = m.get('CategoryId')
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('CreateCluster') is not None:
self.create_cluster = m.get('CreateCluster')
if m.get('CronExpr') is not None:
self.cron_expr = m.get('CronExpr')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('EditLockDetail') is not None:
self.edit_lock_detail = m.get('EditLockDetail')
if m.get('EndSchedule') is not None:
self.end_schedule = m.get('EndSchedule')
if m.get('GmtCreate') is not None:
self.gmt_create = m.get('GmtCreate')
if m.get('GmtModified') is not None:
self.gmt_modified = m.get('GmtModified')
if m.get('Graph') is not None:
self.graph = m.get('Graph')
if m.get('HostName') is not None:
self.host_name = m.get('HostName')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('Namespace') is not None:
self.namespace = m.get('Namespace')
if m.get('ParentFlowList') is not None:
temp_model = DescribeFlowResponseBodyParentFlowList()
self.parent_flow_list = temp_model.from_map(m['ParentFlowList'])
if m.get('Periodic') is not None:
self.periodic = m.get('Periodic')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('StartSchedule') is not None:
self.start_schedule = m.get('StartSchedule')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class DescribeFlowResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeFlowResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeFlowResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeFlowCategoryTreeRequest(TeaModel):
def __init__(self, category_id=None, keyword=None, mode=None, project_id=None, region_id=None, type=None):
self.category_id = category_id # type: str
self.keyword = keyword # type: str
self.mode = mode # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.type = type # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeFlowCategoryTreeRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.category_id is not None:
result['CategoryId'] = self.category_id
if self.keyword is not None:
result['Keyword'] = self.keyword
if self.mode is not None:
result['Mode'] = self.mode
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('CategoryId') is not None:
self.category_id = m.get('CategoryId')
if m.get('Keyword') is not None:
self.keyword = m.get('Keyword')
if m.get('Mode') is not None:
self.mode = m.get('Mode')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class DescribeFlowCategoryTreeResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeFlowCategoryTreeResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class DescribeFlowCategoryTreeResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeFlowCategoryTreeResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeFlowCategoryTreeResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeFlowCategoryTreeResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeFlowJobRequest(TeaModel):
def __init__(self, id=None, project_id=None, region_id=None):
self.id = id # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeFlowJobRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class DescribeFlowJobResponseBodyResourceListResource(TeaModel):
def __init__(self, alias=None, path=None):
self.alias = alias # type: str
self.path = path # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeFlowJobResponseBodyResourceListResource, self).to_map()
if _map is not None:
return _map
result = dict()
if self.alias is not None:
result['Alias'] = self.alias
if self.path is not None:
result['Path'] = self.path
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Alias') is not None:
self.alias = m.get('Alias')
if m.get('Path') is not None:
self.path = m.get('Path')
return self
class DescribeFlowJobResponseBodyResourceList(TeaModel):
def __init__(self, resource=None):
self.resource = resource # type: list[DescribeFlowJobResponseBodyResourceListResource]
def validate(self):
if self.resource:
for k in self.resource:
if k:
k.validate()
def to_map(self):
_map = super(DescribeFlowJobResponseBodyResourceList, self).to_map()
if _map is not None:
return _map
result = dict()
result['Resource'] = []
if self.resource is not None:
for k in self.resource:
result['Resource'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.resource = []
if m.get('Resource') is not None:
for k in m.get('Resource'):
temp_model = DescribeFlowJobResponseBodyResourceListResource()
self.resource.append(temp_model.from_map(k))
return self
class DescribeFlowJobResponseBody(TeaModel):
def __init__(self, adhoc=None, alert_conf=None, category_id=None, custom_variables=None, description=None,
edit_lock_detail=None, env_conf=None, fail_act=None, gmt_create=None, gmt_modified=None, id=None, knox_password=None,
knox_user=None, last_instance_id=None, max_retry=None, max_running_time_sec=None, mode=None,
monitor_conf=None, name=None, param_conf=None, params=None, request_id=None, resource_list=None,
retry_interval=None, retry_policy=None, run_conf=None, type=None):
self.adhoc = adhoc # type: str
self.alert_conf = alert_conf # type: str
self.category_id = category_id # type: str
self.custom_variables = custom_variables # type: str
self.description = description # type: str
self.edit_lock_detail = edit_lock_detail # type: str
self.env_conf = env_conf # type: str
self.fail_act = fail_act # type: str
self.gmt_create = gmt_create # type: long
self.gmt_modified = gmt_modified # type: long
self.id = id # type: str
self.knox_password = knox_password # type: str
self.knox_user = knox_user # type: str
self.last_instance_id = last_instance_id # type: str
self.max_retry = max_retry # type: int
self.max_running_time_sec = max_running_time_sec # type: long
self.mode = mode # type: str
self.monitor_conf = monitor_conf # type: str
self.name = name # type: str
self.param_conf = param_conf # type: str
self.params = params # type: str
self.request_id = request_id # type: str
self.resource_list = resource_list # type: DescribeFlowJobResponseBodyResourceList
self.retry_interval = retry_interval # type: long
self.retry_policy = retry_policy # type: str
self.run_conf = run_conf # type: str
self.type = type # type: str
def validate(self):
if self.resource_list:
self.resource_list.validate()
def to_map(self):
_map = super(DescribeFlowJobResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.adhoc is not None:
result['Adhoc'] = self.adhoc
if self.alert_conf is not None:
result['AlertConf'] = self.alert_conf
if self.category_id is not None:
result['CategoryId'] = self.category_id
if self.custom_variables is not None:
result['CustomVariables'] = self.custom_variables
if self.description is not None:
result['Description'] = self.description
if self.edit_lock_detail is not None:
result['EditLockDetail'] = self.edit_lock_detail
if self.env_conf is not None:
result['EnvConf'] = self.env_conf
if self.fail_act is not None:
result['FailAct'] = self.fail_act
if self.gmt_create is not None:
result['GmtCreate'] = self.gmt_create
if self.gmt_modified is not None:
result['GmtModified'] = self.gmt_modified
if self.id is not None:
result['Id'] = self.id
if self.knox_password is not None:
result['KnoxPassword'] = self.knox_password
if self.knox_user is not None:
result['KnoxUser'] = self.knox_user
if self.last_instance_id is not None:
result['LastInstanceId'] = self.last_instance_id
if self.max_retry is not None:
result['MaxRetry'] = self.max_retry
if self.max_running_time_sec is not None:
result['MaxRunningTimeSec'] = self.max_running_time_sec
if self.mode is not None:
result['Mode'] = self.mode
if self.monitor_conf is not None:
result['MonitorConf'] = self.monitor_conf
if self.name is not None:
result['Name'] = self.name
if self.param_conf is not None:
result['ParamConf'] = self.param_conf
if self.params is not None:
result['Params'] = self.params
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.resource_list is not None:
result['ResourceList'] = self.resource_list.to_map()
if self.retry_interval is not None:
result['RetryInterval'] = self.retry_interval
if self.retry_policy is not None:
result['RetryPolicy'] = self.retry_policy
if self.run_conf is not None:
result['RunConf'] = self.run_conf
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Adhoc') is not None:
self.adhoc = m.get('Adhoc')
if m.get('AlertConf') is not None:
self.alert_conf = m.get('AlertConf')
if m.get('CategoryId') is not None:
self.category_id = m.get('CategoryId')
if m.get('CustomVariables') is not None:
self.custom_variables = m.get('CustomVariables')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('EditLockDetail') is not None:
self.edit_lock_detail = m.get('EditLockDetail')
if m.get('EnvConf') is not None:
self.env_conf = m.get('EnvConf')
if m.get('FailAct') is not None:
self.fail_act = m.get('FailAct')
if m.get('GmtCreate') is not None:
self.gmt_create = m.get('GmtCreate')
if m.get('GmtModified') is not None:
self.gmt_modified = m.get('GmtModified')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('KnoxPassword') is not None:
self.knox_password = m.get('KnoxPassword')
if m.get('KnoxUser') is not None:
self.knox_user = m.get('KnoxUser')
if m.get('LastInstanceId') is not None:
self.last_instance_id = m.get('LastInstanceId')
if m.get('MaxRetry') is not None:
self.max_retry = m.get('MaxRetry')
if m.get('MaxRunningTimeSec') is not None:
self.max_running_time_sec = m.get('MaxRunningTimeSec')
if m.get('Mode') is not None:
self.mode = m.get('Mode')
if m.get('MonitorConf') is not None:
self.monitor_conf = m.get('MonitorConf')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('ParamConf') is not None:
self.param_conf = m.get('ParamConf')
if m.get('Params') is not None:
self.params = m.get('Params')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('ResourceList') is not None:
temp_model = DescribeFlowJobResponseBodyResourceList()
self.resource_list = temp_model.from_map(m['ResourceList'])
if m.get('RetryInterval') is not None:
self.retry_interval = m.get('RetryInterval')
if m.get('RetryPolicy') is not None:
self.retry_policy = m.get('RetryPolicy')
if m.get('RunConf') is not None:
self.run_conf = m.get('RunConf')
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class DescribeFlowJobResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeFlowJobResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeFlowJobResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeFlowJobResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeFlowNodeInstanceRequest(TeaModel):
def __init__(self, id=None, project_id=None, region_id=None):
self.id = id # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeFlowNodeInstanceRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class DescribeFlowNodeInstanceResponseBody(TeaModel):
def __init__(self, adhoc=None, cluster_id=None, cluster_name=None, duration=None, end_time=None, env_conf=None,
external_child_ids=None, external_id=None, external_info=None, external_status=None, external_sub_id=None,
fail_act=None, flow_id=None, flow_instance_id=None, gmt_create=None, gmt_modified=None, host_name=None,
id=None, job_id=None, job_name=None, job_params=None, job_type=None, max_retry=None, mode=None,
monitor_conf=None, node_name=None, param_conf=None, pending=None, project_id=None, request_id=None, retries=None,
retry_interval=None, retry_policy=None, run_conf=None, start_time=None, status=None, type=None):
self.adhoc = adhoc # type: bool
self.cluster_id = cluster_id # type: str
self.cluster_name = cluster_name # type: str
self.duration = duration # type: long
self.end_time = end_time # type: long
self.env_conf = env_conf # type: str
self.external_child_ids = external_child_ids # type: str
self.external_id = external_id # type: str
self.external_info = external_info # type: str
self.external_status = external_status # type: str
self.external_sub_id = external_sub_id # type: str
self.fail_act = fail_act # type: str
self.flow_id = flow_id # type: str
self.flow_instance_id = flow_instance_id # type: str
self.gmt_create = gmt_create # type: long
self.gmt_modified = gmt_modified # type: long
self.host_name = host_name # type: str
self.id = id # type: str
self.job_id = job_id # type: str
self.job_name = job_name # type: str
self.job_params = job_params # type: str
self.job_type = job_type # type: str
self.max_retry = max_retry # type: str
self.mode = mode # type: str
self.monitor_conf = monitor_conf # type: str
self.node_name = node_name # type: str
self.param_conf = param_conf # type: str
self.pending = pending # type: bool
self.project_id = project_id # type: str
self.request_id = request_id # type: str
self.retries = retries # type: int
self.retry_interval = retry_interval # type: str
self.retry_policy = retry_policy # type: str
self.run_conf = run_conf # type: str
self.start_time = start_time # type: long
self.status = status # type: str
self.type = type # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeFlowNodeInstanceResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.adhoc is not None:
result['Adhoc'] = self.adhoc
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.cluster_name is not None:
result['ClusterName'] = self.cluster_name
if self.duration is not None:
result['Duration'] = self.duration
if self.end_time is not None:
result['EndTime'] = self.end_time
if self.env_conf is not None:
result['EnvConf'] = self.env_conf
if self.external_child_ids is not None:
result['ExternalChildIds'] = self.external_child_ids
if self.external_id is not None:
result['ExternalId'] = self.external_id
if self.external_info is not None:
result['ExternalInfo'] = self.external_info
if self.external_status is not None:
result['ExternalStatus'] = self.external_status
if self.external_sub_id is not None:
result['ExternalSubId'] = self.external_sub_id
if self.fail_act is not None:
result['FailAct'] = self.fail_act
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.flow_instance_id is not None:
result['FlowInstanceId'] = self.flow_instance_id
if self.gmt_create is not None:
result['GmtCreate'] = self.gmt_create
if self.gmt_modified is not None:
result['GmtModified'] = self.gmt_modified
if self.host_name is not None:
result['HostName'] = self.host_name
if self.id is not None:
result['Id'] = self.id
if self.job_id is not None:
result['JobId'] = self.job_id
if self.job_name is not None:
result['JobName'] = self.job_name
if self.job_params is not None:
result['JobParams'] = self.job_params
if self.job_type is not None:
result['JobType'] = self.job_type
if self.max_retry is not None:
result['MaxRetry'] = self.max_retry
if self.mode is not None:
result['Mode'] = self.mode
if self.monitor_conf is not None:
result['MonitorConf'] = self.monitor_conf
if self.node_name is not None:
result['NodeName'] = self.node_name
if self.param_conf is not None:
result['ParamConf'] = self.param_conf
if self.pending is not None:
result['Pending'] = self.pending
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.retries is not None:
result['Retries'] = self.retries
if self.retry_interval is not None:
result['RetryInterval'] = self.retry_interval
if self.retry_policy is not None:
result['RetryPolicy'] = self.retry_policy
if self.run_conf is not None:
result['RunConf'] = self.run_conf
if self.start_time is not None:
result['StartTime'] = self.start_time
if self.status is not None:
result['Status'] = self.status
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Adhoc') is not None:
self.adhoc = m.get('Adhoc')
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('ClusterName') is not None:
self.cluster_name = m.get('ClusterName')
if m.get('Duration') is not None:
self.duration = m.get('Duration')
if m.get('EndTime') is not None:
self.end_time = m.get('EndTime')
if m.get('EnvConf') is not None:
self.env_conf = m.get('EnvConf')
if m.get('ExternalChildIds') is not None:
self.external_child_ids = m.get('ExternalChildIds')
if m.get('ExternalId') is not None:
self.external_id = m.get('ExternalId')
if m.get('ExternalInfo') is not None:
self.external_info = m.get('ExternalInfo')
if m.get('ExternalStatus') is not None:
self.external_status = m.get('ExternalStatus')
if m.get('ExternalSubId') is not None:
self.external_sub_id = m.get('ExternalSubId')
if m.get('FailAct') is not None:
self.fail_act = m.get('FailAct')
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('FlowInstanceId') is not None:
self.flow_instance_id = m.get('FlowInstanceId')
if m.get('GmtCreate') is not None:
self.gmt_create = m.get('GmtCreate')
if m.get('GmtModified') is not None:
self.gmt_modified = m.get('GmtModified')
if m.get('HostName') is not None:
self.host_name = m.get('HostName')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('JobId') is not None:
self.job_id = m.get('JobId')
if m.get('JobName') is not None:
self.job_name = m.get('JobName')
if m.get('JobParams') is not None:
self.job_params = m.get('JobParams')
if m.get('JobType') is not None:
self.job_type = m.get('JobType')
if m.get('MaxRetry') is not None:
self.max_retry = m.get('MaxRetry')
if m.get('Mode') is not None:
self.mode = m.get('Mode')
if m.get('MonitorConf') is not None:
self.monitor_conf = m.get('MonitorConf')
if m.get('NodeName') is not None:
self.node_name = m.get('NodeName')
if m.get('ParamConf') is not None:
self.param_conf = m.get('ParamConf')
if m.get('Pending') is not None:
self.pending = m.get('Pending')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Retries') is not None:
self.retries = m.get('Retries')
if m.get('RetryInterval') is not None:
self.retry_interval = m.get('RetryInterval')
if m.get('RetryPolicy') is not None:
self.retry_policy = m.get('RetryPolicy')
if m.get('RunConf') is not None:
self.run_conf = m.get('RunConf')
if m.get('StartTime') is not None:
self.start_time = m.get('StartTime')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class DescribeFlowNodeInstanceResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeFlowNodeInstanceResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeFlowNodeInstanceResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeFlowNodeInstanceResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeFlowProjectRequest(TeaModel):
def __init__(self, project_id=None, region_id=None):
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeFlowProjectRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class DescribeFlowProjectResponseBody(TeaModel):
def __init__(self, description=None, gmt_create=None, gmt_modified=None, id=None, name=None, request_id=None,
user_id=None):
self.description = description # type: str
self.gmt_create = gmt_create # type: long
self.gmt_modified = gmt_modified # type: long
self.id = id # type: str
self.name = name # type: str
self.request_id = request_id # type: str
self.user_id = user_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeFlowProjectResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.description is not None:
result['Description'] = self.description
if self.gmt_create is not None:
result['GmtCreate'] = self.gmt_create
if self.gmt_modified is not None:
result['GmtModified'] = self.gmt_modified
if self.id is not None:
result['Id'] = self.id
if self.name is not None:
result['Name'] = self.name
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.user_id is not None:
result['UserId'] = self.user_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('GmtCreate') is not None:
self.gmt_create = m.get('GmtCreate')
if m.get('GmtModified') is not None:
self.gmt_modified = m.get('GmtModified')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('UserId') is not None:
self.user_id = m.get('UserId')
return self
class DescribeFlowProjectResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeFlowProjectResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeFlowProjectResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeFlowProjectResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class KillFlowJobRequest(TeaModel):
def __init__(self, job_instance_id=None, project_id=None, region_id=None):
self.job_instance_id = job_instance_id # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(KillFlowJobRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.job_instance_id is not None:
result['JobInstanceId'] = self.job_instance_id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('JobInstanceId') is not None:
self.job_instance_id = m.get('JobInstanceId')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class KillFlowJobResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(KillFlowJobResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class KillFlowJobResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: KillFlowJobResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(KillFlowJobResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = KillFlowJobResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListClustersRequestTag(TeaModel):
def __init__(self, key=None, value=None):
self.key = key # type: str
self.value = value # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListClustersRequestTag, self).to_map()
if _map is not None:
return _map
result = dict()
if self.key is not None:
result['Key'] = self.key
if self.value is not None:
result['Value'] = self.value
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Key') is not None:
self.key = m.get('Key')
if m.get('Value') is not None:
self.value = m.get('Value')
return self
class ListClustersRequest(TeaModel):
def __init__(self, cluster_type_list=None, create_type=None, default_status=None, deposit_type=None,
expired_tag_list=None, is_desc=None, machine_type=None, name=None, page_number=None, page_size=None, region_id=None,
resource_group_id=None, resource_owner_id=None, status_list=None, tag=None):
self.cluster_type_list = cluster_type_list # type: list[str]
self.create_type = create_type # type: str
self.default_status = default_status # type: bool
self.deposit_type = deposit_type # type: str
self.expired_tag_list = expired_tag_list # type: list[str]
self.is_desc = is_desc # type: bool
self.machine_type = machine_type # type: str
self.name = name # type: str
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.region_id = region_id # type: str
self.resource_group_id = resource_group_id # type: str
self.resource_owner_id = resource_owner_id # type: long
self.status_list = status_list # type: list[str]
self.tag = tag # type: list[ListClustersRequestTag]
def validate(self):
if self.tag:
for k in self.tag:
if k:
k.validate()
def to_map(self):
_map = super(ListClustersRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.cluster_type_list is not None:
result['ClusterTypeList'] = self.cluster_type_list
if self.create_type is not None:
result['CreateType'] = self.create_type
if self.default_status is not None:
result['DefaultStatus'] = self.default_status
if self.deposit_type is not None:
result['DepositType'] = self.deposit_type
if self.expired_tag_list is not None:
result['ExpiredTagList'] = self.expired_tag_list
if self.is_desc is not None:
result['IsDesc'] = self.is_desc
if self.machine_type is not None:
result['MachineType'] = self.machine_type
if self.name is not None:
result['Name'] = self.name
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
if self.resource_owner_id is not None:
result['ResourceOwnerId'] = self.resource_owner_id
if self.status_list is not None:
result['StatusList'] = self.status_list
result['Tag'] = []
if self.tag is not None:
for k in self.tag:
result['Tag'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClusterTypeList') is not None:
self.cluster_type_list = m.get('ClusterTypeList')
if m.get('CreateType') is not None:
self.create_type = m.get('CreateType')
if m.get('DefaultStatus') is not None:
self.default_status = m.get('DefaultStatus')
if m.get('DepositType') is not None:
self.deposit_type = m.get('DepositType')
if m.get('ExpiredTagList') is not None:
self.expired_tag_list = m.get('ExpiredTagList')
if m.get('IsDesc') is not None:
self.is_desc = m.get('IsDesc')
if m.get('MachineType') is not None:
self.machine_type = m.get('MachineType')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
if m.get('ResourceOwnerId') is not None:
self.resource_owner_id = m.get('ResourceOwnerId')
if m.get('StatusList') is not None:
self.status_list = m.get('StatusList')
self.tag = []
if m.get('Tag') is not None:
for k in m.get('Tag'):
temp_model = ListClustersRequestTag()
self.tag.append(temp_model.from_map(k))
return self
class ListClustersResponseBodyClustersClusterInfoFailReason(TeaModel):
def __init__(self, error_code=None, error_msg=None, request_id=None):
self.error_code = error_code # type: str
self.error_msg = error_msg # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListClustersResponseBodyClustersClusterInfoFailReason, self).to_map()
if _map is not None:
return _map
result = dict()
if self.error_code is not None:
result['ErrorCode'] = self.error_code
if self.error_msg is not None:
result['ErrorMsg'] = self.error_msg
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ErrorCode') is not None:
self.error_code = m.get('ErrorCode')
if m.get('ErrorMsg') is not None:
self.error_msg = m.get('ErrorMsg')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class ListClustersResponseBodyClustersClusterInfoOrderTaskInfo(TeaModel):
def __init__(self, current_count=None, order_id_list=None, target_count=None):
self.current_count = current_count # type: int
self.order_id_list = order_id_list # type: str
self.target_count = target_count # type: int
def validate(self):
pass
def to_map(self):
_map = super(ListClustersResponseBodyClustersClusterInfoOrderTaskInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.current_count is not None:
result['CurrentCount'] = self.current_count
if self.order_id_list is not None:
result['OrderIdList'] = self.order_id_list
if self.target_count is not None:
result['TargetCount'] = self.target_count
return result
def from_map(self, m=None):
m = m or dict()
if m.get('CurrentCount') is not None:
self.current_count = m.get('CurrentCount')
if m.get('OrderIdList') is not None:
self.order_id_list = m.get('OrderIdList')
if m.get('TargetCount') is not None:
self.target_count = m.get('TargetCount')
return self
class ListClustersResponseBodyClustersClusterInfoTagsTag(TeaModel):
def __init__(self, tag_key=None, tag_value=None):
self.tag_key = tag_key # type: str
self.tag_value = tag_value # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListClustersResponseBodyClustersClusterInfoTagsTag, self).to_map()
if _map is not None:
return _map
result = dict()
if self.tag_key is not None:
result['TagKey'] = self.tag_key
if self.tag_value is not None:
result['TagValue'] = self.tag_value
return result
def from_map(self, m=None):
m = m or dict()
if m.get('TagKey') is not None:
self.tag_key = m.get('TagKey')
if m.get('TagValue') is not None:
self.tag_value = m.get('TagValue')
return self
class ListClustersResponseBodyClustersClusterInfoTags(TeaModel):
def __init__(self, tag=None):
self.tag = tag # type: list[ListClustersResponseBodyClustersClusterInfoTagsTag]
def validate(self):
if self.tag:
for k in self.tag:
if k:
k.validate()
def to_map(self):
_map = super(ListClustersResponseBodyClustersClusterInfoTags, self).to_map()
if _map is not None:
return _map
result = dict()
result['Tag'] = []
if self.tag is not None:
for k in self.tag:
result['Tag'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.tag = []
if m.get('Tag') is not None:
for k in m.get('Tag'):
temp_model = ListClustersResponseBodyClustersClusterInfoTagsTag()
self.tag.append(temp_model.from_map(k))
return self
class ListClustersResponseBodyClustersClusterInfo(TeaModel):
def __init__(self, charge_type=None, create_resource=None, create_time=None, deposit_type=None,
expired_time=None, fail_reason=None, has_uncompleted_order=None, id=None, k_8s_cluster_id=None,
machine_type=None, meta_store_type=None, name=None, order_list=None, order_task_info=None, period=None,
running_time=None, status=None, tags=None, type=None):
self.charge_type = charge_type # type: str
self.create_resource = create_resource # type: str
self.create_time = create_time # type: long
self.deposit_type = deposit_type # type: str
self.expired_time = expired_time # type: long
self.fail_reason = fail_reason # type: ListClustersResponseBodyClustersClusterInfoFailReason
self.has_uncompleted_order = has_uncompleted_order # type: bool
self.id = id # type: str
self.k_8s_cluster_id = k_8s_cluster_id # type: str
self.machine_type = machine_type # type: str
self.meta_store_type = meta_store_type # type: str
self.name = name # type: str
self.order_list = order_list # type: str
self.order_task_info = order_task_info # type: ListClustersResponseBodyClustersClusterInfoOrderTaskInfo
self.period = period # type: int
self.running_time = running_time # type: int
self.status = status # type: str
self.tags = tags # type: ListClustersResponseBodyClustersClusterInfoTags
self.type = type # type: str
def validate(self):
if self.fail_reason:
self.fail_reason.validate()
if self.order_task_info:
self.order_task_info.validate()
if self.tags:
self.tags.validate()
def to_map(self):
_map = super(ListClustersResponseBodyClustersClusterInfo, self).to_map()
if _map is not None:
return _map
result = dict()
if self.charge_type is not None:
result['ChargeType'] = self.charge_type
if self.create_resource is not None:
result['CreateResource'] = self.create_resource
if self.create_time is not None:
result['CreateTime'] = self.create_time
if self.deposit_type is not None:
result['DepositType'] = self.deposit_type
if self.expired_time is not None:
result['ExpiredTime'] = self.expired_time
if self.fail_reason is not None:
result['FailReason'] = self.fail_reason.to_map()
if self.has_uncompleted_order is not None:
result['HasUncompletedOrder'] = self.has_uncompleted_order
if self.id is not None:
result['Id'] = self.id
if self.k_8s_cluster_id is not None:
result['K8sClusterId'] = self.k_8s_cluster_id
if self.machine_type is not None:
result['MachineType'] = self.machine_type
if self.meta_store_type is not None:
result['MetaStoreType'] = self.meta_store_type
if self.name is not None:
result['Name'] = self.name
if self.order_list is not None:
result['OrderList'] = self.order_list
if self.order_task_info is not None:
result['OrderTaskInfo'] = self.order_task_info.to_map()
if self.period is not None:
result['Period'] = self.period
if self.running_time is not None:
result['RunningTime'] = self.running_time
if self.status is not None:
result['Status'] = self.status
if self.tags is not None:
result['Tags'] = self.tags.to_map()
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ChargeType') is not None:
self.charge_type = m.get('ChargeType')
if m.get('CreateResource') is not None:
self.create_resource = m.get('CreateResource')
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('DepositType') is not None:
self.deposit_type = m.get('DepositType')
if m.get('ExpiredTime') is not None:
self.expired_time = m.get('ExpiredTime')
if m.get('FailReason') is not None:
temp_model = ListClustersResponseBodyClustersClusterInfoFailReason()
self.fail_reason = temp_model.from_map(m['FailReason'])
if m.get('HasUncompletedOrder') is not None:
self.has_uncompleted_order = m.get('HasUncompletedOrder')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('K8sClusterId') is not None:
self.k_8s_cluster_id = m.get('K8sClusterId')
if m.get('MachineType') is not None:
self.machine_type = m.get('MachineType')
if m.get('MetaStoreType') is not None:
self.meta_store_type = m.get('MetaStoreType')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('OrderList') is not None:
self.order_list = m.get('OrderList')
if m.get('OrderTaskInfo') is not None:
temp_model = ListClustersResponseBodyClustersClusterInfoOrderTaskInfo()
self.order_task_info = temp_model.from_map(m['OrderTaskInfo'])
if m.get('Period') is not None:
self.period = m.get('Period')
if m.get('RunningTime') is not None:
self.running_time = m.get('RunningTime')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('Tags') is not None:
temp_model = ListClustersResponseBodyClustersClusterInfoTags()
self.tags = temp_model.from_map(m['Tags'])
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class ListClustersResponseBodyClusters(TeaModel):
def __init__(self, cluster_info=None):
self.cluster_info = cluster_info # type: list[ListClustersResponseBodyClustersClusterInfo]
def validate(self):
if self.cluster_info:
for k in self.cluster_info:
if k:
k.validate()
def to_map(self):
_map = super(ListClustersResponseBodyClusters, self).to_map()
if _map is not None:
return _map
result = dict()
result['ClusterInfo'] = []
if self.cluster_info is not None:
for k in self.cluster_info:
result['ClusterInfo'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.cluster_info = []
if m.get('ClusterInfo') is not None:
for k in m.get('ClusterInfo'):
temp_model = ListClustersResponseBodyClustersClusterInfo()
self.cluster_info.append(temp_model.from_map(k))
return self
class ListClustersResponseBody(TeaModel):
def __init__(self, clusters=None, page_number=None, page_size=None, request_id=None, total_count=None):
self.clusters = clusters # type: ListClustersResponseBodyClusters
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.request_id = request_id # type: str
self.total_count = total_count # type: int
def validate(self):
if self.clusters:
self.clusters.validate()
def to_map(self):
_map = super(ListClustersResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.clusters is not None:
result['Clusters'] = self.clusters.to_map()
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.total_count is not None:
result['TotalCount'] = self.total_count
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Clusters') is not None:
temp_model = ListClustersResponseBodyClusters()
self.clusters = temp_model.from_map(m['Clusters'])
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('TotalCount') is not None:
self.total_count = m.get('TotalCount')
return self
class ListClustersResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListClustersResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListClustersResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListClustersResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListFlowRequest(TeaModel):
def __init__(self, cluster_id=None, id=None, job_id=None, name=None, page_number=None, page_size=None,
periodic=None, project_id=None, region_id=None, status=None):
self.cluster_id = cluster_id # type: str
self.id = id # type: str
self.job_id = job_id # type: str
self.name = name # type: str
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.periodic = periodic # type: bool
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.status = status # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListFlowRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.id is not None:
result['Id'] = self.id
if self.job_id is not None:
result['JobId'] = self.job_id
if self.name is not None:
result['Name'] = self.name
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.periodic is not None:
result['Periodic'] = self.periodic
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.status is not None:
result['Status'] = self.status
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('JobId') is not None:
self.job_id = m.get('JobId')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('Periodic') is not None:
self.periodic = m.get('Periodic')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('Status') is not None:
self.status = m.get('Status')
return self
class ListFlowResponseBodyFlowFlow(TeaModel):
def __init__(self, alert_conf=None, alert_ding_ding_group_biz_id=None, alert_user_group_biz_id=None,
category_id=None, cluster_id=None, create_cluster=None, cron_expr=None, description=None, end_schedule=None,
gmt_create=None, gmt_modified=None, graph=None, host_name=None, id=None, name=None, periodic=None,
project_id=None, start_schedule=None, status=None, type=None):
self.alert_conf = alert_conf # type: str
self.alert_ding_ding_group_biz_id = alert_ding_ding_group_biz_id # type: str
self.alert_user_group_biz_id = alert_user_group_biz_id # type: str
self.category_id = category_id # type: str
self.cluster_id = cluster_id # type: str
self.create_cluster = create_cluster # type: bool
self.cron_expr = cron_expr # type: str
self.description = description # type: str
self.end_schedule = end_schedule # type: long
self.gmt_create = gmt_create # type: long
self.gmt_modified = gmt_modified # type: long
self.graph = graph # type: str
self.host_name = host_name # type: str
self.id = id # type: str
self.name = name # type: str
self.periodic = periodic # type: bool
self.project_id = project_id # type: str
self.start_schedule = start_schedule # type: long
self.status = status # type: str
self.type = type # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListFlowResponseBodyFlowFlow, self).to_map()
if _map is not None:
return _map
result = dict()
if self.alert_conf is not None:
result['AlertConf'] = self.alert_conf
if self.alert_ding_ding_group_biz_id is not None:
result['AlertDingDingGroupBizId'] = self.alert_ding_ding_group_biz_id
if self.alert_user_group_biz_id is not None:
result['AlertUserGroupBizId'] = self.alert_user_group_biz_id
if self.category_id is not None:
result['CategoryId'] = self.category_id
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.create_cluster is not None:
result['CreateCluster'] = self.create_cluster
if self.cron_expr is not None:
result['CronExpr'] = self.cron_expr
if self.description is not None:
result['Description'] = self.description
if self.end_schedule is not None:
result['EndSchedule'] = self.end_schedule
if self.gmt_create is not None:
result['GmtCreate'] = self.gmt_create
if self.gmt_modified is not None:
result['GmtModified'] = self.gmt_modified
if self.graph is not None:
result['Graph'] = self.graph
if self.host_name is not None:
result['HostName'] = self.host_name
if self.id is not None:
result['Id'] = self.id
if self.name is not None:
result['Name'] = self.name
if self.periodic is not None:
result['Periodic'] = self.periodic
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.start_schedule is not None:
result['StartSchedule'] = self.start_schedule
if self.status is not None:
result['Status'] = self.status
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('AlertConf') is not None:
self.alert_conf = m.get('AlertConf')
if m.get('AlertDingDingGroupBizId') is not None:
self.alert_ding_ding_group_biz_id = m.get('AlertDingDingGroupBizId')
if m.get('AlertUserGroupBizId') is not None:
self.alert_user_group_biz_id = m.get('AlertUserGroupBizId')
if m.get('CategoryId') is not None:
self.category_id = m.get('CategoryId')
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('CreateCluster') is not None:
self.create_cluster = m.get('CreateCluster')
if m.get('CronExpr') is not None:
self.cron_expr = m.get('CronExpr')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('EndSchedule') is not None:
self.end_schedule = m.get('EndSchedule')
if m.get('GmtCreate') is not None:
self.gmt_create = m.get('GmtCreate')
if m.get('GmtModified') is not None:
self.gmt_modified = m.get('GmtModified')
if m.get('Graph') is not None:
self.graph = m.get('Graph')
if m.get('HostName') is not None:
self.host_name = m.get('HostName')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('Periodic') is not None:
self.periodic = m.get('Periodic')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('StartSchedule') is not None:
self.start_schedule = m.get('StartSchedule')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class ListFlowResponseBodyFlow(TeaModel):
def __init__(self, flow=None):
self.flow = flow # type: list[ListFlowResponseBodyFlowFlow]
def validate(self):
if self.flow:
for k in self.flow:
if k:
k.validate()
def to_map(self):
_map = super(ListFlowResponseBodyFlow, self).to_map()
if _map is not None:
return _map
result = dict()
result['Flow'] = []
if self.flow is not None:
for k in self.flow:
result['Flow'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.flow = []
if m.get('Flow') is not None:
for k in m.get('Flow'):
temp_model = ListFlowResponseBodyFlowFlow()
self.flow.append(temp_model.from_map(k))
return self
class ListFlowResponseBody(TeaModel):
def __init__(self, flow=None, page_number=None, page_size=None, request_id=None, total=None):
self.flow = flow # type: ListFlowResponseBodyFlow
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.request_id = request_id # type: str
self.total = total # type: int
def validate(self):
if self.flow:
self.flow.validate()
def to_map(self):
_map = super(ListFlowResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.flow is not None:
result['Flow'] = self.flow.to_map()
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.total is not None:
result['Total'] = self.total
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Flow') is not None:
temp_model = ListFlowResponseBodyFlow()
self.flow = temp_model.from_map(m['Flow'])
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Total') is not None:
self.total = m.get('Total')
return self
class ListFlowResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListFlowResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListFlowResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListFlowJobHistoryRequest(TeaModel):
def __init__(self, id=None, instance_id=None, job_type=None, page_number=None, page_size=None, project_id=None,
region_id=None, status_list=None, time_range=None):
self.id = id # type: str
self.instance_id = instance_id # type: str
self.job_type = job_type # type: str
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.status_list = status_list # type: list[str]
self.time_range = time_range # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListFlowJobHistoryRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.instance_id is not None:
result['InstanceId'] = self.instance_id
if self.job_type is not None:
result['JobType'] = self.job_type
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.status_list is not None:
result['StatusList'] = self.status_list
if self.time_range is not None:
result['TimeRange'] = self.time_range
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('InstanceId') is not None:
self.instance_id = m.get('InstanceId')
if m.get('JobType') is not None:
self.job_type = m.get('JobType')
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('StatusList') is not None:
self.status_list = m.get('StatusList')
if m.get('TimeRange') is not None:
self.time_range = m.get('TimeRange')
return self
class ListFlowJobHistoryResponseBodyNodeInstancesNodeInstance(TeaModel):
def __init__(self, cluster_id=None, end_time=None, env_conf=None, external_id=None, external_info=None,
external_status=None, fail_act=None, gmt_create=None, gmt_modified=None, host_name=None, id=None, job_id=None,
job_name=None, job_params=None, job_type=None, max_retry=None, node_name=None, param_conf=None,
project_id=None, retries=None, retry_interval=None, run_conf=None, start_time=None, status=None, type=None,
pending=None):
self.cluster_id = cluster_id # type: str
self.end_time = end_time # type: long
self.env_conf = env_conf # type: str
self.external_id = external_id # type: str
self.external_info = external_info # type: str
self.external_status = external_status # type: str
self.fail_act = fail_act # type: str
self.gmt_create = gmt_create # type: long
self.gmt_modified = gmt_modified # type: long
self.host_name = host_name # type: str
self.id = id # type: str
self.job_id = job_id # type: str
self.job_name = job_name # type: str
self.job_params = job_params # type: str
self.job_type = job_type # type: str
self.max_retry = max_retry # type: int
self.node_name = node_name # type: str
self.param_conf = param_conf # type: str
self.project_id = project_id # type: str
self.retries = retries # type: int
self.retry_interval = retry_interval # type: long
self.run_conf = run_conf # type: str
self.start_time = start_time # type: long
self.status = status # type: str
self.type = type # type: str
self.pending = pending # type: bool
def validate(self):
pass
def to_map(self):
_map = super(ListFlowJobHistoryResponseBodyNodeInstancesNodeInstance, self).to_map()
if _map is not None:
return _map
result = dict()
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.end_time is not None:
result['EndTime'] = self.end_time
if self.env_conf is not None:
result['EnvConf'] = self.env_conf
if self.external_id is not None:
result['ExternalId'] = self.external_id
if self.external_info is not None:
result['ExternalInfo'] = self.external_info
if self.external_status is not None:
result['ExternalStatus'] = self.external_status
if self.fail_act is not None:
result['FailAct'] = self.fail_act
if self.gmt_create is not None:
result['GmtCreate'] = self.gmt_create
if self.gmt_modified is not None:
result['GmtModified'] = self.gmt_modified
if self.host_name is not None:
result['HostName'] = self.host_name
if self.id is not None:
result['Id'] = self.id
if self.job_id is not None:
result['JobId'] = self.job_id
if self.job_name is not None:
result['JobName'] = self.job_name
if self.job_params is not None:
result['JobParams'] = self.job_params
if self.job_type is not None:
result['JobType'] = self.job_type
if self.max_retry is not None:
result['MaxRetry'] = self.max_retry
if self.node_name is not None:
result['NodeName'] = self.node_name
if self.param_conf is not None:
result['ParamConf'] = self.param_conf
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.retries is not None:
result['Retries'] = self.retries
if self.retry_interval is not None:
result['RetryInterval'] = self.retry_interval
if self.run_conf is not None:
result['RunConf'] = self.run_conf
if self.start_time is not None:
result['StartTime'] = self.start_time
if self.status is not None:
result['Status'] = self.status
if self.type is not None:
result['Type'] = self.type
if self.pending is not None:
result['pending'] = self.pending
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('EndTime') is not None:
self.end_time = m.get('EndTime')
if m.get('EnvConf') is not None:
self.env_conf = m.get('EnvConf')
if m.get('ExternalId') is not None:
self.external_id = m.get('ExternalId')
if m.get('ExternalInfo') is not None:
self.external_info = m.get('ExternalInfo')
if m.get('ExternalStatus') is not None:
self.external_status = m.get('ExternalStatus')
if m.get('FailAct') is not None:
self.fail_act = m.get('FailAct')
if m.get('GmtCreate') is not None:
self.gmt_create = m.get('GmtCreate')
if m.get('GmtModified') is not None:
self.gmt_modified = m.get('GmtModified')
if m.get('HostName') is not None:
self.host_name = m.get('HostName')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('JobId') is not None:
self.job_id = m.get('JobId')
if m.get('JobName') is not None:
self.job_name = m.get('JobName')
if m.get('JobParams') is not None:
self.job_params = m.get('JobParams')
if m.get('JobType') is not None:
self.job_type = m.get('JobType')
if m.get('MaxRetry') is not None:
self.max_retry = m.get('MaxRetry')
if m.get('NodeName') is not None:
self.node_name = m.get('NodeName')
if m.get('ParamConf') is not None:
self.param_conf = m.get('ParamConf')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('Retries') is not None:
self.retries = m.get('Retries')
if m.get('RetryInterval') is not None:
self.retry_interval = m.get('RetryInterval')
if m.get('RunConf') is not None:
self.run_conf = m.get('RunConf')
if m.get('StartTime') is not None:
self.start_time = m.get('StartTime')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('Type') is not None:
self.type = m.get('Type')
if m.get('pending') is not None:
self.pending = m.get('pending')
return self
class ListFlowJobHistoryResponseBodyNodeInstances(TeaModel):
def __init__(self, node_instance=None):
self.node_instance = node_instance # type: list[ListFlowJobHistoryResponseBodyNodeInstancesNodeInstance]
def validate(self):
if self.node_instance:
for k in self.node_instance:
if k:
k.validate()
def to_map(self):
_map = super(ListFlowJobHistoryResponseBodyNodeInstances, self).to_map()
if _map is not None:
return _map
result = dict()
result['NodeInstance'] = []
if self.node_instance is not None:
for k in self.node_instance:
result['NodeInstance'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.node_instance = []
if m.get('NodeInstance') is not None:
for k in m.get('NodeInstance'):
temp_model = ListFlowJobHistoryResponseBodyNodeInstancesNodeInstance()
self.node_instance.append(temp_model.from_map(k))
return self
class ListFlowJobHistoryResponseBody(TeaModel):
def __init__(self, node_instances=None, page_number=None, page_size=None, request_id=None, total=None):
self.node_instances = node_instances # type: ListFlowJobHistoryResponseBodyNodeInstances
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.request_id = request_id # type: str
self.total = total # type: int
def validate(self):
if self.node_instances:
self.node_instances.validate()
def to_map(self):
_map = super(ListFlowJobHistoryResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.node_instances is not None:
result['NodeInstances'] = self.node_instances.to_map()
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.total is not None:
result['Total'] = self.total
return result
def from_map(self, m=None):
m = m or dict()
if m.get('NodeInstances') is not None:
temp_model = ListFlowJobHistoryResponseBodyNodeInstances()
self.node_instances = temp_model.from_map(m['NodeInstances'])
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Total') is not None:
self.total = m.get('Total')
return self
class ListFlowJobHistoryResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListFlowJobHistoryResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListFlowJobHistoryResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListFlowJobHistoryResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListFlowJobsRequest(TeaModel):
def __init__(self, adhoc=None, exact_name=None, id=None, name=None, page_number=None, page_size=None,
project_id=None, region_id=None, type=None):
self.adhoc = adhoc # type: bool
self.exact_name = exact_name # type: str
self.id = id # type: str
self.name = name # type: str
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.type = type # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListFlowJobsRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.adhoc is not None:
result['Adhoc'] = self.adhoc
if self.exact_name is not None:
result['ExactName'] = self.exact_name
if self.id is not None:
result['Id'] = self.id
if self.name is not None:
result['Name'] = self.name
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Adhoc') is not None:
self.adhoc = m.get('Adhoc')
if m.get('ExactName') is not None:
self.exact_name = m.get('ExactName')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class ListFlowJobsResponseBodyJobListJobResourceListResource(TeaModel):
def __init__(self, alias=None, path=None):
self.alias = alias # type: str
self.path = path # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListFlowJobsResponseBodyJobListJobResourceListResource, self).to_map()
if _map is not None:
return _map
result = dict()
if self.alias is not None:
result['Alias'] = self.alias
if self.path is not None:
result['Path'] = self.path
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Alias') is not None:
self.alias = m.get('Alias')
if m.get('Path') is not None:
self.path = m.get('Path')
return self
class ListFlowJobsResponseBodyJobListJobResourceList(TeaModel):
def __init__(self, resource=None):
self.resource = resource # type: list[ListFlowJobsResponseBodyJobListJobResourceListResource]
def validate(self):
if self.resource:
for k in self.resource:
if k:
k.validate()
def to_map(self):
_map = super(ListFlowJobsResponseBodyJobListJobResourceList, self).to_map()
if _map is not None:
return _map
result = dict()
result['Resource'] = []
if self.resource is not None:
for k in self.resource:
result['Resource'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.resource = []
if m.get('Resource') is not None:
for k in m.get('Resource'):
temp_model = ListFlowJobsResponseBodyJobListJobResourceListResource()
self.resource.append(temp_model.from_map(k))
return self
class ListFlowJobsResponseBodyJobListJob(TeaModel):
def __init__(self, adhoc=None, alert_conf=None, category_id=None, custom_variables=None, description=None,
env_conf=None, fail_act=None, gmt_create=None, gmt_modified=None, id=None, last_instance_detail=None,
max_retry=None, mode=None, monitor_conf=None, name=None, param_conf=None, params=None, resource_list=None,
retry_interval=None, run_conf=None, type=None):
self.adhoc = adhoc # type: str
self.alert_conf = alert_conf # type: str
self.category_id = category_id # type: str
self.custom_variables = custom_variables # type: str
self.description = description # type: str
self.env_conf = env_conf # type: str
self.fail_act = fail_act # type: str
self.gmt_create = gmt_create # type: long
self.gmt_modified = gmt_modified # type: long
self.id = id # type: str
self.last_instance_detail = last_instance_detail # type: str
self.max_retry = max_retry # type: int
self.mode = mode # type: str
self.monitor_conf = monitor_conf # type: str
self.name = name # type: str
self.param_conf = param_conf # type: str
self.params = params # type: str
self.resource_list = resource_list # type: ListFlowJobsResponseBodyJobListJobResourceList
self.retry_interval = retry_interval # type: long
self.run_conf = run_conf # type: str
self.type = type # type: str
def validate(self):
if self.resource_list:
self.resource_list.validate()
def to_map(self):
_map = super(ListFlowJobsResponseBodyJobListJob, self).to_map()
if _map is not None:
return _map
result = dict()
if self.adhoc is not None:
result['Adhoc'] = self.adhoc
if self.alert_conf is not None:
result['AlertConf'] = self.alert_conf
if self.category_id is not None:
result['CategoryId'] = self.category_id
if self.custom_variables is not None:
result['CustomVariables'] = self.custom_variables
if self.description is not None:
result['Description'] = self.description
if self.env_conf is not None:
result['EnvConf'] = self.env_conf
if self.fail_act is not None:
result['FailAct'] = self.fail_act
if self.gmt_create is not None:
result['GmtCreate'] = self.gmt_create
if self.gmt_modified is not None:
result['GmtModified'] = self.gmt_modified
if self.id is not None:
result['Id'] = self.id
if self.last_instance_detail is not None:
result['LastInstanceDetail'] = self.last_instance_detail
if self.max_retry is not None:
result['MaxRetry'] = self.max_retry
if self.mode is not None:
result['Mode'] = self.mode
if self.monitor_conf is not None:
result['MonitorConf'] = self.monitor_conf
if self.name is not None:
result['Name'] = self.name
if self.param_conf is not None:
result['ParamConf'] = self.param_conf
if self.params is not None:
result['Params'] = self.params
if self.resource_list is not None:
result['ResourceList'] = self.resource_list.to_map()
if self.retry_interval is not None:
result['RetryInterval'] = self.retry_interval
if self.run_conf is not None:
result['RunConf'] = self.run_conf
if self.type is not None:
result['Type'] = self.type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Adhoc') is not None:
self.adhoc = m.get('Adhoc')
if m.get('AlertConf') is not None:
self.alert_conf = m.get('AlertConf')
if m.get('CategoryId') is not None:
self.category_id = m.get('CategoryId')
if m.get('CustomVariables') is not None:
self.custom_variables = m.get('CustomVariables')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('EnvConf') is not None:
self.env_conf = m.get('EnvConf')
if m.get('FailAct') is not None:
self.fail_act = m.get('FailAct')
if m.get('GmtCreate') is not None:
self.gmt_create = m.get('GmtCreate')
if m.get('GmtModified') is not None:
self.gmt_modified = m.get('GmtModified')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('LastInstanceDetail') is not None:
self.last_instance_detail = m.get('LastInstanceDetail')
if m.get('MaxRetry') is not None:
self.max_retry = m.get('MaxRetry')
if m.get('Mode') is not None:
self.mode = m.get('Mode')
if m.get('MonitorConf') is not None:
self.monitor_conf = m.get('MonitorConf')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('ParamConf') is not None:
self.param_conf = m.get('ParamConf')
if m.get('Params') is not None:
self.params = m.get('Params')
if m.get('ResourceList') is not None:
temp_model = ListFlowJobsResponseBodyJobListJobResourceList()
self.resource_list = temp_model.from_map(m['ResourceList'])
if m.get('RetryInterval') is not None:
self.retry_interval = m.get('RetryInterval')
if m.get('RunConf') is not None:
self.run_conf = m.get('RunConf')
if m.get('Type') is not None:
self.type = m.get('Type')
return self
class ListFlowJobsResponseBodyJobList(TeaModel):
def __init__(self, job=None):
self.job = job # type: list[ListFlowJobsResponseBodyJobListJob]
def validate(self):
if self.job:
for k in self.job:
if k:
k.validate()
def to_map(self):
_map = super(ListFlowJobsResponseBodyJobList, self).to_map()
if _map is not None:
return _map
result = dict()
result['Job'] = []
if self.job is not None:
for k in self.job:
result['Job'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.job = []
if m.get('Job') is not None:
for k in m.get('Job'):
temp_model = ListFlowJobsResponseBodyJobListJob()
self.job.append(temp_model.from_map(k))
return self
class ListFlowJobsResponseBody(TeaModel):
def __init__(self, job_list=None, page_number=None, page_size=None, request_id=None, total=None):
self.job_list = job_list # type: ListFlowJobsResponseBodyJobList
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.request_id = request_id # type: str
self.total = total # type: int
def validate(self):
if self.job_list:
self.job_list.validate()
def to_map(self):
_map = super(ListFlowJobsResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.job_list is not None:
result['JobList'] = self.job_list.to_map()
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.total is not None:
result['Total'] = self.total
return result
def from_map(self, m=None):
m = m or dict()
if m.get('JobList') is not None:
temp_model = ListFlowJobsResponseBodyJobList()
self.job_list = temp_model.from_map(m['JobList'])
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Total') is not None:
self.total = m.get('Total')
return self
class ListFlowJobsResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListFlowJobsResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListFlowJobsResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListFlowJobsResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListFlowProjectUserRequest(TeaModel):
def __init__(self, page_number=None, page_size=None, project_id=None, region_id=None):
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListFlowProjectUserRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class ListFlowProjectUserResponseBodyUsersUser(TeaModel):
def __init__(self, account_user_id=None, gmt_create=None, gmt_modified=None, owner_id=None, project_id=None,
user_name=None):
self.account_user_id = account_user_id # type: str
self.gmt_create = gmt_create # type: long
self.gmt_modified = gmt_modified # type: long
self.owner_id = owner_id # type: str
self.project_id = project_id # type: str
self.user_name = user_name # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListFlowProjectUserResponseBodyUsersUser, self).to_map()
if _map is not None:
return _map
result = dict()
if self.account_user_id is not None:
result['AccountUserId'] = self.account_user_id
if self.gmt_create is not None:
result['GmtCreate'] = self.gmt_create
if self.gmt_modified is not None:
result['GmtModified'] = self.gmt_modified
if self.owner_id is not None:
result['OwnerId'] = self.owner_id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.user_name is not None:
result['UserName'] = self.user_name
return result
def from_map(self, m=None):
m = m or dict()
if m.get('AccountUserId') is not None:
self.account_user_id = m.get('AccountUserId')
if m.get('GmtCreate') is not None:
self.gmt_create = m.get('GmtCreate')
if m.get('GmtModified') is not None:
self.gmt_modified = m.get('GmtModified')
if m.get('OwnerId') is not None:
self.owner_id = m.get('OwnerId')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('UserName') is not None:
self.user_name = m.get('UserName')
return self
class ListFlowProjectUserResponseBodyUsers(TeaModel):
def __init__(self, user=None):
self.user = user # type: list[ListFlowProjectUserResponseBodyUsersUser]
def validate(self):
if self.user:
for k in self.user:
if k:
k.validate()
def to_map(self):
_map = super(ListFlowProjectUserResponseBodyUsers, self).to_map()
if _map is not None:
return _map
result = dict()
result['User'] = []
if self.user is not None:
for k in self.user:
result['User'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.user = []
if m.get('User') is not None:
for k in m.get('User'):
temp_model = ListFlowProjectUserResponseBodyUsersUser()
self.user.append(temp_model.from_map(k))
return self
class ListFlowProjectUserResponseBody(TeaModel):
def __init__(self, page_number=None, page_size=None, request_id=None, total=None, users=None):
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.request_id = request_id # type: str
self.total = total # type: int
self.users = users # type: ListFlowProjectUserResponseBodyUsers
def validate(self):
if self.users:
self.users.validate()
def to_map(self):
_map = super(ListFlowProjectUserResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.total is not None:
result['Total'] = self.total
if self.users is not None:
result['Users'] = self.users.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Total') is not None:
self.total = m.get('Total')
if m.get('Users') is not None:
temp_model = ListFlowProjectUserResponseBodyUsers()
self.users = temp_model.from_map(m['Users'])
return self
class ListFlowProjectUserResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListFlowProjectUserResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListFlowProjectUserResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListFlowProjectUserResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListFlowProjectsRequest(TeaModel):
def __init__(self, name=None, page_number=None, page_size=None, product_type=None, project_id=None,
region_id=None, resource_group_id=None):
self.name = name # type: str
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.product_type = product_type # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.resource_group_id = resource_group_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListFlowProjectsRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.name is not None:
result['Name'] = self.name
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.product_type is not None:
result['ProductType'] = self.product_type
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('ProductType') is not None:
self.product_type = m.get('ProductType')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
return self
class ListFlowProjectsResponseBodyProjectsProject(TeaModel):
def __init__(self, description=None, gmt_create=None, gmt_modified=None, id=None, name=None, user_id=None):
self.description = description # type: str
self.gmt_create = gmt_create # type: long
self.gmt_modified = gmt_modified # type: long
self.id = id # type: str
self.name = name # type: str
self.user_id = user_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListFlowProjectsResponseBodyProjectsProject, self).to_map()
if _map is not None:
return _map
result = dict()
if self.description is not None:
result['Description'] = self.description
if self.gmt_create is not None:
result['GmtCreate'] = self.gmt_create
if self.gmt_modified is not None:
result['GmtModified'] = self.gmt_modified
if self.id is not None:
result['Id'] = self.id
if self.name is not None:
result['Name'] = self.name
if self.user_id is not None:
result['UserId'] = self.user_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('GmtCreate') is not None:
self.gmt_create = m.get('GmtCreate')
if m.get('GmtModified') is not None:
self.gmt_modified = m.get('GmtModified')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('UserId') is not None:
self.user_id = m.get('UserId')
return self
class ListFlowProjectsResponseBodyProjects(TeaModel):
def __init__(self, project=None):
self.project = project # type: list[ListFlowProjectsResponseBodyProjectsProject]
def validate(self):
if self.project:
for k in self.project:
if k:
k.validate()
def to_map(self):
_map = super(ListFlowProjectsResponseBodyProjects, self).to_map()
if _map is not None:
return _map
result = dict()
result['Project'] = []
if self.project is not None:
for k in self.project:
result['Project'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
self.project = []
if m.get('Project') is not None:
for k in m.get('Project'):
temp_model = ListFlowProjectsResponseBodyProjectsProject()
self.project.append(temp_model.from_map(k))
return self
class ListFlowProjectsResponseBody(TeaModel):
def __init__(self, page_number=None, page_size=None, projects=None, request_id=None, total=None):
self.page_number = page_number # type: int
self.page_size = page_size # type: int
self.projects = projects # type: ListFlowProjectsResponseBodyProjects
self.request_id = request_id # type: str
self.total = total # type: int
def validate(self):
if self.projects:
self.projects.validate()
def to_map(self):
_map = super(ListFlowProjectsResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.projects is not None:
result['Projects'] = self.projects.to_map()
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.total is not None:
result['Total'] = self.total
return result
def from_map(self, m=None):
m = m or dict()
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('Projects') is not None:
temp_model = ListFlowProjectsResponseBodyProjects()
self.projects = temp_model.from_map(m['Projects'])
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Total') is not None:
self.total = m.get('Total')
return self
class ListFlowProjectsResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListFlowProjectsResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListFlowProjectsResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListFlowProjectsResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ModifyFlowForWebRequest(TeaModel):
def __init__(self, alert_conf=None, alert_ding_ding_group_biz_id=None, alert_user_group_biz_id=None,
cluster_id=None, create_cluster=None, cron_expr=None, description=None, end_schedule=None, graph=None,
host_name=None, id=None, name=None, namespace=None, parent_category=None, parent_flow_list=None,
periodic=None, project_id=None, region_id=None, start_schedule=None, status=None):
self.alert_conf = alert_conf # type: str
self.alert_ding_ding_group_biz_id = alert_ding_ding_group_biz_id # type: str
self.alert_user_group_biz_id = alert_user_group_biz_id # type: str
self.cluster_id = cluster_id # type: str
self.create_cluster = create_cluster # type: bool
self.cron_expr = cron_expr # type: str
self.description = description # type: str
self.end_schedule = end_schedule # type: long
self.graph = graph # type: str
self.host_name = host_name # type: str
self.id = id # type: str
self.name = name # type: str
self.namespace = namespace # type: str
self.parent_category = parent_category # type: str
self.parent_flow_list = parent_flow_list # type: str
self.periodic = periodic # type: bool
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.start_schedule = start_schedule # type: long
self.status = status # type: str
def validate(self):
pass
def to_map(self):
_map = super(ModifyFlowForWebRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.alert_conf is not None:
result['AlertConf'] = self.alert_conf
if self.alert_ding_ding_group_biz_id is not None:
result['AlertDingDingGroupBizId'] = self.alert_ding_ding_group_biz_id
if self.alert_user_group_biz_id is not None:
result['AlertUserGroupBizId'] = self.alert_user_group_biz_id
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.create_cluster is not None:
result['CreateCluster'] = self.create_cluster
if self.cron_expr is not None:
result['CronExpr'] = self.cron_expr
if self.description is not None:
result['Description'] = self.description
if self.end_schedule is not None:
result['EndSchedule'] = self.end_schedule
if self.graph is not None:
result['Graph'] = self.graph
if self.host_name is not None:
result['HostName'] = self.host_name
if self.id is not None:
result['Id'] = self.id
if self.name is not None:
result['Name'] = self.name
if self.namespace is not None:
result['Namespace'] = self.namespace
if self.parent_category is not None:
result['ParentCategory'] = self.parent_category
if self.parent_flow_list is not None:
result['ParentFlowList'] = self.parent_flow_list
if self.periodic is not None:
result['Periodic'] = self.periodic
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.start_schedule is not None:
result['StartSchedule'] = self.start_schedule
if self.status is not None:
result['Status'] = self.status
return result
def from_map(self, m=None):
m = m or dict()
if m.get('AlertConf') is not None:
self.alert_conf = m.get('AlertConf')
if m.get('AlertDingDingGroupBizId') is not None:
self.alert_ding_ding_group_biz_id = m.get('AlertDingDingGroupBizId')
if m.get('AlertUserGroupBizId') is not None:
self.alert_user_group_biz_id = m.get('AlertUserGroupBizId')
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('CreateCluster') is not None:
self.create_cluster = m.get('CreateCluster')
if m.get('CronExpr') is not None:
self.cron_expr = m.get('CronExpr')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('EndSchedule') is not None:
self.end_schedule = m.get('EndSchedule')
if m.get('Graph') is not None:
self.graph = m.get('Graph')
if m.get('HostName') is not None:
self.host_name = m.get('HostName')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('Namespace') is not None:
self.namespace = m.get('Namespace')
if m.get('ParentCategory') is not None:
self.parent_category = m.get('ParentCategory')
if m.get('ParentFlowList') is not None:
self.parent_flow_list = m.get('ParentFlowList')
if m.get('Periodic') is not None:
self.periodic = m.get('Periodic')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('StartSchedule') is not None:
self.start_schedule = m.get('StartSchedule')
if m.get('Status') is not None:
self.status = m.get('Status')
return self
class ModifyFlowForWebResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ModifyFlowForWebResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class ModifyFlowForWebResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ModifyFlowForWebResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ModifyFlowForWebResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ModifyFlowForWebResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ModifyFlowJobRequestResourceList(TeaModel):
def __init__(self, alias=None, path=None):
self.alias = alias # type: str
self.path = path # type: str
def validate(self):
pass
def to_map(self):
_map = super(ModifyFlowJobRequestResourceList, self).to_map()
if _map is not None:
return _map
result = dict()
if self.alias is not None:
result['Alias'] = self.alias
if self.path is not None:
result['Path'] = self.path
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Alias') is not None:
self.alias = m.get('Alias')
if m.get('Path') is not None:
self.path = m.get('Path')
return self
class ModifyFlowJobRequest(TeaModel):
def __init__(self, alert_conf=None, cluster_id=None, custom_variables=None, description=None, env_conf=None,
fail_act=None, id=None, knox_password=None, knox_user=None, max_retry=None, mode=None, monitor_conf=None,
name=None, param_conf=None, params=None, project_id=None, region_id=None, resource_list=None,
retry_interval=None, retry_policy=None, run_conf=None):
self.alert_conf = alert_conf # type: str
self.cluster_id = cluster_id # type: str
self.custom_variables = custom_variables # type: str
self.description = description # type: str
self.env_conf = env_conf # type: str
self.fail_act = fail_act # type: str
self.id = id # type: str
self.knox_password = knox_password # type: str
self.knox_user = knox_user # type: str
self.max_retry = max_retry # type: int
self.mode = mode # type: str
self.monitor_conf = monitor_conf # type: str
self.name = name # type: str
self.param_conf = param_conf # type: str
self.params = params # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
self.resource_list = resource_list # type: list[ModifyFlowJobRequestResourceList]
self.retry_interval = retry_interval # type: long
self.retry_policy = retry_policy # type: str
self.run_conf = run_conf # type: str
def validate(self):
if self.resource_list:
for k in self.resource_list:
if k:
k.validate()
def to_map(self):
_map = super(ModifyFlowJobRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.alert_conf is not None:
result['AlertConf'] = self.alert_conf
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.custom_variables is not None:
result['CustomVariables'] = self.custom_variables
if self.description is not None:
result['Description'] = self.description
if self.env_conf is not None:
result['EnvConf'] = self.env_conf
if self.fail_act is not None:
result['FailAct'] = self.fail_act
if self.id is not None:
result['Id'] = self.id
if self.knox_password is not None:
result['KnoxPassword'] = self.knox_password
if self.knox_user is not None:
result['KnoxUser'] = self.knox_user
if self.max_retry is not None:
result['MaxRetry'] = self.max_retry
if self.mode is not None:
result['Mode'] = self.mode
if self.monitor_conf is not None:
result['MonitorConf'] = self.monitor_conf
if self.name is not None:
result['Name'] = self.name
if self.param_conf is not None:
result['ParamConf'] = self.param_conf
if self.params is not None:
result['Params'] = self.params
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
result['ResourceList'] = []
if self.resource_list is not None:
for k in self.resource_list:
result['ResourceList'].append(k.to_map() if k else None)
if self.retry_interval is not None:
result['RetryInterval'] = self.retry_interval
if self.retry_policy is not None:
result['RetryPolicy'] = self.retry_policy
if self.run_conf is not None:
result['RunConf'] = self.run_conf
return result
def from_map(self, m=None):
m = m or dict()
if m.get('AlertConf') is not None:
self.alert_conf = m.get('AlertConf')
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('CustomVariables') is not None:
self.custom_variables = m.get('CustomVariables')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('EnvConf') is not None:
self.env_conf = m.get('EnvConf')
if m.get('FailAct') is not None:
self.fail_act = m.get('FailAct')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('KnoxPassword') is not None:
self.knox_password = m.get('KnoxPassword')
if m.get('KnoxUser') is not None:
self.knox_user = m.get('KnoxUser')
if m.get('MaxRetry') is not None:
self.max_retry = m.get('MaxRetry')
if m.get('Mode') is not None:
self.mode = m.get('Mode')
if m.get('MonitorConf') is not None:
self.monitor_conf = m.get('MonitorConf')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('ParamConf') is not None:
self.param_conf = m.get('ParamConf')
if m.get('Params') is not None:
self.params = m.get('Params')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
self.resource_list = []
if m.get('ResourceList') is not None:
for k in m.get('ResourceList'):
temp_model = ModifyFlowJobRequestResourceList()
self.resource_list.append(temp_model.from_map(k))
if m.get('RetryInterval') is not None:
self.retry_interval = m.get('RetryInterval')
if m.get('RetryPolicy') is not None:
self.retry_policy = m.get('RetryPolicy')
if m.get('RunConf') is not None:
self.run_conf = m.get('RunConf')
return self
class ModifyFlowJobResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ModifyFlowJobResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class ModifyFlowJobResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ModifyFlowJobResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ModifyFlowJobResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ModifyFlowJobResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ModifyFlowProjectRequest(TeaModel):
def __init__(self, description=None, name=None, project_id=None, region_id=None):
self.description = description # type: str
self.name = name # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ModifyFlowProjectRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.description is not None:
result['Description'] = self.description
if self.name is not None:
result['Name'] = self.name
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class ModifyFlowProjectResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ModifyFlowProjectResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class ModifyFlowProjectResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ModifyFlowProjectResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ModifyFlowProjectResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ModifyFlowProjectResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ReleaseClusterRequest(TeaModel):
def __init__(self, force_release=None, id=None, region_id=None, resource_owner_id=None):
self.force_release = force_release # type: bool
self.id = id # type: str
self.region_id = region_id # type: str
self.resource_owner_id = resource_owner_id # type: long
def validate(self):
pass
def to_map(self):
_map = super(ReleaseClusterRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.force_release is not None:
result['ForceRelease'] = self.force_release
if self.id is not None:
result['Id'] = self.id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.resource_owner_id is not None:
result['ResourceOwnerId'] = self.resource_owner_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ForceRelease') is not None:
self.force_release = m.get('ForceRelease')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('ResourceOwnerId') is not None:
self.resource_owner_id = m.get('ResourceOwnerId')
return self
class ReleaseClusterResponseBody(TeaModel):
def __init__(self, request_id=None):
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ReleaseClusterResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class ReleaseClusterResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ReleaseClusterResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ReleaseClusterResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ReleaseClusterResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class RerunFlowRequest(TeaModel):
def __init__(self, flow_instance_id=None, project_id=None, re_run_fail=None, region_id=None):
self.flow_instance_id = flow_instance_id # type: str
self.project_id = project_id # type: str
self.re_run_fail = re_run_fail # type: bool
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(RerunFlowRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.flow_instance_id is not None:
result['FlowInstanceId'] = self.flow_instance_id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.re_run_fail is not None:
result['ReRunFail'] = self.re_run_fail
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('FlowInstanceId') is not None:
self.flow_instance_id = m.get('FlowInstanceId')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('ReRunFail') is not None:
self.re_run_fail = m.get('ReRunFail')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class RerunFlowResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(RerunFlowResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class RerunFlowResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: RerunFlowResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(RerunFlowResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = RerunFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ResumeFlowRequest(TeaModel):
def __init__(self, flow_instance_id=None, project_id=None, region_id=None):
self.flow_instance_id = flow_instance_id # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ResumeFlowRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.flow_instance_id is not None:
result['FlowInstanceId'] = self.flow_instance_id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('FlowInstanceId') is not None:
self.flow_instance_id = m.get('FlowInstanceId')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class ResumeFlowResponseBody(TeaModel):
def __init__(self, data=None, request_id=None):
self.data = data # type: bool
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ResumeFlowResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class ResumeFlowResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ResumeFlowResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(ResumeFlowResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ResumeFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class SubmitFlowRequest(TeaModel):
def __init__(self, conf=None, flow_id=None, project_id=None, region_id=None):
self.conf = conf # type: str
self.flow_id = flow_id # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(SubmitFlowRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.conf is not None:
result['Conf'] = self.conf
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Conf') is not None:
self.conf = m.get('Conf')
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class SubmitFlowResponseBody(TeaModel):
def __init__(self, data=None, id=None, instance_id=None, request_id=None):
self.data = data # type: str
self.id = id # type: str
self.instance_id = instance_id # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(SubmitFlowResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.data is not None:
result['Data'] = self.data
if self.id is not None:
result['Id'] = self.id
if self.instance_id is not None:
result['InstanceId'] = self.instance_id
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('InstanceId') is not None:
self.instance_id = m.get('InstanceId')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class SubmitFlowResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: SubmitFlowResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(SubmitFlowResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = SubmitFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class SubmitFlowJobRequest(TeaModel):
def __init__(self, cluster_id=None, conf=None, host_name=None, job_id=None, project_id=None, region_id=None):
self.cluster_id = cluster_id # type: str
self.conf = conf # type: str
self.host_name = host_name # type: str
self.job_id = job_id # type: str
self.project_id = project_id # type: str
self.region_id = region_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(SubmitFlowJobRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.cluster_id is not None:
result['ClusterId'] = self.cluster_id
if self.conf is not None:
result['Conf'] = self.conf
if self.host_name is not None:
result['HostName'] = self.host_name
if self.job_id is not None:
result['JobId'] = self.job_id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.region_id is not None:
result['RegionId'] = self.region_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('ClusterId') is not None:
self.cluster_id = m.get('ClusterId')
if m.get('Conf') is not None:
self.conf = m.get('Conf')
if m.get('HostName') is not None:
self.host_name = m.get('HostName')
if m.get('JobId') is not None:
self.job_id = m.get('JobId')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
return self
class SubmitFlowJobResponseBody(TeaModel):
def __init__(self, id=None, request_id=None):
self.id = id # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(SubmitFlowJobResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.id is not None:
result['Id'] = self.id
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('Id') is not None:
self.id = m.get('Id')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class SubmitFlowJobResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: SubmitFlowJobResponseBody
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super(SubmitFlowJobResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = SubmitFlowJobResponseBody()
self.body = temp_model.from_map(m['body'])
return self