alicloud.emr.Cluster

import * as pulumi from "@pulumi/pulumi";
import * as alicloud from "@pulumi/alicloud";

const default = alicloud.emr.getMainVersions({});
const defaultGetInstanceTypes = _default.then(_default => alicloud.emr.getInstanceTypes({
    destinationResource: "InstanceType",
    clusterType: _default.mainVersions?.[0]?.clusterTypes?.[0],
    supportLocalStorage: false,
    instanceChargeType: "PostPaid",
    supportNodeTypes: [
        "MASTER",
        "CORE",
        "TASK",
    ],
}));
const dataDisk = Promise.all([_default, defaultGetInstanceTypes, defaultGetInstanceTypes]).then(([_default, defaultGetInstanceTypes, defaultGetInstanceTypes1]) => alicloud.emr.getDiskTypes({
    destinationResource: "DataDisk",
    clusterType: _default.mainVersions?.[0]?.clusterTypes?.[0],
    instanceChargeType: "PostPaid",
    instanceType: defaultGetInstanceTypes.types?.[0]?.id,
    zoneId: defaultGetInstanceTypes1.types?.[0]?.zoneId,
}));
const systemDisk = Promise.all([_default, defaultGetInstanceTypes, defaultGetInstanceTypes]).then(([_default, defaultGetInstanceTypes, defaultGetInstanceTypes1]) => alicloud.emr.getDiskTypes({
    destinationResource: "SystemDisk",
    clusterType: _default.mainVersions?.[0]?.clusterTypes?.[0],
    instanceChargeType: "PostPaid",
    instanceType: defaultGetInstanceTypes.types?.[0]?.id,
    zoneId: defaultGetInstanceTypes1.types?.[0]?.zoneId,
}));
const vpc: alicloud.vpc.Network[] = [];
for (const range = {value: 0}; range.value < (vpcId == "" ? 1 : 0); range.value++) {
    vpc.push(new alicloud.vpc.Network(`vpc-${range.value}`, {
        name: vpcName,
        cidrBlock: vpcCidr,
    }));
}
const defaultSecurityGroup: alicloud.ecs.SecurityGroup[] = [];
for (const range = {value: 0}; range.value < (securityGroupId == "" ? 1 : 0); range.value++) {
    defaultSecurityGroup.push(new alicloud.ecs.SecurityGroup(`default-${range.value}`, {
        name: securityGroupName,
        vpcId: vpcId == "" ? vpc[0].id : vpcId,
    }));
}
// VSwitch Resource for Module
const vswitch: alicloud.vpc.Switch[] = [];
for (const range = {value: 0}; range.value < (vswitchId == "" ? 1 : 0); range.value++) {
    vswitch.push(new alicloud.vpc.Switch(`vswitch-${range.value}`, {
        availabilityZone: availabilityZone == "" ? defaultGetInstanceTypes.then(defaultGetInstanceTypes => defaultGetInstanceTypes.types?.[0]?.zoneId) : availabilityZone,
        vswitchName: vswitchName,
        cidrBlock: vswitchCidr,
        vpcId: vpcId == "" ? vpc[0].id : vpcId,
    }));
}
// Ram role Resource for Module
const defaultRole = new alicloud.ram.Role("default", {
    name: ramName,
    document: `    {
        "Statement": [
        {
            "Action": "sts:AssumeRole",
            "Effect": "Allow",
            "Principal": {
            "Service": [
                "emr.aliyuncs.com",
                "ecs.aliyuncs.com"
            ]
            }
        }
        ],
        "Version": "1"
    }
`,
    description: "this is a role test.",
    force: true,
});
const defaultCluster = new alicloud.emr.Cluster("default", {
    name: "terraform-create-cluster-test",
    emrVer: _default.then(_default => _default.mainVersions?.[0]?.emrVersion),
    clusterType: _default.then(_default => _default.mainVersions?.[0]?.clusterTypes?.[0]),
    hostGroups: [
        {
            hostGroupName: "master_group",
            hostGroupType: "MASTER",
            nodeCount: "2",
            instanceType: defaultGetInstanceTypes.then(defaultGetInstanceTypes => defaultGetInstanceTypes.types?.[0]?.id),
            diskType: dataDisk.then(dataDisk => dataDisk.types?.[0]?.value),
            diskCapacity: Promise.all([dataDisk, dataDisk]).then(([dataDisk, dataDisk1]) => dataDisk.types?.[0]?.min > 160 ? dataDisk1.types?.[0]?.min : 160),
            diskCount: "1",
            sysDiskType: systemDisk.then(systemDisk => systemDisk.types?.[0]?.value),
            sysDiskCapacity: Promise.all([systemDisk, systemDisk]).then(([systemDisk, systemDisk1]) => systemDisk.types?.[0]?.min > 160 ? systemDisk1.types?.[0]?.min : 160),
        },
        {
            hostGroupName: "core_group",
            hostGroupType: "CORE",
            nodeCount: "3",
            instanceType: defaultGetInstanceTypes.then(defaultGetInstanceTypes => defaultGetInstanceTypes.types?.[0]?.id),
            diskType: dataDisk.then(dataDisk => dataDisk.types?.[0]?.value),
            diskCapacity: Promise.all([dataDisk, dataDisk]).then(([dataDisk, dataDisk1]) => dataDisk.types?.[0]?.min > 160 ? dataDisk1.types?.[0]?.min : 160),
            diskCount: "4",
            sysDiskType: systemDisk.then(systemDisk => systemDisk.types?.[0]?.value),
            sysDiskCapacity: Promise.all([systemDisk, systemDisk]).then(([systemDisk, systemDisk1]) => systemDisk.types?.[0]?.min > 160 ? systemDisk1.types?.[0]?.min : 160),
        },
        {
            hostGroupName: "task_group",
            hostGroupType: "TASK",
            nodeCount: "2",
            instanceType: defaultGetInstanceTypes.then(defaultGetInstanceTypes => defaultGetInstanceTypes.types?.[0]?.id),
            diskType: dataDisk.then(dataDisk => dataDisk.types?.[0]?.value),
            diskCapacity: Promise.all([dataDisk, dataDisk]).then(([dataDisk, dataDisk1]) => dataDisk.types?.[0]?.min > 160 ? dataDisk1.types?.[0]?.min : 160),
            diskCount: "4",
            sysDiskType: systemDisk.then(systemDisk => systemDisk.types?.[0]?.value),
            sysDiskCapacity: Promise.all([systemDisk, systemDisk]).then(([systemDisk, systemDisk1]) => systemDisk.types?.[0]?.min > 160 ? systemDisk1.types?.[0]?.min : 160),
        },
    ],
    highAvailabilityEnable: true,
    zoneId: defaultGetInstanceTypes.then(defaultGetInstanceTypes => defaultGetInstanceTypes.types?.[0]?.zoneId),
    securityGroupId: securityGroupId == "" ? defaultSecurityGroup[0].id : securityGroupId,
    isOpenPublicIp: true,
    chargeType: "PostPaid",
    vswitchId: vswitchId == "" ? vswitch[0].id : vswitchId,
    userDefinedEmrEcsRole: defaultRole.name,
    sshEnable: true,
    masterPwd: "ABCtest1234!",
});

