Alibaba Cloud v3.76.0, Apr 8 25

Alibaba Cloud v3.76.0 published on Tuesday, Apr 8, 2025 by Pulumi

alicloud.emrv2.getClusterInstances

Explore with Pulumi AI

Alibaba Cloud v3.76.0 published on Tuesday, Apr 8, 2025 by Pulumi

Example Usage

Basic Usage

TypeScript
Python
Go
C#
Java
YAML

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

const _default = alicloud.resourcemanager.getResourceGroups({
    status: "OK",
});
const defaultGetZones = alicloud.getZones({
    availableInstanceType: "ecs.g7.xlarge",
});
const defaultNetwork = new alicloud.vpc.Network("default", {
    vpcName: "TF-VPC",
    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: "TF_VSwitch",
});
const defaultEcsKeyPair = new alicloud.ecs.EcsKeyPair("default", {keyPairName: "terraform-kp"});
const defaultSecurityGroup = new alicloud.ecs.SecurityGroup("default", {
    name: "TF_SECURITY_GROUP",
    vpcId: defaultNetwork.id,
});
const defaultRole = new alicloud.ram.Role("default", {
    name: "emrtf",
    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.emrv2.Cluster("default", {
    paymentType: "PayAsYouGo",
    clusterType: "DATALAKE",
    releaseVersion: "EMR-5.10.0",
    clusterName: "terraform-emr-cluster-v2",
    deployMode: "NORMAL",
    securityMode: "NORMAL",
    applications: [
        "HADOOP-COMMON",
        "HDFS",
        "YARN",
        "HIVE",
        "SPARK3",
        "TEZ",
    ],
    applicationConfigs: [
        {
            applicationName: "HIVE",
            configFileName: "hivemetastore-site.xml",
            configItemKey: "hive.metastore.type",
            configItemValue: "DLF",
            configScope: "CLUSTER",
        },
        {
            applicationName: "SPARK3",
            configFileName: "hive-site.xml",
            configItemKey: "hive.metastore.type",
            configItemValue: "DLF",
            configScope: "CLUSTER",
        },
    ],
    nodeAttributes: [{
        ramRole: defaultRole.name,
        securityGroupId: defaultSecurityGroup.id,
        vpcId: defaultNetwork.id,
        zoneId: defaultGetZones.then(defaultGetZones => defaultGetZones.zones?.[0]?.id),
        keyPairName: defaultEcsKeyPair.id,
    }],
    tags: {
        created: "tf",
    },
    nodeGroups: [
        {
            nodeGroupType: "MASTER",
            nodeGroupName: "emr-master",
            paymentType: "PayAsYouGo",
            vswitchIds: [defaultSwitch.id],
            withPublicIp: false,
            instanceTypes: ["ecs.g7.xlarge"],
            nodeCount: 1,
            systemDisk: {
                category: "cloud_essd",
                size: 80,
                count: 1,
            },
            dataDisks: [{
                category: "cloud_essd",
                size: 80,
                count: 3,
            }],
        },
        {
            nodeGroupType: "CORE",
            nodeGroupName: "emr-core",
            paymentType: "PayAsYouGo",
            vswitchIds: [defaultSwitch.id],
            withPublicIp: false,
            instanceTypes: ["ecs.g7.xlarge"],
            nodeCount: 3,
            systemDisk: {
                category: "cloud_essd",
                size: 80,
                count: 1,
            },
            dataDisks: [{
                category: "cloud_essd",
                size: 80,
                count: 3,
            }],
        },
    ],
    resourceGroupId: _default.then(_default => _default.ids?.[0]),
});
const ids = alicloud.emrv2.getClusterInstances({});
export const emrv2ClusterInstancesId1 = ids.then(ids => ids.instances?.[0]?.instanceId);
const nodeGroupNames = alicloud.emrv2.getClusterInstances({
    nodeGroupNames: ["emr-core"],
});
export const emrv2ClusterInstancesId2 = nodeGroupNames.then(nodeGroupNames => nodeGroupNames.instances?.[0]?.instanceId);

import pulumi
import pulumi_alicloud as alicloud

default = alicloud.resourcemanager.get_resource_groups(status="OK")
default_get_zones = alicloud.get_zones(available_instance_type="ecs.g7.xlarge")
default_network = alicloud.vpc.Network("default",
    vpc_name="TF-VPC",
    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="TF_VSwitch")
default_ecs_key_pair = alicloud.ecs.EcsKeyPair("default", key_pair_name="terraform-kp")
default_security_group = alicloud.ecs.SecurityGroup("default",
    name="TF_SECURITY_GROUP",
    vpc_id=default_network.id)
default_role = alicloud.ram.Role("default",
    name="emrtf",
    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.emrv2.Cluster("default",
    payment_type="PayAsYouGo",
    cluster_type="DATALAKE",
    release_version="EMR-5.10.0",
    cluster_name="terraform-emr-cluster-v2",
    deploy_mode="NORMAL",
    security_mode="NORMAL",
    applications=[
        "HADOOP-COMMON",
        "HDFS",
        "YARN",
        "HIVE",
        "SPARK3",
        "TEZ",
    ],
    application_configs=[
        {
            "application_name": "HIVE",
            "config_file_name": "hivemetastore-site.xml",
            "config_item_key": "hive.metastore.type",
            "config_item_value": "DLF",
            "config_scope": "CLUSTER",
        },
        {
            "application_name": "SPARK3",
            "config_file_name": "hive-site.xml",
            "config_item_key": "hive.metastore.type",
            "config_item_value": "DLF",
            "config_scope": "CLUSTER",
        },
    ],
    node_attributes=[{
        "ram_role": default_role.name,
        "security_group_id": default_security_group.id,
        "vpc_id": default_network.id,
        "zone_id": default_get_zones.zones[0].id,
        "key_pair_name": default_ecs_key_pair.id,
    }],
    tags={
        "created": "tf",
    },
    node_groups=[
        {
            "node_group_type": "MASTER",
            "node_group_name": "emr-master",
            "payment_type": "PayAsYouGo",
            "vswitch_ids": [default_switch.id],
            "with_public_ip": False,
            "instance_types": ["ecs.g7.xlarge"],
            "node_count": 1,
            "system_disk": {
                "category": "cloud_essd",
                "size": 80,
                "count": 1,
            },
            "data_disks": [{
                "category": "cloud_essd",
                "size": 80,
                "count": 3,
            }],
        },
        {
            "node_group_type": "CORE",
            "node_group_name": "emr-core",
            "payment_type": "PayAsYouGo",
            "vswitch_ids": [default_switch.id],
            "with_public_ip": False,
            "instance_types": ["ecs.g7.xlarge"],
            "node_count": 3,
            "system_disk": {
                "category": "cloud_essd",
                "size": 80,
                "count": 1,
            },
            "data_disks": [{
                "category": "cloud_essd",
                "size": 80,
                "count": 3,
            }],
        },
    ],
    resource_group_id=default.ids[0])
ids = alicloud.emrv2.get_cluster_instances()
pulumi.export("emrv2ClusterInstancesId1", ids.instances[0].instance_id)
node_group_names = alicloud.emrv2.get_cluster_instances(node_group_names=["emr-core"])
pulumi.export("emrv2ClusterInstancesId2", node_group_names.instances[0].instance_id)

package main

import (
	"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/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/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_default, err := resourcemanager.GetResourceGroups(ctx, &resourcemanager.GetResourceGroupsArgs{
			Status: pulumi.StringRef("OK"),
		}, 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("TF-VPC"),
			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("TF_VSwitch"),
		})
		if err != nil {
			return err
		}
		defaultEcsKeyPair, err := ecs.NewEcsKeyPair(ctx, "default", &ecs.EcsKeyPairArgs{
			KeyPairName: pulumi.String("terraform-kp"),
		})
		if err != nil {
			return err
		}
		defaultSecurityGroup, err := ecs.NewSecurityGroup(ctx, "default", &ecs.SecurityGroupArgs{
			Name:  pulumi.String("TF_SECURITY_GROUP"),
			VpcId: defaultNetwork.ID(),
		})
		if err != nil {
			return err
		}
		defaultRole, err := ram.NewRole(ctx, "default", &ram.RoleArgs{
			Name: pulumi.String("emrtf"),
			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
		}
		_, err = emrv2.NewCluster(ctx, "default", &emrv2.ClusterArgs{
			PaymentType:    pulumi.String("PayAsYouGo"),
			ClusterType:    pulumi.String("DATALAKE"),
			ReleaseVersion: pulumi.String("EMR-5.10.0"),
			ClusterName:    pulumi.String("terraform-emr-cluster-v2"),
			DeployMode:     pulumi.String("NORMAL"),
			SecurityMode:   pulumi.String("NORMAL"),
			Applications: pulumi.StringArray{
				pulumi.String("HADOOP-COMMON"),
				pulumi.String("HDFS"),
				pulumi.String("YARN"),
				pulumi.String("HIVE"),
				pulumi.String("SPARK3"),
				pulumi.String("TEZ"),
			},
			ApplicationConfigs: emrv2.ClusterApplicationConfigArray{
				&emrv2.ClusterApplicationConfigArgs{
					ApplicationName: pulumi.String("HIVE"),
					ConfigFileName:  pulumi.String("hivemetastore-site.xml"),
					ConfigItemKey:   pulumi.String("hive.metastore.type"),
					ConfigItemValue: pulumi.String("DLF"),
					ConfigScope:     pulumi.String("CLUSTER"),
				},
				&emrv2.ClusterApplicationConfigArgs{
					ApplicationName: pulumi.String("SPARK3"),
					ConfigFileName:  pulumi.String("hive-site.xml"),
					ConfigItemKey:   pulumi.String("hive.metastore.type"),
					ConfigItemValue: pulumi.String("DLF"),
					ConfigScope:     pulumi.String("CLUSTER"),
				},
			},
			NodeAttributes: emrv2.ClusterNodeAttributeArray{
				&emrv2.ClusterNodeAttributeArgs{
					RamRole:         defaultRole.Name,
					SecurityGroupId: defaultSecurityGroup.ID(),
					VpcId:           defaultNetwork.ID(),
					ZoneId:          pulumi.String(defaultGetZones.Zones[0].Id),
					KeyPairName:     defaultEcsKeyPair.ID(),
				},
			},
			Tags: pulumi.StringMap{
				"created": pulumi.String("tf"),
			},
			NodeGroups: emrv2.ClusterNodeGroupArray{
				&emrv2.ClusterNodeGroupArgs{
					NodeGroupType: pulumi.String("MASTER"),
					NodeGroupName: pulumi.String("emr-master"),
					PaymentType:   pulumi.String("PayAsYouGo"),
					VswitchIds: pulumi.StringArray{
						defaultSwitch.ID(),
					},
					WithPublicIp: pulumi.Bool(false),
					InstanceTypes: pulumi.StringArray{
						pulumi.String("ecs.g7.xlarge"),
					},
					NodeCount: pulumi.Int(1),
					SystemDisk: &emrv2.ClusterNodeGroupSystemDiskArgs{
						Category: pulumi.String("cloud_essd"),
						Size:     pulumi.Int(80),
						Count:    pulumi.Int(1),
					},
					DataDisks: emrv2.ClusterNodeGroupDataDiskArray{
						&emrv2.ClusterNodeGroupDataDiskArgs{
							Category: pulumi.String("cloud_essd"),
							Size:     pulumi.Int(80),
							Count:    pulumi.Int(3),
						},
					},
				},
				&emrv2.ClusterNodeGroupArgs{
					NodeGroupType: pulumi.String("CORE"),
					NodeGroupName: pulumi.String("emr-core"),
					PaymentType:   pulumi.String("PayAsYouGo"),
					VswitchIds: pulumi.StringArray{
						defaultSwitch.ID(),
					},
					WithPublicIp: pulumi.Bool(false),
					InstanceTypes: pulumi.StringArray{
						pulumi.String("ecs.g7.xlarge"),
					},
					NodeCount: pulumi.Int(3),
					SystemDisk: &emrv2.ClusterNodeGroupSystemDiskArgs{
						Category: pulumi.String("cloud_essd"),
						Size:     pulumi.Int(80),
						Count:    pulumi.Int(1),
					},
					DataDisks: emrv2.ClusterNodeGroupDataDiskArray{
						&emrv2.ClusterNodeGroupDataDiskArgs{
							Category: pulumi.String("cloud_essd"),
							Size:     pulumi.Int(80),
							Count:    pulumi.Int(3),
						},
					},
				},
			},
			ResourceGroupId: pulumi.String(_default.Ids[0]),
		})
		if err != nil {
			return err
		}
		ids, err := emrv2.GetClusterInstances(ctx, &emrv2.GetClusterInstancesArgs{}, nil)
		if err != nil {
			return err
		}
		ctx.Export("emrv2ClusterInstancesId1", ids.Instances[0].InstanceId)
		nodeGroupNames, err := emrv2.GetClusterInstances(ctx, &emrv2.GetClusterInstancesArgs{
			NodeGroupNames: []string{
				"emr-core",
			},
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("emrv2ClusterInstancesId2", nodeGroupNames.Instances[0].InstanceId)
		return nil
	})
}

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

return await Deployment.RunAsync(() => 
{
    var @default = AliCloud.ResourceManager.GetResourceGroups.Invoke(new()
    {
        Status = "OK",
    });

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

    var defaultNetwork = new AliCloud.Vpc.Network("default", new()
    {
        VpcName = "TF-VPC",
        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 = "TF_VSwitch",
    });

    var defaultEcsKeyPair = new AliCloud.Ecs.EcsKeyPair("default", new()
    {
        KeyPairName = "terraform-kp",
    });

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

    var defaultRole = new AliCloud.Ram.Role("default", new()
    {
        Name = "emrtf",
        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.Emrv2.Cluster("default", new()
    {
        PaymentType = "PayAsYouGo",
        ClusterType = "DATALAKE",
        ReleaseVersion = "EMR-5.10.0",
        ClusterName = "terraform-emr-cluster-v2",
        DeployMode = "NORMAL",
        SecurityMode = "NORMAL",
        Applications = new[]
        {
            "HADOOP-COMMON",
            "HDFS",
            "YARN",
            "HIVE",
            "SPARK3",
            "TEZ",
        },
        ApplicationConfigs = new[]
        {
            new AliCloud.Emrv2.Inputs.ClusterApplicationConfigArgs
            {
                ApplicationName = "HIVE",
                ConfigFileName = "hivemetastore-site.xml",
                ConfigItemKey = "hive.metastore.type",
                ConfigItemValue = "DLF",
                ConfigScope = "CLUSTER",
            },
            new AliCloud.Emrv2.Inputs.ClusterApplicationConfigArgs
            {
                ApplicationName = "SPARK3",
                ConfigFileName = "hive-site.xml",
                ConfigItemKey = "hive.metastore.type",
                ConfigItemValue = "DLF",
                ConfigScope = "CLUSTER",
            },
        },
        NodeAttributes = new[]
        {
            new AliCloud.Emrv2.Inputs.ClusterNodeAttributeArgs
            {
                RamRole = defaultRole.Name,
                SecurityGroupId = defaultSecurityGroup.Id,
                VpcId = defaultNetwork.Id,
                ZoneId = defaultGetZones.Apply(getZonesResult => getZonesResult.Zones[0]?.Id),
                KeyPairName = defaultEcsKeyPair.Id,
            },
        },
        Tags = 
        {
            { "created", "tf" },
        },
        NodeGroups = new[]
        {
            new AliCloud.Emrv2.Inputs.ClusterNodeGroupArgs
            {
                NodeGroupType = "MASTER",
                NodeGroupName = "emr-master",
                PaymentType = "PayAsYouGo",
                VswitchIds = new[]
                {
                    defaultSwitch.Id,
                },
                WithPublicIp = false,
                InstanceTypes = new[]
                {
                    "ecs.g7.xlarge",
                },
                NodeCount = 1,
                SystemDisk = new AliCloud.Emrv2.Inputs.ClusterNodeGroupSystemDiskArgs
                {
                    Category = "cloud_essd",
                    Size = 80,
                    Count = 1,
                },
                DataDisks = new[]
                {
                    new AliCloud.Emrv2.Inputs.ClusterNodeGroupDataDiskArgs
                    {
                        Category = "cloud_essd",
                        Size = 80,
                        Count = 3,
                    },
                },
            },
            new AliCloud.Emrv2.Inputs.ClusterNodeGroupArgs
            {
                NodeGroupType = "CORE",
                NodeGroupName = "emr-core",
                PaymentType = "PayAsYouGo",
                VswitchIds = new[]
                {
                    defaultSwitch.Id,
                },
                WithPublicIp = false,
                InstanceTypes = new[]
                {
                    "ecs.g7.xlarge",
                },
                NodeCount = 3,
                SystemDisk = new AliCloud.Emrv2.Inputs.ClusterNodeGroupSystemDiskArgs
                {
                    Category = "cloud_essd",
                    Size = 80,
                    Count = 1,
                },
                DataDisks = new[]
                {
                    new AliCloud.Emrv2.Inputs.ClusterNodeGroupDataDiskArgs
                    {
                        Category = "cloud_essd",
                        Size = 80,
                        Count = 3,
                    },
                },
            },
        },
        ResourceGroupId = @default.Apply(@default => @default.Apply(getResourceGroupsResult => getResourceGroupsResult.Ids[0])),
    });

    var ids = AliCloud.Emrv2.GetClusterInstances.Invoke();

    var nodeGroupNames = AliCloud.Emrv2.GetClusterInstances.Invoke(new()
    {
        NodeGroupNames = new[]
        {
            "emr-core",
        },
    });

    return new Dictionary<string, object?>
    {
        ["emrv2ClusterInstancesId1"] = ids.Apply(getClusterInstancesResult => getClusterInstancesResult.Instances[0]?.InstanceId),
        ["emrv2ClusterInstancesId2"] = nodeGroupNames.Apply(getClusterInstancesResult => getClusterInstancesResult.Instances[0]?.InstanceId),
    };
});

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.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.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.ClusterApplicationConfigArgs;
import com.pulumi.alicloud.emrv2.inputs.ClusterNodeAttributeArgs;
import com.pulumi.alicloud.emrv2.inputs.ClusterNodeGroupArgs;
import com.pulumi.alicloud.emrv2.inputs.ClusterNodeGroupSystemDiskArgs;
import com.pulumi.alicloud.emrv2.Emrv2Functions;
import com.pulumi.alicloud.emrv2.inputs.GetClusterInstancesArgs;
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 = ResourcemanagerFunctions.getResourceGroups(GetResourceGroupsArgs.builder()
            .status("OK")
            .build());

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

        var defaultNetwork = new Network("defaultNetwork", NetworkArgs.builder()
            .vpcName("TF-VPC")
            .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("TF_VSwitch")
            .build());

        var defaultEcsKeyPair = new EcsKeyPair("defaultEcsKeyPair", EcsKeyPairArgs.builder()
            .keyPairName("terraform-kp")
            .build());

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

        var defaultRole = new Role("defaultRole", RoleArgs.builder()
            .name("emrtf")
            .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()
            .paymentType("PayAsYouGo")
            .clusterType("DATALAKE")
            .releaseVersion("EMR-5.10.0")
            .clusterName("terraform-emr-cluster-v2")
            .deployMode("NORMAL")
            .securityMode("NORMAL")
            .applications(            
                "HADOOP-COMMON",
                "HDFS",
                "YARN",
                "HIVE",
                "SPARK3",
                "TEZ")
            .applicationConfigs(            
                ClusterApplicationConfigArgs.builder()
                    .applicationName("HIVE")
                    .configFileName("hivemetastore-site.xml")
                    .configItemKey("hive.metastore.type")
                    .configItemValue("DLF")
                    .configScope("CLUSTER")
                    .build(),
                ClusterApplicationConfigArgs.builder()
                    .applicationName("SPARK3")
                    .configFileName("hive-site.xml")
                    .configItemKey("hive.metastore.type")
                    .configItemValue("DLF")
                    .configScope("CLUSTER")
                    .build())
            .nodeAttributes(ClusterNodeAttributeArgs.builder()
                .ramRole(defaultRole.name())
                .securityGroupId(defaultSecurityGroup.id())
                .vpcId(defaultNetwork.id())
                .zoneId(defaultGetZones.applyValue(getZonesResult -> getZonesResult.zones()[0].id()))
                .keyPairName(defaultEcsKeyPair.id())
                .build())
            .tags(Map.of("created", "tf"))
            .nodeGroups(            
                ClusterNodeGroupArgs.builder()
                    .nodeGroupType("MASTER")
                    .nodeGroupName("emr-master")
                    .paymentType("PayAsYouGo")
                    .vswitchIds(defaultSwitch.id())
                    .withPublicIp(false)
                    .instanceTypes("ecs.g7.xlarge")
                    .nodeCount(1)
                    .systemDisk(ClusterNodeGroupSystemDiskArgs.builder()
                        .category("cloud_essd")
                        .size(80)
                        .count(1)
                        .build())
                    .dataDisks(ClusterNodeGroupDataDiskArgs.builder()
                        .category("cloud_essd")
                        .size(80)
                        .count(3)
                        .build())
                    .build(),
                ClusterNodeGroupArgs.builder()
                    .nodeGroupType("CORE")
                    .nodeGroupName("emr-core")
                    .paymentType("PayAsYouGo")
                    .vswitchIds(defaultSwitch.id())
                    .withPublicIp(false)
                    .instanceTypes("ecs.g7.xlarge")
                    .nodeCount(3)
                    .systemDisk(ClusterNodeGroupSystemDiskArgs.builder()
                        .category("cloud_essd")
                        .size(80)
                        .count(1)
                        .build())
                    .dataDisks(ClusterNodeGroupDataDiskArgs.builder()
                        .category("cloud_essd")
                        .size(80)
                        .count(3)
                        .build())
                    .build())
            .resourceGroupId(default_.ids()[0])
            .build());

        final var ids = Emrv2Functions.getClusterInstances();

        ctx.export("emrv2ClusterInstancesId1", ids.applyValue(getClusterInstancesResult -> getClusterInstancesResult.instances()[0].instanceId()));
        final var nodeGroupNames = Emrv2Functions.getClusterInstances(GetClusterInstancesArgs.builder()
            .nodeGroupNames("emr-core")
            .build());

        ctx.export("emrv2ClusterInstancesId2", nodeGroupNames.applyValue(getClusterInstancesResult -> getClusterInstancesResult.instances()[0].instanceId()));
    }
}

resources:
  defaultNetwork:
    type: alicloud:vpc:Network
    name: default
    properties:
      vpcName: TF-VPC
      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: TF_VSwitch
  defaultEcsKeyPair:
    type: alicloud:ecs:EcsKeyPair
    name: default
    properties:
      keyPairName: terraform-kp
  defaultSecurityGroup:
    type: alicloud:ecs:SecurityGroup
    name: default
    properties:
      name: TF_SECURITY_GROUP
      vpcId: ${defaultNetwork.id}
  defaultRole:
    type: alicloud:ram:Role
    name: default
    properties:
      name: emrtf
      document: |2
            {
                "Statement": [
                {
                    "Action": "sts:AssumeRole",
                    "Effect": "Allow",
                    "Principal": {
                    "Service": [
                        "emr.aliyuncs.com",
                        "ecs.aliyuncs.com"
                    ]
                    }
                }
                ],
                "Version": "1"
            }
      description: this is a role test.
      force: true
  defaultCluster:
    type: alicloud:emrv2:Cluster
    name: default
    properties:
      paymentType: PayAsYouGo
      clusterType: DATALAKE
      releaseVersion: EMR-5.10.0
      clusterName: terraform-emr-cluster-v2
      deployMode: NORMAL
      securityMode: NORMAL
      applications:
        - HADOOP-COMMON
        - HDFS
        - YARN
        - HIVE
        - SPARK3
        - TEZ
      applicationConfigs:
        - applicationName: HIVE
          configFileName: hivemetastore-site.xml
          configItemKey: hive.metastore.type
          configItemValue: DLF
          configScope: CLUSTER
        - applicationName: SPARK3
          configFileName: hive-site.xml
          configItemKey: hive.metastore.type
          configItemValue: DLF
          configScope: CLUSTER
      nodeAttributes:
        - ramRole: ${defaultRole.name}
          securityGroupId: ${defaultSecurityGroup.id}
          vpcId: ${defaultNetwork.id}
          zoneId: ${defaultGetZones.zones[0].id}
          keyPairName: ${defaultEcsKeyPair.id}
      tags:
        created: tf
      nodeGroups:
        - nodeGroupType: MASTER
          nodeGroupName: emr-master
          paymentType: PayAsYouGo
          vswitchIds:
            - ${defaultSwitch.id}
          withPublicIp: false
          instanceTypes:
            - ecs.g7.xlarge
          nodeCount: 1
          systemDisk:
            category: cloud_essd
            size: 80
            count: 1
          dataDisks:
            - category: cloud_essd
              size: 80
              count: 3
        - nodeGroupType: CORE
          nodeGroupName: emr-core
          paymentType: PayAsYouGo
          vswitchIds:
            - ${defaultSwitch.id}
          withPublicIp: false
          instanceTypes:
            - ecs.g7.xlarge
          nodeCount: 3
          systemDisk:
            category: cloud_essd
            size: 80
            count: 1
          dataDisks:
            - category: cloud_essd
              size: 80
              count: 3
      resourceGroupId: ${default.ids[0]}
variables:
  default:
    fn::invoke:
      function: alicloud:resourcemanager:getResourceGroups
      arguments:
        status: OK
  defaultGetZones:
    fn::invoke:
      function: alicloud:getZones
      arguments:
        availableInstanceType: ecs.g7.xlarge
  ids:
    fn::invoke:
      function: alicloud:emrv2:getClusterInstances
      arguments: {}
  nodeGroupNames:
    fn::invoke:
      function: alicloud:emrv2:getClusterInstances
      arguments:
        nodeGroupNames:
          - emr-core
outputs:
  emrv2ClusterInstancesId1: ${ids.instances[0].instanceId}
  emrv2ClusterInstancesId2: ${nodeGroupNames.instances[0].instanceId}

Using getClusterInstances

Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

TypeScript
Python
Go
C#
Java
YAML

function getClusterInstances(args: GetClusterInstancesArgs, opts?: InvokeOptions): Promise<GetClusterInstancesResult>
function getClusterInstancesOutput(args: GetClusterInstancesOutputArgs, opts?: InvokeOptions): Output<GetClusterInstancesResult>

def get_cluster_instances(cluster_id: Optional[str] = None,
                          ids: Optional[Sequence[str]] = None,
                          instance_states: Optional[Sequence[str]] = None,
                          max_results: Optional[int] = None,
                          next_token: Optional[str] = None,
                          node_group_ids: Optional[Sequence[str]] = None,
                          node_group_names: Optional[Sequence[str]] = None,
                          output_file: Optional[str] = None,
                          tags: Optional[Mapping[str, str]] = None,
                          opts: Optional[InvokeOptions] = None) -> GetClusterInstancesResult
def get_cluster_instances_output(cluster_id: Optional[pulumi.Input[str]] = None,
                          ids: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None,
                          instance_states: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None,
                          max_results: Optional[pulumi.Input[int]] = None,
                          next_token: Optional[pulumi.Input[str]] = None,
                          node_group_ids: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None,
                          node_group_names: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None,
                          output_file: Optional[pulumi.Input[str]] = None,
                          tags: Optional[pulumi.Input[Mapping[str, pulumi.Input[str]]]] = None,
                          opts: Optional[InvokeOptions] = None) -> Output[GetClusterInstancesResult]

func GetClusterInstances(ctx *Context, args *GetClusterInstancesArgs, opts ...InvokeOption) (*GetClusterInstancesResult, error)
func GetClusterInstancesOutput(ctx *Context, args *GetClusterInstancesOutputArgs, opts ...InvokeOption) GetClusterInstancesResultOutput

> Note: This function is named GetClusterInstances in the Go SDK.

public static class GetClusterInstances 
{
    public static Task<GetClusterInstancesResult> InvokeAsync(GetClusterInstancesArgs args, InvokeOptions? opts = null)
    public static Output<GetClusterInstancesResult> Invoke(GetClusterInstancesInvokeArgs args, InvokeOptions? opts = null)
}

public static CompletableFuture<GetClusterInstancesResult> getClusterInstances(GetClusterInstancesArgs args, InvokeOptions options)
public static Output<GetClusterInstancesResult> getClusterInstances(GetClusterInstancesArgs args, InvokeOptions options)

fn::invoke:
  function: alicloud:emrv2/getClusterInstances:getClusterInstances
  arguments:
    # arguments dictionary

The following arguments are supported:

ClusterId string: The emr cluster ID.
Ids List<string>: A list of Cluster IDs.
InstanceStates List<string>: The cluster ecs instance states.
MaxResults int: The max results is used to list emr cluster ecs instances for next page.
NextToken string: The next token is used to list emr cluster ecs instances for next page.
NodeGroupIds List<string>: The cluster node group ids.
NodeGroupNames List<string>: The cluster node group names.
OutputFile string: File name where to save data source results (after running pulumi preview).
Tags Dictionary<string, string>: A mapping of tags to assign to the resource.

ClusterId string: The emr cluster ID.
Ids []string: A list of Cluster IDs.
InstanceStates []string: The cluster ecs instance states.
MaxResults int: The max results is used to list emr cluster ecs instances for next page.
NextToken string: The next token is used to list emr cluster ecs instances for next page.
NodeGroupIds []string: The cluster node group ids.
NodeGroupNames []string: The cluster node group names.
OutputFile string: File name where to save data source results (after running pulumi preview).
Tags map[string]string: A mapping of tags to assign to the resource.

clusterId String: The emr cluster ID.
ids List<String>: A list of Cluster IDs.
instanceStates List<String>: The cluster ecs instance states.
maxResults Integer: The max results is used to list emr cluster ecs instances for next page.
nextToken String: The next token is used to list emr cluster ecs instances for next page.
nodeGroupIds List<String>: The cluster node group ids.
nodeGroupNames List<String>: The cluster node group names.
outputFile String: File name where to save data source results (after running pulumi preview).
tags Map<String,String>: A mapping of tags to assign to the resource.

clusterId string: The emr cluster ID.
ids string[]: A list of Cluster IDs.
instanceStates string[]: The cluster ecs instance states.
maxResults number: The max results is used to list emr cluster ecs instances for next page.
nextToken string: The next token is used to list emr cluster ecs instances for next page.
nodeGroupIds string[]: The cluster node group ids.
nodeGroupNames string[]: The cluster node group names.
outputFile string: File name where to save data source results (after running pulumi preview).
tags {[key: string]: string}: A mapping of tags to assign to the resource.

cluster_id str: The emr cluster ID.
ids Sequence[str]: A list of Cluster IDs.
instance_states Sequence[str]: The cluster ecs instance states.
max_results int: The max results is used to list emr cluster ecs instances for next page.
next_token str: The next token is used to list emr cluster ecs instances for next page.
node_group_ids Sequence[str]: The cluster node group ids.
node_group_names Sequence[str]: The cluster node group names.
output_file str: File name where to save data source results (after running pulumi preview).
tags Mapping[str, str]: A mapping of tags to assign to the resource.

clusterId String: The emr cluster ID.
ids List<String>: A list of Cluster IDs.
instanceStates List<String>: The cluster ecs instance states.
maxResults Number: The max results is used to list emr cluster ecs instances for next page.
nextToken String: The next token is used to list emr cluster ecs instances for next page.
nodeGroupIds List<String>: The cluster node group ids.
nodeGroupNames List<String>: The cluster node group names.
outputFile String: File name where to save data source results (after running pulumi preview).
tags Map<String>: A mapping of tags to assign to the resource.

getClusterInstances Result

The following output properties are available:

ClusterId string
Id string: The provider-assigned unique ID for this managed resource.
Ids List<string>: A list of Cluster ecs instance IDS.
Instances List<Pulumi.AliCloud.Emrv2.Outputs.GetClusterInstancesInstance>: A list of Emr Cluster ecs instances. Each element contains the following attributes:
Names List<string>: A list of Cluster ecs instance names.
NextToken string
TotalCount int: The total count of list emr cluster ecs instances.
InstanceStates List<string>
MaxResults int
NodeGroupIds List<string>
NodeGroupNames List<string>
OutputFile string
Tags Dictionary<string, string>

ClusterId string
Id string: The provider-assigned unique ID for this managed resource.
Ids []string: A list of Cluster ecs instance IDS.
Instances []GetClusterInstancesInstance: A list of Emr Cluster ecs instances. Each element contains the following attributes:
Names []string: A list of Cluster ecs instance names.
NextToken string
TotalCount int: The total count of list emr cluster ecs instances.
InstanceStates []string
MaxResults int
NodeGroupIds []string
NodeGroupNames []string
OutputFile string
Tags map[string]string

clusterId String
id String: The provider-assigned unique ID for this managed resource.
ids List<String>: A list of Cluster ecs instance IDS.
instances List<GetClusterInstancesInstance>: A list of Emr Cluster ecs instances. Each element contains the following attributes:
names List<String>: A list of Cluster ecs instance names.
nextToken String
totalCount Integer: The total count of list emr cluster ecs instances.
instanceStates List<String>
maxResults Integer
nodeGroupIds List<String>
nodeGroupNames List<String>
outputFile String
tags Map<String,String>

clusterId string
id string: The provider-assigned unique ID for this managed resource.
ids string[]: A list of Cluster ecs instance IDS.
instances GetClusterInstancesInstance[]: A list of Emr Cluster ecs instances. Each element contains the following attributes:
names string[]: A list of Cluster ecs instance names.
nextToken string
totalCount number: The total count of list emr cluster ecs instances.
instanceStates string[]
maxResults number
nodeGroupIds string[]
nodeGroupNames string[]
outputFile string
tags {[key: string]: string}

cluster_id str
id str: The provider-assigned unique ID for this managed resource.
ids Sequence[str]: A list of Cluster ecs instance IDS.
instances Sequence[GetClusterInstancesInstance]: A list of Emr Cluster ecs instances. Each element contains the following attributes:
names Sequence[str]: A list of Cluster ecs instance names.
next_token str
total_count int: The total count of list emr cluster ecs instances.
instance_states Sequence[str]
max_results int
node_group_ids Sequence[str]
node_group_names Sequence[str]
output_file str
tags Mapping[str, str]

clusterId String
id String: The provider-assigned unique ID for this managed resource.
ids List<String>: A list of Cluster ecs instance IDS.
instances List<Property Map>: A list of Emr Cluster ecs instances. Each element contains the following attributes:
names List<String>: A list of Cluster ecs instance names.
nextToken String
totalCount Number: The total count of list emr cluster ecs instances.
instanceStates List<String>
maxResults Number
nodeGroupIds List<String>
nodeGroupNames List<String>
outputFile String
tags Map<String>

Supporting Types

GetClusterInstancesInstance

AutoRenew bool: The emr cluster node group whether auto renew when payment type is 'Subscription'.
AutoRenewDuration int: The emr cluster node group auto renew duration when payment type is 'Subscription'.
AutoRenewDurationUnit string: The emr cluster node group auto renew duration unit when payment type is 'Subscription'.
CreateTime string: The creation time of the resource.
ExpireTime string: The expire time of the resource.
InstanceId string: The emr cluster ecs instance ID.
InstanceName string: The emr cluster ecs instance name.
InstanceState string: The emr cluster ecs instance state.
InstanceType string: The emr cluster ecs instance type.
NodeGroupId string: The emr cluster node group ID.
NodeGroupType string: The emr cluster node group type.
PrivateIp string: The emr cluster ecs instance private ip.
PublicIp string: The emr cluster ecs instance public ip.
ZoneId string: The emr cluster node group zone ID.

AutoRenew bool: The emr cluster node group whether auto renew when payment type is 'Subscription'.
AutoRenewDuration int: The emr cluster node group auto renew duration when payment type is 'Subscription'.
AutoRenewDurationUnit string: The emr cluster node group auto renew duration unit when payment type is 'Subscription'.
CreateTime string: The creation time of the resource.
ExpireTime string: The expire time of the resource.
InstanceId string: The emr cluster ecs instance ID.
InstanceName string: The emr cluster ecs instance name.
InstanceState string: The emr cluster ecs instance state.
InstanceType string: The emr cluster ecs instance type.
NodeGroupId string: The emr cluster node group ID.
NodeGroupType string: The emr cluster node group type.
PrivateIp string: The emr cluster ecs instance private ip.
PublicIp string: The emr cluster ecs instance public ip.
ZoneId string: The emr cluster node group zone ID.

autoRenew Boolean: The emr cluster node group whether auto renew when payment type is 'Subscription'.
autoRenewDuration Integer: The emr cluster node group auto renew duration when payment type is 'Subscription'.
autoRenewDurationUnit String: The emr cluster node group auto renew duration unit when payment type is 'Subscription'.
createTime String: The creation time of the resource.
expireTime String: The expire time of the resource.
instanceId String: The emr cluster ecs instance ID.
instanceName String: The emr cluster ecs instance name.
instanceState String: The emr cluster ecs instance state.
instanceType String: The emr cluster ecs instance type.
nodeGroupId String: The emr cluster node group ID.
nodeGroupType String: The emr cluster node group type.
privateIp String: The emr cluster ecs instance private ip.
publicIp String: The emr cluster ecs instance public ip.
zoneId String: The emr cluster node group zone ID.

autoRenew boolean: The emr cluster node group whether auto renew when payment type is 'Subscription'.
autoRenewDuration number: The emr cluster node group auto renew duration when payment type is 'Subscription'.
autoRenewDurationUnit string: The emr cluster node group auto renew duration unit when payment type is 'Subscription'.
createTime string: The creation time of the resource.
expireTime string: The expire time of the resource.
instanceId string: The emr cluster ecs instance ID.
instanceName string: The emr cluster ecs instance name.
instanceState string: The emr cluster ecs instance state.
instanceType string: The emr cluster ecs instance type.
nodeGroupId string: The emr cluster node group ID.
nodeGroupType string: The emr cluster node group type.
privateIp string: The emr cluster ecs instance private ip.
publicIp string: The emr cluster ecs instance public ip.
zoneId string: The emr cluster node group zone ID.

auto_renew bool: The emr cluster node group whether auto renew when payment type is 'Subscription'.
auto_renew_duration int: The emr cluster node group auto renew duration when payment type is 'Subscription'.
auto_renew_duration_unit str: The emr cluster node group auto renew duration unit when payment type is 'Subscription'.
create_time str: The creation time of the resource.
expire_time str: The expire time of the resource.
instance_id str: The emr cluster ecs instance ID.
instance_name str: The emr cluster ecs instance name.
instance_state str: The emr cluster ecs instance state.
instance_type str: The emr cluster ecs instance type.
node_group_id str: The emr cluster node group ID.
node_group_type str: The emr cluster node group type.
private_ip str: The emr cluster ecs instance private ip.
public_ip str: The emr cluster ecs instance public ip.
zone_id str: The emr cluster node group zone ID.

autoRenew Boolean: The emr cluster node group whether auto renew when payment type is 'Subscription'.
autoRenewDuration Number: The emr cluster node group auto renew duration when payment type is 'Subscription'.
autoRenewDurationUnit String: The emr cluster node group auto renew duration unit when payment type is 'Subscription'.
createTime String: The creation time of the resource.
expireTime String: The expire time of the resource.
instanceId String: The emr cluster ecs instance ID.
instanceName String: The emr cluster ecs instance name.
instanceState String: The emr cluster ecs instance state.
instanceType String: The emr cluster ecs instance type.
nodeGroupId String: The emr cluster node group ID.
nodeGroupType String: The emr cluster node group type.
privateIp String: The emr cluster ecs instance private ip.
publicIp String: The emr cluster ecs instance public ip.
zoneId String: The emr cluster node group zone ID.

Package Details

Repository: Alibaba Cloud pulumi/pulumi-alicloud
License: Apache-2.0
Notes: This Pulumi package is based on the alicloud Terraform Provider.

Alibaba Cloud v3.76.0 published on Tuesday, Apr 8, 2025 by Pulumi

pulumi/pulumi-alicloud

alicloud.emrv2.getClusterInstances

On this page

On this page

Example Usage

Using getClusterInstances

getClusterInstances Result

Supporting Types

GetClusterInstancesInstance

Package Details

On this page

On this page