alicloud.emrv2.Cluster

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

const config = new pulumi.Config();
const name = config.get("name") || "tf-example";
const default = alicloud.resourcemanager.getResourceGroups({
    status: "OK",
});
const defaultGetKeys = alicloud.kms.getKeys({
    status: "Enabled",
});
const defaultGetZones = alicloud.getZones({
    availableInstanceType: "ecs.g7.xlarge",
});
const defaultNetwork = new alicloud.vpc.Network("default", {
    vpcName: name,
    cidrBlock: "172.16.0.0/12",
});
const defaultSwitch = new alicloud.vpc.Switch("default", {
    vpcId: defaultNetwork.id,
    cidrBlock: "172.16.0.0/21",
    zoneId: defaultGetZones.then(defaultGetZones => defaultGetZones.zones?.[0]?.id),
    vswitchName: name,
});
const defaultInteger = new random.index.Integer("default", {
    max: 99999,
    min: 10000,
});
const defaultEcsKeyPair = new alicloud.ecs.EcsKeyPair("default", {keyPairName: `${name}-${defaultInteger.result}`});
const defaultSecurityGroup = new alicloud.ecs.SecurityGroup("default", {
    name: name,
    vpcId: defaultNetwork.id,
});
const defaultRole = new alicloud.ram.Role("default", {
    name: name,
    document: `    {
        "Statement": [
        {
            "Action": "sts:AssumeRole",
            "Effect": "Allow",
            "Principal": {
            "Service": [
                "emr.aliyuncs.com",
                "ecs.aliyuncs.com"
            ]
            }
        }
        ],
        "Version": "1"
    }
`,
    description: "this is a role example.",
    force: true,
});
const defaultCluster = new alicloud.emrv2.Cluster("default", {
    nodeGroups: [
        {
            vswitchIds: [defaultSwitch.id],
            instanceTypes: ["ecs.g7.xlarge"],
            nodeCount: 1,
            spotInstanceRemedy: false,
            dataDisks: [{
                count: 3,
                category: "cloud_essd",
                size: 80,
                performanceLevel: "PL0",
            }],
            nodeGroupName: "emr-master",
            paymentType: "PayAsYouGo",
            withPublicIp: false,
            gracefulShutdown: false,
            systemDisk: {
                category: "cloud_essd",
                size: 80,
                performanceLevel: "PL0",
                count: 1,
            },
            nodeGroupType: "MASTER",
        },
        {
            spotInstanceRemedy: false,
            deploymentSetStrategy: "CLUSTER",
            nodeGroupType: "CORE",
            vswitchIds: [defaultSwitch.id],
            nodeCount: 2,
            gracefulShutdown: false,
            systemDisk: {
                performanceLevel: "PL0",
                count: 1,
                category: "cloud_essd",
                size: 80,
            },
            dataDisks: [{
                count: 3,
                performanceLevel: "PL0",
                category: "cloud_essd",
                size: 80,
            }],
            nodeGroupName: "emr-core",
            paymentType: "PayAsYouGo",
            instanceTypes: ["ecs.g7.xlarge"],
            withPublicIp: false,
        },
    ],
    deployMode: "NORMAL",
    tags: {
        Created: "TF",
        For: "example",
    },
    releaseVersion: "EMR-5.10.0",
    applications: [
        "HADOOP-COMMON",
        "HDFS",
        "YARN",
    ],
    nodeAttributes: [{
        zoneId: defaultGetZones.then(defaultGetZones => defaultGetZones.zones?.[0]?.id),
        keyPairName: defaultEcsKeyPair.id,
        dataDiskEncrypted: true,
        dataDiskKmsKeyId: defaultGetKeys.then(defaultGetKeys => defaultGetKeys.ids?.[0]),
        vpcId: defaultNetwork.id,
        ramRole: defaultRole.name,
        securityGroupId: defaultSecurityGroup.id,
    }],
    logCollectStrategy: JSON.stringify({
        open: ["all"],
        close: [""],
    }),
    resourceGroupId: _default.then(_default => _default.ids?.[0]),
    clusterName: name,
    paymentType: "PayAsYouGo",
    clusterType: "DATAFLOW",
});

import pulumi
import json
import pulumi_alicloud as alicloud
import pulumi_random as random

config = pulumi.Config()
name = config.get("name")
if name is None:
    name = "tf-example"
default = alicloud.resourcemanager.get_resource_groups(status="OK")
default_get_keys = alicloud.kms.get_keys(status="Enabled")
default_get_zones = alicloud.get_zones(available_instance_type="ecs.g7.xlarge")
default_network = alicloud.vpc.Network("default",
    vpc_name=name,
    cidr_block="172.16.0.0/12")
default_switch = alicloud.vpc.Switch("default",
    vpc_id=default_network.id,
    cidr_block="172.16.0.0/21",
    zone_id=default_get_zones.zones[0].id,
    vswitch_name=name)
default_integer = random.index.Integer("default",
    max=99999,
    min=10000)
default_ecs_key_pair = alicloud.ecs.EcsKeyPair("default", key_pair_name=f"{name}-{default_integer['result']}")
default_security_group = alicloud.ecs.SecurityGroup("default",
    name=name,
    vpc_id=default_network.id)