import pulumi
import pulumi_alicloud as alicloud

default = alicloud.emr.get_main_versions()
default_get_instance_types = alicloud.emr.get_instance_types(destination_resource="InstanceType",
    cluster_type=default.main_versions[0].cluster_types[0],
    support_local_storage=False,
    instance_charge_type="PostPaid",
    support_node_types=[
        "MASTER",
        "CORE",
        "TASK",
    ])
data_disk = alicloud.emr.get_disk_types(destination_resource="DataDisk",
    cluster_type=default.main_versions[0].cluster_types[0],
    instance_charge_type="PostPaid",
    instance_type=default_get_instance_types.types[0].id,
    zone_id=default_get_instance_types.types[0].zone_id)
system_disk = alicloud.emr.get_disk_types(destination_resource="SystemDisk",
    cluster_type=default.main_versions[0].cluster_types[0],
    instance_charge_type="PostPaid",
    instance_type=default_get_instance_types.types[0].id,
    zone_id=default_get_instance_types.types[0].zone_id)
vpc = []
for range in [{"value": i} for i in range(0, 1 if vpc_id ==  else 0)]:
    vpc.append(alicloud.vpc.Network(f"vpc-{range['value']}",
        name=vpc_name,
        cidr_block=vpc_cidr))
default_security_group = []
for range in [{"value": i} for i in range(0, 1 if security_group_id ==  else 0)]:
    default_security_group.append(alicloud.ecs.SecurityGroup(f"default-{range['value']}",
        name=security_group_name,
        vpc_id=vpc[0].id if vpc_id == "" else vpc_id))
# VSwitch Resource for Module
vswitch = []
for range in [{"value": i} for i in range(0, 1 if vswitch_id ==  else 0)]:
    vswitch.append(alicloud.vpc.Switch(f"vswitch-{range['value']}",
        availability_zone=default_get_instance_types.types[0].zone_id if availability_zone == "" else availability_zone,
        vswitch_name=vswitch_name,
        cidr_block=vswitch_cidr,
        vpc_id=vpc[0].id if vpc_id == "" else vpc_id))
# Ram role Resource for Module
default_role = alicloud.ram.Role("default",
    name=ram_name,
    document="""    {
        "Statement": [
        {
            "Action": "sts:AssumeRole",
            "Effect": "Allow",
            "Principal": {
            "Service": [
                "emr.aliyuncs.com",
                "ecs.aliyuncs.com"
            ]
            }
        }
        ],
        "Version": "1"
    }
""",
    description="this is a role test.",
    force=True)
default_cluster = alicloud.emr.Cluster("default",
    name="terraform-create-cluster-test",
    emr_ver=default.main_versions[0].emr_version,
    cluster_type=default.main_versions[0].cluster_types[0],
    host_groups=[
        alicloud.emr.ClusterHostGroupArgs(
            host_group_name="master_group",
            host_group_type="MASTER",
            node_count="2",
            instance_type=default_get_instance_types.types[0].id,
            disk_type=data_disk.types[0].value,
            disk_capacity=data_disk.types[0].min if data_disk.types[0].min > 160 else "160",
            disk_count="1",
            sys_disk_type=system_disk.types[0].value,
            sys_disk_capacity=system_disk.types[0].min if system_disk.types[0].min > 160 else "160",
        ),
        alicloud.emr.ClusterHostGroupArgs(
            host_group_name="core_group",
            host_group_type="CORE",
            node_count="3",
            instance_type=default_get_instance_types.types[0].id,
            disk_type=data_disk.types[0].value,
            disk_capacity=data_disk.types[0].min if data_disk.types[0].min > 160 else "160",
            disk_count="4",
            sys_disk_type=system_disk.types[0].value,
            sys_disk_capacity=system_disk.types[0].min if system_disk.types[0].min > 160 else "160",
        ),
        alicloud.emr.ClusterHostGroupArgs(
            host_group_name="task_group",
            host_group_type="TASK",
            node_count="2",
            instance_type=default_get_instance_types.types[0].id,
            disk_type=data_disk.types[0].value,
            disk_capacity=data_disk.types[0].min if data_disk.types[0].min > 160 else "160",
            disk_count="4",
            sys_disk_type=system_disk.types[0].value,
            sys_disk_capacity=system_disk.types[0].min if system_disk.types[0].min > 160 else "160",
        ),
    ],
    high_availability_enable=True,
    zone_id=default_get_instance_types.types[0].zone_id,
    security_group_id=default_security_group[0].id if security_group_id == "" else security_group_id,
    is_open_public_ip=True,
    charge_type="PostPaid",
    vswitch_id=vswitch[0].id if vswitch_id == "" else vswitch_id,
    user_defined_emr_ecs_role=default_role.name,
    ssh_enable=True,
    master_pwd="ABCtest1234!")

package main