default_role = alicloud.ram.Role("default",
    name=name,
    document="""    {
        "Statement": [
        {
            "Action": "sts:AssumeRole",
            "Effect": "Allow",
            "Principal": {
            "Service": [
                "emr.aliyuncs.com",
                "ecs.aliyuncs.com"
            ]
            }
        }
        ],
        "Version": "1"
    }
""",
    description="this is a role example.",
    force=True)
default_cluster = alicloud.emrv2.Cluster("default",
    node_groups=[
        alicloud.emrv2.ClusterNodeGroupArgs(
            vswitch_ids=[default_switch.id],
            instance_types=["ecs.g7.xlarge"],
            node_count=1,
            spot_instance_remedy=False,
            data_disks=[alicloud.emrv2.ClusterNodeGroupDataDiskArgs(
                count=3,
                category="cloud_essd",
                size=80,
                performance_level="PL0",
            )],
            node_group_name="emr-master",
            payment_type="PayAsYouGo",
            with_public_ip=False,
            graceful_shutdown=False,
            system_disk=alicloud.emrv2.ClusterNodeGroupSystemDiskArgs(
                category="cloud_essd",
                size=80,
                performance_level="PL0",
                count=1,
            ),
            node_group_type="MASTER",
        ),
        alicloud.emrv2.ClusterNodeGroupArgs(
            spot_instance_remedy=False,
            deployment_set_strategy="CLUSTER",
            node_group_type="CORE",
            vswitch_ids=[default_switch.id],
            node_count=2,
            graceful_shutdown=False,
            system_disk=alicloud.emrv2.ClusterNodeGroupSystemDiskArgs(
                performance_level="PL0",
                count=1,
                category="cloud_essd",
                size=80,
            ),
            data_disks=[alicloud.emrv2.ClusterNodeGroupDataDiskArgs(
                count=3,
                performance_level="PL0",
                category="cloud_essd",
                size=80,
            )],
            node_group_name="emr-core",
            payment_type="PayAsYouGo",
            instance_types=["ecs.g7.xlarge"],
            with_public_ip=False,
        ),
    ],
    deploy_mode="NORMAL",
    tags={
        "Created": "TF",
        "For": "example",
    },
    release_version="EMR-5.10.0",
    applications=[
        "HADOOP-COMMON",
        "HDFS",
        "YARN",
    ],
    node_attributes=[alicloud.emrv2.ClusterNodeAttributeArgs(
        zone_id=default_get_zones.zones[0].id,
        key_pair_name=default_ecs_key_pair.id,
        data_disk_encrypted=True,
        data_disk_kms_key_id=default_get_keys.ids[0],
        vpc_id=default_network.id,
        ram_role=default_role.name,
        security_group_id=default_security_group.id,
    )],
    log_collect_strategy=json.dumps({
        "open": ["all"],
        "close": [""],
    }),
    resource_group_id=default.ids[0],
    cluster_name=name,
    payment_type="PayAsYouGo",
    cluster_type="DATAFLOW")

package main