import (
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/ecs"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/emr"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/ram"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/vpc"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_default, err := emr.GetMainVersions(ctx, nil, nil);
if err != nil {
return err
}
defaultGetInstanceTypes, err := emr.GetInstanceTypes(ctx, &emr.GetInstanceTypesArgs{
DestinationResource: "InstanceType",
ClusterType: _default.MainVersions[0].ClusterTypes[0],
SupportLocalStorage: pulumi.BoolRef(false),
InstanceChargeType: "PostPaid",
SupportNodeTypes: []string{
"MASTER",
"CORE",
"TASK",
},
}, nil);
if err != nil {
return err
}
dataDisk, err := emr.GetDiskTypes(ctx, &emr.GetDiskTypesArgs{
DestinationResource: "DataDisk",
ClusterType: _default.MainVersions[0].ClusterTypes[0],
InstanceChargeType: "PostPaid",
InstanceType: defaultGetInstanceTypes.Types[0].Id,
ZoneId: pulumi.StringRef(defaultGetInstanceTypes.Types[0].ZoneId),
}, nil);
if err != nil {
return err
}
systemDisk, err := emr.GetDiskTypes(ctx, &emr.GetDiskTypesArgs{
DestinationResource: "SystemDisk",
ClusterType: _default.MainVersions[0].ClusterTypes[0],
InstanceChargeType: "PostPaid",
InstanceType: defaultGetInstanceTypes.Types[0].Id,
ZoneId: pulumi.StringRef(defaultGetInstanceTypes.Types[0].ZoneId),
}, nil);
if err != nil {
return err
}
var tmp0 float64
if vpcId == "" {
tmp0 = 1
} else {
tmp0 = 0
}
var vpc []*vpc.Network
for index := 0; index < tmp0; index++ {
    key0 := index
    _ := index
__res, err := vpc.NewNetwork(ctx, fmt.Sprintf("vpc-%v", key0), &vpc.NetworkArgs{
Name: pulumi.Any(vpcName),
CidrBlock: pulumi.Any(vpcCidr),
})
if err != nil {
return err
}
vpc = append(vpc, __res)
}
var tmp1 pulumi.String
if vpcId == "" {
tmp1 = vpc[0].ID()
} else {
tmp1 = pulumi.Any(vpcId)
}
var tmp2 float64
if securityGroupId == "" {
tmp2 = 1
} else {
tmp2 = 0
}
var defaultSecurityGroup []*ecs.SecurityGroup
for index := 0; index < tmp2; index++ {
    key0 := index
    _ := index
__res, err := ecs.NewSecurityGroup(ctx, fmt.Sprintf("default-%v", key0), &ecs.SecurityGroupArgs{
Name: pulumi.Any(securityGroupName),
VpcId: pulumi.String(tmp1),
})
if err != nil {
return err
}
defaultSecurityGroup = append(defaultSecurityGroup, __res)
}
var tmp3 pulumi.String
if availabilityZone == "" {
tmp3 = pulumi.String(defaultGetInstanceTypes.Types[0].ZoneId)
} else {
tmp3 = pulumi.Any(availabilityZone)
}
var tmp4 pulumi.String
if vpcId == "" {
tmp4 = vpc[0].ID()
} else {
tmp4 = pulumi.Any(vpcId)
}
// VSwitch Resource for Module
var tmp5 float64
if vswitchId == "" {
tmp5 = 1
} else {
tmp5 = 0
}
var vswitch []*vpc.Switch
for index := 0; index < tmp5; index++ {
    key0 := index
    _ := index
__res, err := vpc.NewSwitch(ctx, fmt.Sprintf("vswitch-%v", key0), &vpc.SwitchArgs{
AvailabilityZone: pulumi.String(tmp3),
VswitchName: pulumi.Any(vswitchName),
CidrBlock: pulumi.Any(vswitchCidr),
VpcId: pulumi.String(tmp4),
})
if err != nil {
return err
}
vswitch = append(vswitch, __res)
}
// Ram role Resource for Module
defaultRole, err := ram.NewRole(ctx, "default", &ram.RoleArgs{
Name: pulumi.Any(ramName),
Document: pulumi.String(`    {
        "Statement": [
        {
            "Action": "sts:AssumeRole",
            "Effect": "Allow",
            "Principal": {
            "Service": [
                "emr.aliyuncs.com",
                "ecs.aliyuncs.com"
            ]
            }
        }
        ],
        "Version": "1"
    }
`),
Description: pulumi.String("this is a role test."),
Force: pulumi.Bool(true),
})
if err != nil {
return err
}
var tmp6 pulumi.String
if securityGroupId == "" {
tmp6 = defaultSecurityGroup[0].ID()
} else {
tmp6 = pulumi.Any(securityGroupId)
}
var tmp7 pulumi.String
if vswitchId == "" {
tmp7 = vswitch[0].ID()
} else {
tmp7 = pulumi.Any(vswitchId)
}
_, err = emr.NewCluster(ctx, "default", &emr.ClusterArgs{
Name: pulumi.String("terraform-create-cluster-test"),
EmrVer: pulumi.String(_default.MainVersions[0].EmrVersion),
ClusterType: pulumi.String(_default.MainVersions[0].ClusterTypes[0]),
HostGroups: emr.ClusterHostGroupArray{
var tmp8 pulumi.String
if dataDisk.Types[0].Min > 160 {
tmp8 = pulumi.Int(dataDisk.Types[0].Min)
} else {
tmp8 = pulumi.String("160")
}
var tmp9 pulumi.String
if systemDisk.Types[0].Min > 160 {
tmp9 = pulumi.Int(systemDisk.Types[0].Min)
} else {
tmp9 = pulumi.String("160")
}
&emr.ClusterHostGroupArgs{
HostGroupName: pulumi.String("master_group"),
HostGroupType: pulumi.String("MASTER"),
NodeCount: pulumi.String("2"),
InstanceType: pulumi.String(defaultGetInstanceTypes.Types[0].Id),
DiskType: pulumi.String(dataDisk.Types[0].Value),
DiskCapacity: pulumi.String(tmp8),
DiskCount: pulumi.String("1"),
SysDiskType: pulumi.String(systemDisk.Types[0].Value),
SysDiskCapacity: pulumi.String(tmp9),
},
var tmp10 pulumi.String
if dataDisk.Types[0].Min > 160 {
tmp10 = pulumi.Int(dataDisk.Types[0].Min)
} else {
tmp10 = pulumi.String("160")
}
var tmp11 pulumi.String
if systemDisk.Types[0].Min > 160 {
tmp11 = pulumi.Int(systemDisk.Types[0].Min)
} else {
tmp11 = pulumi.String("160")
}
&emr.ClusterHostGroupArgs{
HostGroupName: pulumi.String("core_group"),
HostGroupType: pulumi.String("CORE"),
NodeCount: pulumi.String("3"),
InstanceType: pulumi.String(defaultGetInstanceTypes.Types[0].Id),
DiskType: pulumi.String(dataDisk.Types[0].Value),
DiskCapacity: pulumi.String(tmp10),
DiskCount: pulumi.String("4"),
SysDiskType: pulumi.String(systemDisk.Types[0].Value),
SysDiskCapacity: pulumi.String(tmp11),
},
var tmp12 pulumi.String
if dataDisk.Types[0].Min > 160 {
tmp12 = pulumi.Int(dataDisk.Types[0].Min)
} else {
tmp12 = pulumi.String("160")
}
var tmp13 pulumi.String
if systemDisk.Types[0].Min > 160 {
tmp13 = pulumi.Int(systemDisk.Types[0].Min)
} else {
tmp13 = pulumi.String("160")
}
&emr.ClusterHostGroupArgs{
HostGroupName: pulumi.String("task_group"),
HostGroupType: pulumi.String("TASK"),
NodeCount: pulumi.String("2"),
InstanceType: pulumi.String(defaultGetInstanceTypes.Types[0].Id),
DiskType: pulumi.String(dataDisk.Types[0].Value),
DiskCapacity: pulumi.String(tmp12),
DiskCount: pulumi.String("4"),
SysDiskType: pulumi.String(systemDisk.Types[0].Value),
SysDiskCapacity: pulumi.String(tmp13),
},
},
HighAvailabilityEnable: pulumi.Bool(true),
ZoneId: pulumi.String(defaultGetInstanceTypes.Types[0].ZoneId),
SecurityGroupId: pulumi.String(tmp6),
IsOpenPublicIp: pulumi.Bool(true),
ChargeType: pulumi.String("PostPaid"),
VswitchId: pulumi.String(tmp7),
UserDefinedEmrEcsRole: defaultRole.Name,
SshEnable: pulumi.Bool(true),
MasterPwd: pulumi.String("ABCtest1234!"),
})
if err != nil {
return err
}
return nil
})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AliCloud = Pulumi.AliCloud;

return await Deployment.RunAsync(() => 
{
    var @default = AliCloud.Emr.GetMainVersions.Invoke();

    var defaultGetInstanceTypes = AliCloud.Emr.GetInstanceTypes.Invoke(new()
    {
        DestinationResource = "InstanceType",
        ClusterType = @default.Apply(getMainVersionsResult => getMainVersionsResult.MainVersions[0]?.ClusterTypes[0]),
        SupportLocalStorage = false,
        InstanceChargeType = "PostPaid",
        SupportNodeTypes = new[]
        {
            "MASTER",
            "CORE",
            "TASK",
        },
    });

    var dataDisk = AliCloud.Emr.GetDiskTypes.Invoke(new()
    {
        DestinationResource = "DataDisk",
        ClusterType = @default.Apply(getMainVersionsResult => getMainVersionsResult.MainVersions[0]?.ClusterTypes[0]),
        InstanceChargeType = "PostPaid",
        InstanceType = defaultGetInstanceTypes.Apply(getInstanceTypesResult => getInstanceTypesResult.Types[0]?.Id),
        ZoneId = defaultGetInstanceTypes.Apply(getInstanceTypesResult => getInstanceTypesResult.Types[0]?.ZoneId),
    });

    var systemDisk = AliCloud.Emr.GetDiskTypes.Invoke(new()
    {
        DestinationResource = "SystemDisk",
        ClusterType = @default.Apply(getMainVersionsResult => getMainVersionsResult.MainVersions[0]?.ClusterTypes[0]),
        InstanceChargeType = "PostPaid",
        InstanceType = defaultGetInstanceTypes.Apply(getInstanceTypesResult => getInstanceTypesResult.Types[0]?.Id),
        ZoneId = defaultGetInstanceTypes.Apply(getInstanceTypesResult => getInstanceTypesResult.Types[0]?.ZoneId),
    });

    var vpc = new List<AliCloud.Vpc.Network>();
    for (var rangeIndex = 0; rangeIndex < (vpcId == "" ? 1 : 0); rangeIndex++)
    {
        var range = new { Value = rangeIndex };
        vpc.Add(new AliCloud.Vpc.Network($"vpc-{range.Value}", new()
        {
            Name = vpcName,
            CidrBlock = vpcCidr,
        }));
    }
    var defaultSecurityGroup = new List<AliCloud.Ecs.SecurityGroup>();
    for (var rangeIndex = 0; rangeIndex < (securityGroupId == "" ? 1 : 0); rangeIndex++)
    {
        var range = new { Value = rangeIndex };
        defaultSecurityGroup.Add(new AliCloud.Ecs.SecurityGroup($"default-{range.Value}", new()
        {
            Name = securityGroupName,
            VpcId = vpcId == "" ? vpc[0].Id : vpcId,
        }));
    }
    // VSwitch Resource for Module
    var vswitch = new List<AliCloud.Vpc.Switch>();
    for (var rangeIndex = 0; rangeIndex < (vswitchId == "" ? 1 : 0); rangeIndex++)
    {
        var range = new { Value = rangeIndex };
        vswitch.Add(new AliCloud.Vpc.Switch($"vswitch-{range.Value}", new()
        {
            AvailabilityZone = availabilityZone == "" ? defaultGetInstanceTypes.Apply(getInstanceTypesResult => getInstanceTypesResult.Types[0]?.ZoneId) : availabilityZone,
            VswitchName = vswitchName,
            CidrBlock = vswitchCidr,
            VpcId = vpcId == "" ? vpc[0].Id : vpcId,
        }));
    }
    // Ram role Resource for Module
    var defaultRole = new AliCloud.Ram.Role("default", new()
    {
        Name = ramName,
        Document = @"    {
        ""Statement"": [
        {
            ""Action"": ""sts:AssumeRole"",
            ""Effect"": ""Allow"",
            ""Principal"": {
            ""Service"": [
                ""emr.aliyuncs.com"",
                ""ecs.aliyuncs.com""
            ]
            }
        }
        ],
        ""Version"": ""1""
    }
",
        Description = "this is a role test.",
        Force = true,
    });

    var defaultCluster = new AliCloud.Emr.Cluster("default", new()
    {
        Name = "terraform-create-cluster-test",
        EmrVer = @default.Apply(@default => @default.Apply(getMainVersionsResult => getMainVersionsResult.MainVersions[0]?.EmrVersion)),
        ClusterType = @default.Apply(@default => @default.Apply(getMainVersionsResult => getMainVersionsResult.MainVersions[0]?.ClusterTypes[0])),
        HostGroups = new[]
        {
            new AliCloud.Emr.Inputs.ClusterHostGroupArgs
            {
                HostGroupName = "master_group",
                HostGroupType = "MASTER",
                NodeCount = "2",
                InstanceType = defaultGetInstanceTypes.Apply(getInstanceTypesResult => getInstanceTypesResult.Types[0]?.Id),
                DiskType = dataDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Value),
                DiskCapacity = Output.Tuple(dataDisk, dataDisk).Apply(values =>
                {
                    var dataDisk = values.Item1;
                    var dataDisk1 = values.Item2;
                    return dataDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Min) > 160 ? dataDisk1.Types[0]?.Min : 160;
                }),
                DiskCount = "1",
                SysDiskType = systemDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Value),
                SysDiskCapacity = Output.Tuple(systemDisk, systemDisk).Apply(values =>
                {
                    var systemDisk = values.Item1;
                    var systemDisk1 = values.Item2;
                    return systemDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Min) > 160 ? systemDisk1.Types[0]?.Min : 160;
                }),
            },
            new AliCloud.Emr.Inputs.ClusterHostGroupArgs
            {
                HostGroupName = "core_group",
                HostGroupType = "CORE",
                NodeCount = "3",
                InstanceType = defaultGetInstanceTypes.Apply(getInstanceTypesResult => getInstanceTypesResult.Types[0]?.Id),
                DiskType = dataDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Value),
                DiskCapacity = Output.Tuple(dataDisk, dataDisk).Apply(values =>
                {
                    var dataDisk = values.Item1;
                    var dataDisk1 = values.Item2;
                    return dataDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Min) > 160 ? dataDisk1.Types[0]?.Min : 160;
                }),
                DiskCount = "4",
                SysDiskType = systemDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Value),
                SysDiskCapacity = Output.Tuple(systemDisk, systemDisk).Apply(values =>
                {
                    var systemDisk = values.Item1;
                    var systemDisk1 = values.Item2;
                    return systemDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Min) > 160 ? systemDisk1.Types[0]?.Min : 160;
                }),
            },
            new AliCloud.Emr.Inputs.ClusterHostGroupArgs
            {
                HostGroupName = "task_group",
                HostGroupType = "TASK",
                NodeCount = "2",
                InstanceType = defaultGetInstanceTypes.Apply(getInstanceTypesResult => getInstanceTypesResult.Types[0]?.Id),
                DiskType = dataDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Value),
                DiskCapacity = Output.Tuple(dataDisk, dataDisk).Apply(values =>
                {
                    var dataDisk = values.Item1;
                    var dataDisk1 = values.Item2;
                    return dataDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Min) > 160 ? dataDisk1.Types[0]?.Min : 160;
                }),
                DiskCount = "4",
                SysDiskType = systemDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Value),
                SysDiskCapacity = Output.Tuple(systemDisk, systemDisk).Apply(values =>
                {
                    var systemDisk = values.Item1;
                    var systemDisk1 = values.Item2;
                    return systemDisk.Apply(getDiskTypesResult => getDiskTypesResult.Types[0]?.Min) > 160 ? systemDisk1.Types[0]?.Min : 160;
                }),
            },
        },
        HighAvailabilityEnable = true,
        ZoneId = defaultGetInstanceTypes.Apply(getInstanceTypesResult => getInstanceTypesResult.Types[0]?.ZoneId),
        SecurityGroupId = securityGroupId == "" ? defaultSecurityGroup[0].Id : securityGroupId,
        IsOpenPublicIp = true,
        ChargeType = "PostPaid",
        VswitchId = vswitchId == "" ? vswitch[0].Id : vswitchId,
        UserDefinedEmrEcsRole = defaultRole.Name,
        SshEnable = true,
        MasterPwd = "ABCtest1234!",
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.alicloud.emr.EmrFunctions;
import com.pulumi.alicloud.emr.inputs.GetMainVersionsArgs;
import com.pulumi.alicloud.emr.inputs.GetInstanceTypesArgs;
import com.pulumi.alicloud.emr.inputs.GetDiskTypesArgs;
import com.pulumi.alicloud.vpc.Network;
import com.pulumi.alicloud.vpc.NetworkArgs;
import com.pulumi.alicloud.ecs.SecurityGroup;
import com.pulumi.alicloud.ecs.SecurityGroupArgs;
import com.pulumi.alicloud.vpc.Switch;
import com.pulumi.alicloud.vpc.SwitchArgs;
import com.pulumi.alicloud.ram.Role;
import com.pulumi.alicloud.ram.RoleArgs;
import com.pulumi.alicloud.emr.Cluster;
import com.pulumi.alicloud.emr.ClusterArgs;
import com.pulumi.alicloud.emr.inputs.ClusterHostGroupArgs;
import com.pulumi.codegen.internal.KeyedValue;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var default = EmrFunctions.getMainVersions();

        final var defaultGetInstanceTypes = EmrFunctions.getInstanceTypes(GetInstanceTypesArgs.builder()
            .destinationResource("InstanceType")
            .clusterType(default_.mainVersions()[0].clusterTypes()[0])
            .supportLocalStorage(false)
            .instanceChargeType("PostPaid")
            .supportNodeTypes(            
                "MASTER",
                "CORE",
                "TASK")
            .build());

        final var dataDisk = EmrFunctions.getDiskTypes(GetDiskTypesArgs.builder()
            .destinationResource("DataDisk")
            .clusterType(default_.mainVersions()[0].clusterTypes()[0])
            .instanceChargeType("PostPaid")
            .instanceType(defaultGetInstanceTypes.applyValue(getInstanceTypesResult -> getInstanceTypesResult.types()[0].id()))
            .zoneId(defaultGetInstanceTypes.applyValue(getInstanceTypesResult -> getInstanceTypesResult.types()[0].zoneId()))
            .build());

        final var systemDisk = EmrFunctions.getDiskTypes(GetDiskTypesArgs.builder()
            .destinationResource("SystemDisk")
            .clusterType(default_.mainVersions()[0].clusterTypes()[0])
            .instanceChargeType("PostPaid")
            .instanceType(defaultGetInstanceTypes.applyValue(getInstanceTypesResult -> getInstanceTypesResult.types()[0].id()))
            .zoneId(defaultGetInstanceTypes.applyValue(getInstanceTypesResult -> getInstanceTypesResult.types()[0].zoneId()))
            .build());

        for (var i = 0; i < (vpcId == "" ? 1 : 0); i++) {
            new Network("vpc-" + i, NetworkArgs.builder()
                .name(vpcName)
                .cidrBlock(vpcCidr)
                .build());

        
}
        for (var i = 0; i < (securityGroupId == "" ? 1 : 0); i++) {
            new SecurityGroup("defaultSecurityGroup-" + i, SecurityGroupArgs.builder()
                .name(securityGroupName)
                .vpcId(vpcId == "" ? vpc[0].id() : vpcId)
                .build());

        
}
        // VSwitch Resource for Module
        for (var i = 0; i < (vswitchId == "" ? 1 : 0); i++) {
            new Switch("vswitch-" + i, SwitchArgs.builder()
                .availabilityZone(availabilityZone == "" ? defaultGetInstanceTypes.applyValue(getInstanceTypesResult -> getInstanceTypesResult.types()[0].zoneId()) : availabilityZone)
                .vswitchName(vswitchName)
                .cidrBlock(vswitchCidr)
                .vpcId(vpcId == "" ? vpc[0].id() : vpcId)
                .build());

        
}
        // Ram role Resource for Module
        var defaultRole = new Role("defaultRole", RoleArgs.builder()
            .name(ramName)
            .document("""
    {
        "Statement": [
        {
            "Action": "sts:AssumeRole",
            "Effect": "Allow",
            "Principal": {
            "Service": [
                "emr.aliyuncs.com",
                "ecs.aliyuncs.com"
            ]
            }
        }
        ],
        "Version": "1"
    }
            """)
            .description("this is a role test.")
            .force(true)
            .build());

        var defaultCluster = new Cluster("defaultCluster", ClusterArgs.builder()
            .name("terraform-create-cluster-test")
            .emrVer(default_.mainVersions()[0].emrVersion())
            .clusterType(default_.mainVersions()[0].clusterTypes()[0])
            .hostGroups(            
                ClusterHostGroupArgs.builder()
                    .hostGroupName("master_group")
                    .hostGroupType("MASTER")
                    .nodeCount("2")
                    .instanceType(defaultGetInstanceTypes.applyValue(getInstanceTypesResult -> getInstanceTypesResult.types()[0].id()))
                    .diskType(dataDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].value()))
                    .diskCapacity(dataDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) > 160 ? dataDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) : 160)
                    .diskCount("1")
                    .sysDiskType(systemDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].value()))
                    .sysDiskCapacity(systemDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) > 160 ? systemDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) : 160)
                    .build(),
                ClusterHostGroupArgs.builder()
                    .hostGroupName("core_group")
                    .hostGroupType("CORE")
                    .nodeCount("3")
                    .instanceType(defaultGetInstanceTypes.applyValue(getInstanceTypesResult -> getInstanceTypesResult.types()[0].id()))
                    .diskType(dataDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].value()))
                    .diskCapacity(dataDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) > 160 ? dataDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) : 160)
                    .diskCount("4")
                    .sysDiskType(systemDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].value()))
                    .sysDiskCapacity(systemDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) > 160 ? systemDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) : 160)
                    .build(),
                ClusterHostGroupArgs.builder()
                    .hostGroupName("task_group")
                    .hostGroupType("TASK")
                    .nodeCount("2")
                    .instanceType(defaultGetInstanceTypes.applyValue(getInstanceTypesResult -> getInstanceTypesResult.types()[0].id()))
                    .diskType(dataDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].value()))
                    .diskCapacity(dataDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) > 160 ? dataDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) : 160)
                    .diskCount("4")
                    .sysDiskType(systemDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].value()))
                    .sysDiskCapacity(systemDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) > 160 ? systemDisk.applyValue(getDiskTypesResult -> getDiskTypesResult.types()[0].min()) : 160)
                    .build())
            .highAvailabilityEnable(true)
            .zoneId(defaultGetInstanceTypes.applyValue(getInstanceTypesResult -> getInstanceTypesResult.types()[0].zoneId()))
            .securityGroupId(securityGroupId == "" ? defaultSecurityGroup[0].id() : securityGroupId)
            .isOpenPublicIp(true)
            .chargeType("PostPaid")
            .vswitchId(vswitchId == "" ? vswitch[0].id() : vswitchId)
            .userDefinedEmrEcsRole(defaultRole.name())
            .sshEnable(true)
            .masterPwd("ABCtest1234!")
            .build());

    }
}