import (
	"encoding/json"
	"fmt"

	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/ecs"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/emrv2"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/kms"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/ram"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/resourcemanager"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/vpc"
	"github.com/pulumi/pulumi-random/sdk/v4/go/random"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		name := "tf-example"
		if param := cfg.Get("name"); param != "" {
			name = param
		}
		_default, err := resourcemanager.GetResourceGroups(ctx, &resourcemanager.GetResourceGroupsArgs{
			Status: pulumi.StringRef("OK"),
		}, nil)
		if err != nil {
			return err
		}
		defaultGetKeys, err := kms.GetKeys(ctx, &kms.GetKeysArgs{
			Status: pulumi.StringRef("Enabled"),
		}, nil)
		if err != nil {
			return err
		}
		defaultGetZones, err := alicloud.GetZones(ctx, &alicloud.GetZonesArgs{
			AvailableInstanceType: pulumi.StringRef("ecs.g7.xlarge"),
		}, nil)
		if err != nil {
			return err
		}
		defaultNetwork, err := vpc.NewNetwork(ctx, "default", &vpc.NetworkArgs{
			VpcName:   pulumi.String(name),
			CidrBlock: pulumi.String("172.16.0.0/12"),
		})
		if err != nil {
			return err
		}
		defaultSwitch, err := vpc.NewSwitch(ctx, "default", &vpc.SwitchArgs{
			VpcId:       defaultNetwork.ID(),
			CidrBlock:   pulumi.String("172.16.0.0/21"),
			ZoneId:      pulumi.String(defaultGetZones.Zones[0].Id),
			VswitchName: pulumi.String(name),
		})
		if err != nil {
			return err
		}
		defaultInteger, err := random.NewInteger(ctx, "default", &random.IntegerArgs{
			Max: 99999,
			Min: 10000,
		})
		if err != nil {
			return err
		}
		defaultEcsKeyPair, err := ecs.NewEcsKeyPair(ctx, "default", &ecs.EcsKeyPairArgs{
			KeyPairName: pulumi.String(fmt.Sprintf("%v-%v", name, defaultInteger.Result)),
		})
		if err != nil {
			return err
		}
		defaultSecurityGroup, err := ecs.NewSecurityGroup(ctx, "default", &ecs.SecurityGroupArgs{
			Name:  pulumi.String(name),
			VpcId: defaultNetwork.ID(),
		})
		if err != nil {
			return err
		}
		defaultRole, err := ram.NewRole(ctx, "default", &ram.RoleArgs{
			Name: pulumi.String(name),
			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 example."),
			Force:       pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		tmpJSON0, err := json.Marshal(map[string]interface{}{
			"open": []string{
				"all",
			},
			"close": []string{
				"",
			},
		})
		if err != nil {
			return err
		}
		json0 := string(tmpJSON0)
		_, err = emrv2.NewCluster(ctx, "default", &emrv2.ClusterArgs{
			NodeGroups: emrv2.ClusterNodeGroupArray{
				&emrv2.ClusterNodeGroupArgs{
					VswitchIds: pulumi.StringArray{
						defaultSwitch.ID(),
					},
					InstanceTypes: pulumi.StringArray{
						pulumi.String("ecs.g7.xlarge"),
					},
					NodeCount:          pulumi.Int(1),
					SpotInstanceRemedy: pulumi.Bool(false),
					DataDisks: emrv2.ClusterNodeGroupDataDiskArray{
						&emrv2.ClusterNodeGroupDataDiskArgs{
							Count:            pulumi.Int(3),
							Category:         pulumi.String("cloud_essd"),
							Size:             pulumi.Int(80),
							PerformanceLevel: pulumi.String("PL0"),
						},
					},
					NodeGroupName:    pulumi.String("emr-master"),
					PaymentType:      pulumi.String("PayAsYouGo"),
					WithPublicIp:     pulumi.Bool(false),
					GracefulShutdown: pulumi.Bool(false),
					SystemDisk: &emrv2.ClusterNodeGroupSystemDiskArgs{
						Category:         pulumi.String("cloud_essd"),
						Size:             pulumi.Int(80),
						PerformanceLevel: pulumi.String("PL0"),
						Count:            pulumi.Int(1),
					},
					NodeGroupType: pulumi.String("MASTER"),
				},
				&emrv2.ClusterNodeGroupArgs{
					SpotInstanceRemedy:    pulumi.Bool(false),
					DeploymentSetStrategy: pulumi.String("CLUSTER"),
					NodeGroupType:         pulumi.String("CORE"),
					VswitchIds: pulumi.StringArray{
						defaultSwitch.ID(),
					},
					NodeCount:        pulumi.Int(2),
					GracefulShutdown: pulumi.Bool(false),
					SystemDisk: &emrv2.ClusterNodeGroupSystemDiskArgs{
						PerformanceLevel: pulumi.String("PL0"),
						Count:            pulumi.Int(1),
						Category:         pulumi.String("cloud_essd"),
						Size:             pulumi.Int(80),
					},
					DataDisks: emrv2.ClusterNodeGroupDataDiskArray{
						&emrv2.ClusterNodeGroupDataDiskArgs{
							Count:            pulumi.Int(3),
							PerformanceLevel: pulumi.String("PL0"),
							Category:         pulumi.String("cloud_essd"),
							Size:             pulumi.Int(80),
						},
					},
					NodeGroupName: pulumi.String("emr-core"),
					PaymentType:   pulumi.String("PayAsYouGo"),
					InstanceTypes: pulumi.StringArray{
						pulumi.String("ecs.g7.xlarge"),
					},
					WithPublicIp: pulumi.Bool(false),
				},
			},
			DeployMode: pulumi.String("NORMAL"),
			Tags: pulumi.Map{
				"Created": pulumi.Any("TF"),
				"For":     pulumi.Any("example"),
			},
			ReleaseVersion: pulumi.String("EMR-5.10.0"),
			Applications: pulumi.StringArray{
				pulumi.String("HADOOP-COMMON"),
				pulumi.String("HDFS"),
				pulumi.String("YARN"),
			},
			NodeAttributes: emrv2.ClusterNodeAttributeArray{
				&emrv2.ClusterNodeAttributeArgs{
					ZoneId:            pulumi.String(defaultGetZones.Zones[0].Id),
					KeyPairName:       defaultEcsKeyPair.ID(),
					DataDiskEncrypted: pulumi.Bool(true),
					DataDiskKmsKeyId:  pulumi.String(defaultGetKeys.Ids[0]),
					VpcId:             defaultNetwork.ID(),
					RamRole:           defaultRole.Name,
					SecurityGroupId:   defaultSecurityGroup.ID(),
				},
			},
			LogCollectStrategy: pulumi.String(json0),
			ResourceGroupId:    pulumi.String(_default.Ids[0]),
			ClusterName:        pulumi.String(name),
			PaymentType:        pulumi.String("PayAsYouGo"),
			ClusterType:        pulumi.String("DATAFLOW"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using System.Text.Json;
using Pulumi;
using AliCloud = Pulumi.AliCloud;
using Random = Pulumi.Random;

return await Deployment.RunAsync(() => 
{
    var config = new Config();
    var name = config.Get("name") ?? "tf-example";
    var @default = AliCloud.ResourceManager.GetResourceGroups.Invoke(new()
    {
        Status = "OK",
    });

    var defaultGetKeys = AliCloud.Kms.GetKeys.Invoke(new()
    {
        Status = "Enabled",
    });

    var defaultGetZones = AliCloud.GetZones.Invoke(new()
    {
        AvailableInstanceType = "ecs.g7.xlarge",
    });

    var defaultNetwork = new AliCloud.Vpc.Network("default", new()
    {
        VpcName = name,
        CidrBlock = "172.16.0.0/12",
    });

    var defaultSwitch = new AliCloud.Vpc.Switch("default", new()
    {
        VpcId = defaultNetwork.Id,
        CidrBlock = "172.16.0.0/21",
        ZoneId = defaultGetZones.Apply(getZonesResult => getZonesResult.Zones[0]?.Id),
        VswitchName = name,
    });

    var defaultInteger = new Random.Index.Integer("default", new()
    {
        Max = 99999,
        Min = 10000,
    });

    var defaultEcsKeyPair = new AliCloud.Ecs.EcsKeyPair("default", new()
    {
        KeyPairName = $"{name}-{defaultInteger.Result}",
    });

    var defaultSecurityGroup = new AliCloud.Ecs.SecurityGroup("default", new()
    {
        Name = name,
        VpcId = defaultNetwork.Id,
    });

    var defaultRole = new AliCloud.Ram.Role("default", new()
    {
        Name = name,
        Document = @"    {
        ""Statement"": [
        {
            ""Action"": ""sts:AssumeRole"",
            ""Effect"": ""Allow"",
            ""Principal"": {
            ""Service"": [
                ""emr.aliyuncs.com"",
                ""ecs.aliyuncs.com""
            ]
            }
        }
        ],
        ""Version"": ""1""
    }
",
        Description = "this is a role example.",
        Force = true,
    });

    var defaultCluster = new AliCloud.Emrv2.Cluster("default", new()
    {
        NodeGroups = new[]
        {
            new AliCloud.Emrv2.Inputs.ClusterNodeGroupArgs
            {
                VswitchIds = new[]
                {
                    defaultSwitch.Id,
                },
                InstanceTypes = new[]
                {
                    "ecs.g7.xlarge",
                },
                NodeCount = 1,
                SpotInstanceRemedy = false,
                DataDisks = new[]
                {
                    new AliCloud.Emrv2.Inputs.ClusterNodeGroupDataDiskArgs
                    {
                        Count = 3,
                        Category = "cloud_essd",
                        Size = 80,
                        PerformanceLevel = "PL0",
                    },
                },
                NodeGroupName = "emr-master",
                PaymentType = "PayAsYouGo",
                WithPublicIp = false,
                GracefulShutdown = false,
                SystemDisk = new AliCloud.Emrv2.Inputs.ClusterNodeGroupSystemDiskArgs
                {
                    Category = "cloud_essd",
                    Size = 80,
                    PerformanceLevel = "PL0",
                    Count = 1,
                },
                NodeGroupType = "MASTER",
            },
            new AliCloud.Emrv2.Inputs.ClusterNodeGroupArgs
            {
                SpotInstanceRemedy = false,
                DeploymentSetStrategy = "CLUSTER",
                NodeGroupType = "CORE",
                VswitchIds = new[]
                {
                    defaultSwitch.Id,
                },
                NodeCount = 2,
                GracefulShutdown = false,
                SystemDisk = new AliCloud.Emrv2.Inputs.ClusterNodeGroupSystemDiskArgs
                {
                    PerformanceLevel = "PL0",
                    Count = 1,
                    Category = "cloud_essd",
                    Size = 80,
                },
                DataDisks = new[]
                {
                    new AliCloud.Emrv2.Inputs.ClusterNodeGroupDataDiskArgs
                    {
                        Count = 3,
                        PerformanceLevel = "PL0",
                        Category = "cloud_essd",
                        Size = 80,
                    },
                },
                NodeGroupName = "emr-core",
                PaymentType = "PayAsYouGo",
                InstanceTypes = new[]
                {
                    "ecs.g7.xlarge",
                },
                WithPublicIp = false,
            },
        },
        DeployMode = "NORMAL",
        Tags = 
        {
            { "Created", "TF" },
            { "For", "example" },
        },
        ReleaseVersion = "EMR-5.10.0",
        Applications = new[]
        {
            "HADOOP-COMMON",
            "HDFS",
            "YARN",
        },
        NodeAttributes = new[]
        {
            new AliCloud.Emrv2.Inputs.ClusterNodeAttributeArgs
            {
                ZoneId = defaultGetZones.Apply(getZonesResult => getZonesResult.Zones[0]?.Id),
                KeyPairName = defaultEcsKeyPair.Id,
                DataDiskEncrypted = true,
                DataDiskKmsKeyId = defaultGetKeys.Apply(getKeysResult => getKeysResult.Ids[0]),
                VpcId = defaultNetwork.Id,
                RamRole = defaultRole.Name,
                SecurityGroupId = defaultSecurityGroup.Id,
            },
        },
        LogCollectStrategy = JsonSerializer.Serialize(new Dictionary<string, object?>
        {
            ["open"] = new[]
            {
                "all",
            },
            ["close"] = new[]
            {
                "",
            },
        }),
        ResourceGroupId = @default.Apply(@default => @default.Apply(getResourceGroupsResult => getResourceGroupsResult.Ids[0])),
        ClusterName = name,
        PaymentType = "PayAsYouGo",
        ClusterType = "DATAFLOW",
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.alicloud.resourcemanager.ResourcemanagerFunctions;
import com.pulumi.alicloud.resourcemanager.inputs.GetResourceGroupsArgs;
import com.pulumi.alicloud.kms.KmsFunctions;
import com.pulumi.alicloud.kms.inputs.GetKeysArgs;
import com.pulumi.alicloud.AlicloudFunctions;
import com.pulumi.alicloud.inputs.GetZonesArgs;
import com.pulumi.alicloud.vpc.Network;
import com.pulumi.alicloud.vpc.NetworkArgs;
import com.pulumi.alicloud.vpc.Switch;
import com.pulumi.alicloud.vpc.SwitchArgs;
import com.pulumi.random.integer;
import com.pulumi.random.IntegerArgs;
import com.pulumi.alicloud.ecs.EcsKeyPair;
import com.pulumi.alicloud.ecs.EcsKeyPairArgs;
import com.pulumi.alicloud.ecs.SecurityGroup;
import com.pulumi.alicloud.ecs.SecurityGroupArgs;
import com.pulumi.alicloud.ram.Role;
import com.pulumi.alicloud.ram.RoleArgs;
import com.pulumi.alicloud.emrv2.Cluster;
import com.pulumi.alicloud.emrv2.ClusterArgs;
import com.pulumi.alicloud.emrv2.inputs.ClusterNodeGroupArgs;
import com.pulumi.alicloud.emrv2.inputs.ClusterNodeGroupSystemDiskArgs;
import com.pulumi.alicloud.emrv2.inputs.ClusterNodeAttributeArgs;
import static com.pulumi.codegen.internal.Serialization.*;
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 config = ctx.config();
        final var name = config.get("name").orElse("tf-example");
        final var default = ResourcemanagerFunctions.getResourceGroups(GetResourceGroupsArgs.builder()
            .status("OK")
            .build());

        final var defaultGetKeys = KmsFunctions.getKeys(GetKeysArgs.builder()
            .status("Enabled")
            .build());

        final var defaultGetZones = AlicloudFunctions.getZones(GetZonesArgs.builder()
            .availableInstanceType("ecs.g7.xlarge")
            .build());

        var defaultNetwork = new Network("defaultNetwork", NetworkArgs.builder()        
            .vpcName(name)
            .cidrBlock("172.16.0.0/12")
            .build());

        var defaultSwitch = new Switch("defaultSwitch", SwitchArgs.builder()        
            .vpcId(defaultNetwork.id())
            .cidrBlock("172.16.0.0/21")
            .zoneId(defaultGetZones.applyValue(getZonesResult -> getZonesResult.zones()[0].id()))
            .vswitchName(name)
            .build());

        var defaultInteger = new Integer("defaultInteger", IntegerArgs.builder()        
            .max(99999)
            .min(10000)
            .build());

        var defaultEcsKeyPair = new EcsKeyPair("defaultEcsKeyPair", EcsKeyPairArgs.builder()        
            .keyPairName(String.format("%s-%s", name,defaultInteger.result()))
            .build());

        var defaultSecurityGroup = new SecurityGroup("defaultSecurityGroup", SecurityGroupArgs.builder()        
            .name(name)
            .vpcId(defaultNetwork.id())
            .build());

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

        var defaultCluster = new Cluster("defaultCluster", ClusterArgs.builder()        
            .nodeGroups(            
                ClusterNodeGroupArgs.builder()
                    .vswitchIds(defaultSwitch.id())
                    .instanceTypes("ecs.g7.xlarge")
                    .nodeCount("1")
                    .spotInstanceRemedy("false")
                    .dataDisks(ClusterNodeGroupDataDiskArgs.builder()
                        .count("3")
                        .category("cloud_essd")
                        .size("80")
                        .performanceLevel("PL0")
                        .build())
                    .nodeGroupName("emr-master")
                    .paymentType("PayAsYouGo")
                    .withPublicIp("false")
                    .gracefulShutdown("false")
                    .systemDisk(ClusterNodeGroupSystemDiskArgs.builder()
                        .category("cloud_essd")
                        .size("80")
                        .performanceLevel("PL0")
                        .count("1")
                        .build())
                    .nodeGroupType("MASTER")
                    .build(),
                ClusterNodeGroupArgs.builder()
                    .spotInstanceRemedy("false")
                    .deploymentSetStrategy("CLUSTER")
                    .nodeGroupType("CORE")
                    .vswitchIds(defaultSwitch.id())
                    .nodeCount("2")
                    .gracefulShutdown("false")
                    .systemDisk(ClusterNodeGroupSystemDiskArgs.builder()
                        .performanceLevel("PL0")
                        .count("1")
                        .category("cloud_essd")
                        .size("80")
                        .build())
                    .dataDisks(ClusterNodeGroupDataDiskArgs.builder()
                        .count("3")
                        .performanceLevel("PL0")
                        .category("cloud_essd")
                        .size("80")
                        .build())
                    .nodeGroupName("emr-core")
                    .paymentType("PayAsYouGo")
                    .instanceTypes("ecs.g7.xlarge")
                    .withPublicIp("false")
                    .build())
            .deployMode("NORMAL")
            .tags(Map.ofEntries(
                Map.entry("Created", "TF"),
                Map.entry("For", "example")
            ))
            .releaseVersion("EMR-5.10.0")
            .applications(            
                "HADOOP-COMMON",
                "HDFS",
                "YARN")
            .nodeAttributes(ClusterNodeAttributeArgs.builder()
                .zoneId(defaultGetZones.applyValue(getZonesResult -> getZonesResult.zones()[0].id()))
                .keyPairName(defaultEcsKeyPair.id())
                .dataDiskEncrypted("true")
                .dataDiskKmsKeyId(defaultGetKeys.applyValue(getKeysResult -> getKeysResult.ids()[0]))
                .vpcId(defaultNetwork.id())
                .ramRole(defaultRole.name())
                .securityGroupId(defaultSecurityGroup.id())
                .build())
            .logCollectStrategy(serializeJson(
                jsonObject(
                    jsonProperty("open", jsonArray("all")),
                    jsonProperty("close", jsonArray(""))
                )))
            .resourceGroupId(default_.ids()[0])
            .clusterName(name)
            .paymentType("PayAsYouGo")
            .clusterType("DATAFLOW")
            .build());

    }
}

configuration:
  name:
    type: string
    default: tf-example
resources:
  defaultNetwork:
    type: alicloud:vpc:Network
    name: default
    properties:
      vpcName: ${name}
      cidrBlock: 172.16.0.0/12
  defaultSwitch:
    type: alicloud:vpc:Switch
    name: default
    properties:
      vpcId: ${defaultNetwork.id}
      cidrBlock: 172.16.0.0/21
      zoneId: ${defaultGetZones.zones[0].id}
      vswitchName: ${name}
  defaultInteger:
    type: random:integer
    name: default
    properties:
      max: 99999
      min: 10000
  defaultEcsKeyPair:
    type: alicloud:ecs:EcsKeyPair
    name: default
    properties:
      keyPairName: ${name}-${defaultInteger.result}
  defaultSecurityGroup:
    type: alicloud:ecs:SecurityGroup
    name: default
    properties:
      name: ${name}
      vpcId: ${defaultNetwork.id}
  defaultRole:
    type: alicloud:ram:Role
    name: default
    properties:
      name: ${name}
      document: |2
            {
                "Statement": [
                {
                    "Action": "sts:AssumeRole",
                    "Effect": "Allow",
                    "Principal": {
                    "Service": [
                        "emr.aliyuncs.com",
                        "ecs.aliyuncs.com"
                    ]
                    }
                }
                ],
                "Version": "1"
            }
      description: this is a role example.
      force: true
  defaultCluster:
    type: alicloud:emrv2:Cluster
    name: default
    properties:
      nodeGroups:
        - vswitchIds:
            - ${defaultSwitch.id}
          instanceTypes:
            - ecs.g7.xlarge
          nodeCount: '1'
          spotInstanceRemedy: 'false'
          dataDisks:
            - count: '3'
              category: cloud_essd
              size: '80'
              performanceLevel: PL0
          nodeGroupName: emr-master
          paymentType: PayAsYouGo
          withPublicIp: 'false'
          gracefulShutdown: 'false'
          systemDisk:
            category: cloud_essd
            size: '80'
            performanceLevel: PL0
            count: '1'
          nodeGroupType: MASTER
        - spotInstanceRemedy: 'false'
          deploymentSetStrategy: CLUSTER
          nodeGroupType: CORE
          vswitchIds:
            - ${defaultSwitch.id}
          nodeCount: '2'
          gracefulShutdown: 'false'
          systemDisk:
            performanceLevel: PL0
            count: '1'
            category: cloud_essd
            size: '80'
          dataDisks:
            - count: '3'
              performanceLevel: PL0
              category: cloud_essd
              size: '80'
          nodeGroupName: emr-core
          paymentType: PayAsYouGo
          instanceTypes:
            - ecs.g7.xlarge
          withPublicIp: 'false'
      deployMode: NORMAL
      tags:
        Created: TF
        For: example
      releaseVersion: EMR-5.10.0
      applications:
        - HADOOP-COMMON
        - HDFS
        - YARN
      nodeAttributes:
        - zoneId: ${defaultGetZones.zones[0].id}
          keyPairName: ${defaultEcsKeyPair.id}
          dataDiskEncrypted: 'true'
          dataDiskKmsKeyId: ${defaultGetKeys.ids[0]}
          vpcId: ${defaultNetwork.id}
          ramRole: ${defaultRole.name}
          securityGroupId: ${defaultSecurityGroup.id}
      logCollectStrategy:
        fn::toJSON:
          open:
            - all
          close:
            -
      resourceGroupId: ${default.ids[0]}
      clusterName: ${name}
      paymentType: PayAsYouGo
      clusterType: DATAFLOW
variables:
  default:
    fn::invoke:
      Function: alicloud:resourcemanager:getResourceGroups
      Arguments:
        status: OK
  defaultGetKeys:
    fn::invoke:
      Function: alicloud:kms:getKeys
      Arguments:
        status: Enabled
  defaultGetZones:
    fn::invoke:
      Function: alicloud:getZones
      Arguments:
        availableInstanceType: ecs.g7.xlarge

var exampleclusterResourceResourceFromEmrv2cluster = new AliCloud.Emrv2.Cluster("exampleclusterResourceResourceFromEmrv2cluster", new()
{
    NodeAttributes = new[]
    {
        new AliCloud.Emrv2.Inputs.ClusterNodeAttributeArgs
        {
            KeyPairName = "string",
            RamRole = "string",
            SecurityGroupId = "string",
            VpcId = "string",
            ZoneId = "string",
            DataDiskEncrypted = false,
            DataDiskKmsKeyId = "string",
        },
    },
    Applications = new[]
    {
        "string",
    },
    ReleaseVersion = "string",
    ClusterName = "string",
    ClusterType = "string",
    NodeGroups = new[]
    {
        new AliCloud.Emrv2.Inputs.ClusterNodeGroupArgs
        {
            NodeCount = 0,
            SystemDisk = new AliCloud.Emrv2.Inputs.ClusterNodeGroupSystemDiskArgs
            {
                Category = "string",
                Size = 0,
                Count = 0,
                PerformanceLevel = "string",
            },
            DataDisks = new[]
            {
                new AliCloud.Emrv2.Inputs.ClusterNodeGroupDataDiskArgs
                {
                    Category = "string",
                    Size = 0,
                    Count = 0,
                    PerformanceLevel = "string",
                },
            },
            NodeGroupType = "string",
            NodeGroupName = "string",
            InstanceTypes = new[]
            {
                "string",
            },
            GracefulShutdown = false,
            AdditionalSecurityGroupIds = new[]
            {
                "string",
            },
            DeploymentSetStrategy = "string",
            NodeResizeStrategy = "string",
            PaymentType = "string",
            SpotBidPrices = new[]
            {
                new AliCloud.Emrv2.Inputs.ClusterNodeGroupSpotBidPriceArgs
                {
                    BidPrice = 0,
                    InstanceType = "string",
                },
            },
            SpotInstanceRemedy = false,
            SubscriptionConfig = new AliCloud.Emrv2.Inputs.ClusterNodeGroupSubscriptionConfigArgs
            {
                PaymentDuration = 0,
                PaymentDurationUnit = "string",
                AutoPayOrder = false,
                AutoRenew = false,
                AutoRenewDuration = 0,
                AutoRenewDurationUnit = "string",
            },
            CostOptimizedConfig = new AliCloud.Emrv2.Inputs.ClusterNodeGroupCostOptimizedConfigArgs
            {
                OnDemandBaseCapacity = 0,
                OnDemandPercentageAboveBaseCapacity = 0,
                SpotInstancePools = 0,
            },
            VswitchIds = new[]
            {
                "string",
            },
            WithPublicIp = false,
        },
    },
    LogCollectStrategy = "string",
    ApplicationConfigs = new[]
    {
        new AliCloud.Emrv2.Inputs.ClusterApplicationConfigArgs
        {
            ApplicationName = "string",
            ConfigFileName = "string",
            ConfigItemKey = "string",
            ConfigItemValue = "string",
            ConfigDescription = "string",
            ConfigScope = "string",
            NodeGroupId = "string",
            NodeGroupName = "string",
        },
    },
    DeployMode = "string",
    PaymentType = "string",
    BootstrapScripts = new[]
    {
        new AliCloud.Emrv2.Inputs.ClusterBootstrapScriptArgs
        {
            ExecutionFailStrategy = "string",
            ExecutionMoment = "string",
            NodeSelector = new AliCloud.Emrv2.Inputs.ClusterBootstrapScriptNodeSelectorArgs
            {
                NodeSelectType = "string",
                NodeGroupId = "string",
                NodeGroupName = "string",
                NodeGroupTypes = new[]
                {
                    "string",
                },
                NodeNames = new[]
                {
                    "string",
                },
            },
            ScriptArgs = "string",
            ScriptName = "string",
            ScriptPath = "string",
            Priority = 0,
        },
    },
    ResourceGroupId = "string",
    SecurityMode = "string",
    SubscriptionConfig = new AliCloud.Emrv2.Inputs.ClusterSubscriptionConfigArgs
    {
        PaymentDuration = 0,
        PaymentDurationUnit = "string",
        AutoPayOrder = false,
        AutoRenew = false,
        AutoRenewDuration = 0,
        AutoRenewDurationUnit = "string",
    },
    Tags = 
    {
        { "string", "any" },
    },
});

example, err := emrv2.NewCluster(ctx, "exampleclusterResourceResourceFromEmrv2cluster", &emrv2.ClusterArgs{
	NodeAttributes: emrv2.ClusterNodeAttributeArray{
		&emrv2.ClusterNodeAttributeArgs{
			KeyPairName:       pulumi.String("string"),
			RamRole:           pulumi.String("string"),
			SecurityGroupId:   pulumi.String("string"),
			VpcId:             pulumi.String("string"),
			ZoneId:            pulumi.String("string"),
			DataDiskEncrypted: pulumi.Bool(false),
			DataDiskKmsKeyId:  pulumi.String("string"),
		},
	},
	Applications: pulumi.StringArray{
		pulumi.String("string"),
	},
	ReleaseVersion: pulumi.String("string"),
	ClusterName:    pulumi.String("string"),
	ClusterType:    pulumi.String("string"),
	NodeGroups: emrv2.ClusterNodeGroupArray{
		&emrv2.ClusterNodeGroupArgs{
			NodeCount: pulumi.Int(0),
			SystemDisk: &emrv2.ClusterNodeGroupSystemDiskArgs{
				Category:         pulumi.String("string"),
				Size:             pulumi.Int(0),
				Count:            pulumi.Int(0),
				PerformanceLevel: pulumi.String("string"),
			},
			DataDisks: emrv2.ClusterNodeGroupDataDiskArray{
				&emrv2.ClusterNodeGroupDataDiskArgs{
					Category:         pulumi.String("string"),
					Size:             pulumi.Int(0),
					Count:            pulumi.Int(0),
					PerformanceLevel: pulumi.String("string"),
				},
			},
			NodeGroupType: pulumi.String("string"),
			NodeGroupName: pulumi.String("string"),
			InstanceTypes: pulumi.StringArray{
				pulumi.String("string"),
			},
			GracefulShutdown: pulumi.Bool(false),
			AdditionalSecurityGroupIds: pulumi.StringArray{
				pulumi.String("string"),
			},
			DeploymentSetStrategy: pulumi.String("string"),
			NodeResizeStrategy:    pulumi.String("string"),
			PaymentType:           pulumi.String("string"),
			SpotBidPrices: emrv2.ClusterNodeGroupSpotBidPriceArray{
				&emrv2.ClusterNodeGroupSpotBidPriceArgs{
					BidPrice:     pulumi.Int(0),
					InstanceType: pulumi.String("string"),
				},
			},
			SpotInstanceRemedy: pulumi.Bool(false),
			SubscriptionConfig: &emrv2.ClusterNodeGroupSubscriptionConfigArgs{
				PaymentDuration:       pulumi.Int(0),
				PaymentDurationUnit:   pulumi.String("string"),
				AutoPayOrder:          pulumi.Bool(false),
				AutoRenew:             pulumi.Bool(false),
				AutoRenewDuration:     pulumi.Int(0),
				AutoRenewDurationUnit: pulumi.String("string"),
			},
			CostOptimizedConfig: &emrv2.ClusterNodeGroupCostOptimizedConfigArgs{
				OnDemandBaseCapacity:                pulumi.Int(0),
				OnDemandPercentageAboveBaseCapacity: pulumi.Int(0),
				SpotInstancePools:                   pulumi.Int(0),
			},
			VswitchIds: pulumi.StringArray{
				pulumi.String("string"),
			},
			WithPublicIp: pulumi.Bool(false),
		},
	},
	LogCollectStrategy: pulumi.String("string"),
	ApplicationConfigs: emrv2.ClusterApplicationConfigArray{
		&emrv2.ClusterApplicationConfigArgs{
			ApplicationName:   pulumi.String("string"),
			ConfigFileName:    pulumi.String("string"),
			ConfigItemKey:     pulumi.String("string"),
			ConfigItemValue:   pulumi.String("string"),
			ConfigDescription: pulumi.String("string"),
			ConfigScope:       pulumi.String("string"),
			NodeGroupId:       pulumi.String("string"),
			NodeGroupName:     pulumi.String("string"),
		},
	},
	DeployMode:  pulumi.String("string"),
	PaymentType: pulumi.String("string"),
	BootstrapScripts: emrv2.ClusterBootstrapScriptArray{
		&emrv2.ClusterBootstrapScriptArgs{
			ExecutionFailStrategy: pulumi.String("string"),
			ExecutionMoment:       pulumi.String("string"),
			NodeSelector: &emrv2.ClusterBootstrapScriptNodeSelectorArgs{
				NodeSelectType: pulumi.String("string"),
				NodeGroupId:    pulumi.String("string"),
				NodeGroupName:  pulumi.String("string"),
				NodeGroupTypes: pulumi.StringArray{
					pulumi.String("string"),
				},
				NodeNames: pulumi.StringArray{
					pulumi.String("string"),
				},
			},
			ScriptArgs: pulumi.String("string"),
			ScriptName: pulumi.String("string"),
			ScriptPath: pulumi.String("string"),
			Priority:   pulumi.Int(0),
		},
	},
	ResourceGroupId: pulumi.String("string"),
	SecurityMode:    pulumi.String("string"),
	SubscriptionConfig: &emrv2.ClusterSubscriptionConfigArgs{
		PaymentDuration:       pulumi.Int(0),
		PaymentDurationUnit:   pulumi.String("string"),
		AutoPayOrder:          pulumi.Bool(false),
		AutoRenew:             pulumi.Bool(false),
		AutoRenewDuration:     pulumi.Int(0),
		AutoRenewDurationUnit: pulumi.String("string"),
	},
	Tags: pulumi.Map{
		"string": pulumi.Any("any"),
	},
})