import * as pulumi from "@pulumi/pulumi";
import * as alicloud from "@pulumi/alicloud";

const default = alicloud.emr.getMainVersions({});
const defaultGetInstanceTypes = _default.then(_default => alicloud.emr.getInstanceTypes({
    destinationResource: "InstanceType",
    clusterType: _default.mainVersions?.[0]?.clusterTypes?.[0],
    supportLocalStorage: false,
    instanceChargeType: "PostPaid",
    supportNodeTypes: [
        "MASTER",
        "CORE",
        "TASK",
    ],
}));
const dataDisk = Promise.all([_default, defaultGetInstanceTypes, defaultGetInstanceTypes]).then(([_default, defaultGetInstanceTypes, defaultGetInstanceTypes1]) => alicloud.emr.getDiskTypes({
    destinationResource: "DataDisk",
    clusterType: _default.mainVersions?.[0]?.clusterTypes?.[0],
    instanceChargeType: "PostPaid",
    instanceType: defaultGetInstanceTypes.types?.[0]?.id,
    zoneId: defaultGetInstanceTypes1.types?.[0]?.zoneId,
}));
const systemDisk = Promise.all([_default, defaultGetInstanceTypes, defaultGetInstanceTypes]).then(([_default, defaultGetInstanceTypes, defaultGetInstanceTypes1]) => alicloud.emr.getDiskTypes({
    destinationResource: "SystemDisk",
    clusterType: _default.mainVersions?.[0]?.clusterTypes?.[0],
    instanceChargeType: "PostPaid",
    instanceType: defaultGetInstanceTypes.types?.[0]?.id,
    zoneId: defaultGetInstanceTypes1.types?.[0]?.zoneId,
}));
const vpc: alicloud.vpc.Network[] = [];
for (const range = {value: 0}; range.value < (vpcId == "" ? 1 : 0); range.value++) {
    vpc.push(new alicloud.vpc.Network(`vpc-${range.value}`, {
        name: vpcName,
        cidrBlock: vpcCidr,
    }));
}
const defaultSecurityGroup: alicloud.ecs.SecurityGroup[] = [];
for (const range = {value: 0}; range.value < (securityGroupId == "" ? 1 : 0); range.value++) {
    defaultSecurityGroup.push(new alicloud.ecs.SecurityGroup(`default-${range.value}`, {
        name: securityGroupName,
        vpcId: vpcId == "" ? vpc[0].id : vpcId,
    }));
}
// VSwitch Resource for Module
const vswitch: alicloud.vpc.Switch[] = [];
for (const range = {value: 0}; range.value < (vswitchId == "" ? 1 : 0); range.value++) {
    vswitch.push(new alicloud.vpc.Switch(`vswitch-${range.value}`, {
        availabilityZone: availabilityZone == "" ? defaultGetInstanceTypes.then(defaultGetInstanceTypes => defaultGetInstanceTypes.types?.[0]?.zoneId) : availabilityZone,
        vswitchName: vswitchName,
        cidrBlock: vswitchCidr,
        vpcId: vpcId == "" ? vpc[0].id : vpcId,
    }));
}
// Ram role Resource for Module
const defaultRole = new alicloud.ram.Role("default", {
    name: ramName,
    document: `    {
        "Statement": [
        {
            "Action": "sts:AssumeRole",
            "Effect": "Allow",
            "Principal": {
            "Service": [
                "emr.aliyuncs.com",
                "ecs.aliyuncs.com"
            ]
            }
        }
        ],
        "Version": "1"
    }
`,
    description: "this is a role test.",
    force: true,
});
const defaultCluster = new alicloud.emr.Cluster("default", {
    name: "terraform-resize-cluster-test",
    emrVer: _default.then(_default => _default.mainVersions?.[0]?.emrVersion),
    clusterType: _default.then(_default => _default.mainVersions?.[0]?.clusterTypes?.[0]),
    hostGroups: [
        {
            hostGroupName: "master_group",
            hostGroupType: "MASTER",
            nodeCount: "2",
            instanceType: defaultGetInstanceTypes.then(defaultGetInstanceTypes => defaultGetInstanceTypes.types?.[0]?.id),
            diskType: dataDisk.then(dataDisk => dataDisk.types?.[0]?.value),
            diskCapacity: Promise.all([dataDisk, dataDisk]).then(([dataDisk, dataDisk1]) => dataDisk.types?.[0]?.min > 160 ? dataDisk1.types?.[0]?.min : 160),
            diskCount: "1",
            sysDiskType: systemDisk.then(systemDisk => systemDisk.types?.[0]?.value),
            sysDiskCapacity: Promise.all([systemDisk, systemDisk]).then(([systemDisk, systemDisk1]) => systemDisk.types?.[0]?.min > 160 ? systemDisk1.types?.[0]?.min : 160),
        },
        {
            hostGroupName: "core_group",
            hostGroupType: "CORE",
            nodeCount: "3",
            instanceType: defaultGetInstanceTypes.then(defaultGetInstanceTypes => defaultGetInstanceTypes.types?.[0]?.id),
            diskType: dataDisk.then(dataDisk => dataDisk.types?.[0]?.value),
            diskCapacity: Promise.all([dataDisk, dataDisk]).then(([dataDisk, dataDisk1]) => dataDisk.types?.[0]?.min > 160 ? dataDisk1.types?.[0]?.min : 160),
            diskCount: "4",
            sysDiskType: systemDisk.then(systemDisk => systemDisk.types?.[0]?.value),
            sysDiskCapacity: Promise.all([systemDisk, systemDisk]).then(([systemDisk, systemDisk1]) => systemDisk.types?.[0]?.min > 160 ? systemDisk1.types?.[0]?.min : 160),
        },
        {
            hostGroupName: "task_group",
            hostGroupType: "TASK",
            nodeCount: "4",
            instanceType: defaultGetInstanceTypes.then(defaultGetInstanceTypes => defaultGetInstanceTypes.types?.[0]?.id),
            diskType: dataDisk.then(dataDisk => dataDisk.types?.[0]?.value),
            diskCapacity: Promise.all([dataDisk, dataDisk]).then(([dataDisk, dataDisk1]) => dataDisk.types?.[0]?.min > 160 ? dataDisk1.types?.[0]?.min : 160),
            diskCount: "4",
            sysDiskType: systemDisk.then(systemDisk => systemDisk.types?.[0]?.value),
            sysDiskCapacity: Promise.all([systemDisk, systemDisk]).then(([systemDisk, systemDisk1]) => systemDisk.types?.[0]?.min > 160 ? systemDisk1.types?.[0]?.min : 160),
        },
    ],
    highAvailabilityEnable: true,
    zoneId: defaultGetInstanceTypes.then(defaultGetInstanceTypes => defaultGetInstanceTypes.types?.[0]?.zoneId),
    securityGroupId: securityGroupId == "" ? defaultSecurityGroup[0].id : securityGroupId,
    isOpenPublicIp: true,
    chargeType: "PostPaid",
    vswitchId: vswitchId == "" ? vswitch[0].id : vswitchId,
    userDefinedEmrEcsRole: defaultRole.name,
    sshEnable: true,
    masterPwd: "ABCtest1234!",
});