Cluster erstellen

Cluster erstellen

Voraussetzungen:

  • Name: Der Clustername muss mit einem Kleinbuchstaben beginnen, gefolgt von bis zu 51 Kleinbuchstaben, Ziffern und Bindestrichen. Das letzte Zeichen darf kein Bindestrich sein.

  • Clusterregion: Sie müssen eine Compute Engine-Region für den Cluster angeben, z. B. us-east1 oder europe-west1, um Clusterressourcen wie VM-Instanzen und in Cloud Storage gespeicherte Clustermetadaten innerhalb der Region zu isolieren.

    • Weitere Informationen zu Compute Engine-Regionen finden Sie unter Clusterregion.
    • Informationen zum Auswählen von Regionen finden Sie unter Verfügbare Regionen und Zonen. Sie können auch den Befehl gcloud compute regions list ausführen, um eine Liste der verfügbaren Regionen aufzurufen.

  • Konnektivität: Compute Engine-VM-Instanzen (VMs) in einem Managed Service for Apache Spark-Cluster, bestehend aus Master- und Worker-VMs, erfordern eine vollständige interne IP-Adressen-Netzwerkverbindung. Das default-VPC-Netzwerk stellt diese Verbindung bereit (siehe Netzwerkkonfiguration für Managed Service for Apache Spark-Cluster).

  • Maschinentyp (empfohlen): Die Angabe eines Maschinentyps ist zwar optional, Google empfiehlt jedoch, explizit einen Maschinentyp für die Master- und Worker-VMs in Ihrem Cluster auszuwählen. Wenn Sie keinen Maschinentyp angeben, wählt Managed Service for Apache Spark dynamisch Maschinentypen basierend auf der Ressourcenverfügbarkeit aus. Diese dynamische Auswahl kann zu Abweichungen bei Kosten und Leistung führen.

    • Weitere Informationen zur Auswahl eines Maschinentyps finden Sie unter Unterstützte Maschinentypen.
    • Um potenzielle Probleme mit der Nichtverfügbarkeit von Ressourcen zu minimieren, empfehlen wir die Verwendung von flexiblen VMs, mit denen Sie eine Liste akzeptabler Maschinentypen angeben können.

Console

Öffnen Sie in der Google Cloud -Console die Seite Cluster erstellen, um die Standard-Clustereinstellungen aufzurufen. Sie können die angezeigten Standardeinstellungen bestätigen oder ändern und dann auf Zusätzliche Konfiguration klicken, um den Cluster weiter anzupassen.

Klicken Sie auf Cluster erstellen, um den Cluster zu erstellen. Der Clustername wird auf der Seite Cluster angezeigt und der Status wird nach der Bereitstellung des Clusters in Running geändert. Klicken Sie auf den Clusternamen, um die Seite mit den Clusterdetails zu öffnen. Dort können Sie Jobs, Instanzen und Konfigurationseinstellungen für Ihren Cluster prüfen und eine Verbindung zu Weboberflächen herstellen, die auf dem Cluster ausgeführt werden.

gcloud

Wenn Sie einen Managed Service for Apache Spark-Cluster über die Befehlszeile erstellen möchten, führen Sie den Befehl gcloud dataproc clusters create lokal in einem Terminalfenster oder in Cloud Shell aus.

gcloud dataproc clusters create CLUSTER_NAME \
    --region=REGION \
    --master-machine-type=MASTER_MACHINE_TYPE \
    --worker-machine-type=WORKER_MACHINE_TYPE

Mit dem Befehl wird ein Cluster erstellt. Master- und Worker-Maschinentypen sind zwar optional, es wird jedoch empfohlen, sie explizit mit den Flags --master-machine-type und --worker-machine-type (z. B. n4-standard-4) anzugeben, um einheitliche Kosten und Leistung zu gewährleisten. Wenn Sie keine Maschinentypen angeben, werden Standardmaschinentypen dynamisch basierend auf der Ressourcenverfügbarkeit ausgewählt. Informationen zur Verwendung von Befehlszeilen-Flags zum Anpassen von Clustereinstellungen finden Sie im Befehl gcloud dataproc clusters create.

Erstellen Sie einen Cluster mit einer YAML-Datei

  1. Führen Sie den folgenden gcloud-Befehl aus, um die Konfiguration eines vorhandenen Managed Service for Apache Spark-Clusters in eine cluster.yaml-Datei zu exportieren. 
    gcloud dataproc clusters export EXISTING_CLUSTER_NAME \
    --region=REGION \
    --destination=cluster.yaml
  2. Erstellen Sie einen neuen Cluster. Dazu importieren Sie die Konfiguration der YAML-Datei. 
    gcloud dataproc clusters import NEW_CLUSTER_NAME \
    --region=REGION \
    --source=cluster.yaml

**Hinweis:** Während des Exportvorgangs werden clusterspezifische Felder wie Clustername, Nur-Ausgabe-Felder und automatisch angewendete Labels gefiltert. Diese Felder sind in der importierten YAML-Datei, die zum Erstellen eines Clusters verwendet wurde, nicht zulässig.

REST

In diesem Abschnitt wird beschrieben, wie Sie einen Cluster erstellen. Die Angabe von Maschinentypen ist zwar optional, es wird jedoch empfohlen, machine_type_uri explizit in Ihre master_config und worker_config (z. B. n4-standard-4) aufzunehmen, um einheitliche Kosten und Leistung zu gewährleisten. Wenn Sie keine Maschinentypen angeben, werden Standardmaschinentypen dynamisch basierend auf der Ressourcenverfügbarkeit ausgewählt.

Ersetzen Sie diese Werte in den folgenden Anfragedaten:

  • CLUSTER_NAME: Clustername
  • PROJECT: Google Cloud -Projekt-ID
  • REGION: Eine verfügbare Compute Engine-Region, in der der Cluster erstellt wird.
  • ZONE: Eine optionale Zone innerhalb der ausgewählten Region, in der der Cluster erstellt wird.
  • MASTER_MACHINE_TYPE: (Empfohlen) Der Maschinentyp für den Masterknoten (z. B. n4-standard-4).
  • WORKER_MACHINE_TYPE: (Empfohlen) Der Maschinentyp für Worker-Knoten (z. B. n4-standard-4).

HTTP-Methode und URL: 

POST https://dataproc.googleapis.com/v1/projects/PROJECT/regions/REGION/clusters

JSON-Text anfordern:

{
  "project_id":"PROJECT",
  "cluster_name":"CLUSTER_NAME",
  "config":{
    "master_config":{
      "num_instances":1,
      "machine_type_uri":"MASTER_MACHINE_TYPE",
      "image_uri":""
    },
    "softwareConfig": {
      "imageVersion": "",
      "properties": {},
      "optionalComponents": []
    },
    "worker_config":{
      "num_instances":2,
      "machine_type_uri":"WORKER_MACHINE_TYPE",
      "image_uri":""
    },
    "gce_cluster_config":{
      "zone_uri":"ZONE"
    }
  }
}

Wenn Sie die Anfrage senden möchten, maximieren Sie eine der folgenden Optionen:

Sie sollten eine JSON-Antwort ähnlich wie diese erhalten:

{
"name": "projects/PROJECT/regions/REGION/operations/b5706e31......",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.dataproc.v1.ClusterOperationMetadata",
    "clusterName": "CLUSTER_NAME",
    "clusterUuid": "5fe882b2-...",
    "status": {
      "state": "PENDING",
      "innerState": "PENDING",
      "stateStartTime": "2019-11-21T00:37:56.220Z"
    },
    "operationType": "CREATE",
    "description": "Create cluster with 2 workers",
    "warnings": [
      "For PD-Standard without local SSDs, we strongly recommend provisioning 1TB ...""
    ]
  }
}

Go

  1. Installieren Sie die Clientbibliothek.
  2. Standardanmeldedaten für Anwendungen einrichten
  3. Führen Sie den Code aus.

    Hinweis: Die Angabe von Maschinentypen ist zwar optional, es wird jedoch empfohlen, die Master- und Worker-Maschinentypen in Ihrer Clusterkonfiguration explizit festzulegen (z. B. auf n4-standard-4), um konsistente Kosten und Leistung zu gewährleisten. Wenn Sie diese Angabe weglassen, werden die Standardmaschinentypen dynamisch anhand der Ressourcenverfügbarkeit ausgewählt.

    import (
	"context"
	"fmt"
	"io"

	dataproc "cloud.google.com/go/dataproc/apiv1"
	"cloud.google.com/go/dataproc/apiv1/dataprocpb"
	"google.golang.org/api/option"
)

func createCluster(w io.Writer, projectID, region, clusterName string) error {
	// projectID := "your-project-id"
	// region := "us-central1"
	// clusterName := "your-cluster"
	ctx := context.Background()

	// Create the cluster client.
	endpoint := region + "-dataproc.googleapis.com:443"
	clusterClient, err := dataproc.NewClusterControllerClient(ctx, option.WithEndpoint(endpoint))
	if err != nil {
		return fmt.Errorf("dataproc.NewClusterControllerClient: %w", err)
	}
	defer clusterClient.Close()

	// Create the cluster config.
	req := &dataprocpb.CreateClusterRequest{
		ProjectId: projectID,
		Region:    region,
		Cluster: &dataprocpb.Cluster{
			ProjectId:   projectID,
			ClusterName: clusterName,
			Config: &dataprocpb.ClusterConfig{
				MasterConfig: &dataprocpb.InstanceGroupConfig{
					NumInstances:   1,
					MachineTypeUri: "n1-standard-2",
				},
				WorkerConfig: &dataprocpb.InstanceGroupConfig{
					NumInstances:   2,
					MachineTypeUri: "n1-standard-2",
				},
			},
		},
	}

	// Create the cluster.
	op, err := clusterClient.CreateCluster(ctx, req)
	if err != nil {
		return fmt.Errorf("CreateCluster: %w", err)
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		return fmt.Errorf("CreateCluster.Wait: %w", err)
	}

	// Output a success message.
	fmt.Fprintf(w, "Cluster created successfully: %s", resp.ClusterName)
	return nil
}

Java

  1. Installieren Sie die Clientbibliothek.
  2. Standardanmeldedaten für Anwendungen einrichten
  3. Führen Sie den Code aus.

    Hinweis: Die Angabe von Maschinentypen ist zwar optional, es wird jedoch empfohlen, die Master- und Worker-Maschinentypen in Ihrer Clusterkonfiguration explizit festzulegen (z. B. auf n4-standard-4), um konsistente Kosten und Leistung zu gewährleisten. Wenn Sie diese Angabe weglassen, werden die Standardmaschinentypen dynamisch anhand der Ressourcenverfügbarkeit ausgewählt.

    import com.google.api.gax.longrunning.OperationFuture;
import com.google.cloud.dataproc.v1.Cluster;
import com.google.cloud.dataproc.v1.ClusterConfig;
import com.google.cloud.dataproc.v1.ClusterControllerClient;
import com.google.cloud.dataproc.v1.ClusterControllerSettings;
import com.google.cloud.dataproc.v1.ClusterOperationMetadata;
import com.google.cloud.dataproc.v1.InstanceGroupConfig;
import java.io.IOException;
import java.util.concurrent.ExecutionException;

public class CreateCluster {

  public static void createCluster() throws IOException, InterruptedException {
    // TODO(developer): Replace these variables before running the sample.
    String projectId = "your-project-id";
    String region = "your-project-region";
    String clusterName = "your-cluster-name";
    createCluster(projectId, region, clusterName);
  }

  public static void createCluster(String projectId, String region, String clusterName)
      throws IOException, InterruptedException {
    String myEndpoint = String.format("%s-dataproc.googleapis.com:443", region);

    // Configure the settings for the cluster controller client.
    ClusterControllerSettings clusterControllerSettings =
        ClusterControllerSettings.newBuilder().setEndpoint(myEndpoint).build();

    // Create a cluster controller client with the configured settings. The client only needs to be
    // created once and can be reused for multiple requests. Using a try-with-resources
    // closes the client, but this can also be done manually with the .close() method.
    try (ClusterControllerClient clusterControllerClient =
        ClusterControllerClient.create(clusterControllerSettings)) {
      // Configure the settings for our cluster.
      InstanceGroupConfig masterConfig =
          InstanceGroupConfig.newBuilder()
              .setMachineTypeUri("n1-standard-2")
              .setNumInstances(1)
              .build();
      InstanceGroupConfig workerConfig =
          InstanceGroupConfig.newBuilder()
              .setMachineTypeUri("n1-standard-2")
              .setNumInstances(2)
              .build();
      ClusterConfig clusterConfig =
          ClusterConfig.newBuilder()
              .setMasterConfig(masterConfig)
              .setWorkerConfig(workerConfig)
              .build();
      // Create the cluster object with the desired cluster config.
      Cluster cluster =
          Cluster.newBuilder().setClusterName(clusterName).setConfig(clusterConfig).build();

      // Create the Cloud Dataproc cluster.
      OperationFuture<Cluster, ClusterOperationMetadata> createClusterAsyncRequest =
          clusterControllerClient.createClusterAsync(projectId, region, cluster);
      Cluster response = createClusterAsyncRequest.get();

      // Print out a success message.
      System.out.printf("Cluster created successfully: %s", response.getClusterName());

    } catch (ExecutionException e) {
      System.err.println(String.format("Error executing createCluster: %s ", e.getMessage()));
    }
  }
}

Node.js

  1. Installieren Sie die Clientbibliothek.
  2. Standardanmeldedaten für Anwendungen einrichten
  3. Führen Sie den Code aus.

    Hinweis: Die Angabe von Maschinentypen ist zwar optional, es wird jedoch empfohlen, die Master- und Worker-Maschinentypen in Ihrer Clusterkonfiguration explizit festzulegen (z. B. auf n4-standard-4), um konsistente Kosten und Leistung zu gewährleisten. Wenn Sie diese Angabe weglassen, werden die Standardmaschinentypen dynamisch anhand der Ressourcenverfügbarkeit ausgewählt.

    const dataproc = require('@google-cloud/dataproc');

// TODO(developer): Uncomment and set the following variables
// projectId = 'YOUR_PROJECT_ID'
// region = 'YOUR_CLUSTER_REGION'
// clusterName = 'YOUR_CLUSTER_NAME'

// Create a client with the endpoint set to the desired cluster region
const client = new dataproc.v1.ClusterControllerClient({
  apiEndpoint: `${region}-dataproc.googleapis.com`,
  projectId: projectId,
});

async function createCluster() {
  // Create the cluster config
  const request = {
    projectId: projectId,
    region: region,
    cluster: {
      clusterName: clusterName,
      config: {
        masterConfig: {
          numInstances: 1,
          machineTypeUri: 'n1-standard-2',
        },
        workerConfig: {
          numInstances: 2,
          machineTypeUri: 'n1-standard-2',
        },
      },
    },
  };

  // Create the cluster
  const [operation] = await client.createCluster(request);
  const [response] = await operation.promise();

  // Output a success message
  console.log(`Cluster created successfully: ${response.clusterName}`);

Python

  1. Installieren Sie die Clientbibliothek.
  2. Standardanmeldedaten für Anwendungen einrichten
  3. Führen Sie den Code aus.

    Hinweis: Die Angabe von Maschinentypen ist zwar optional, es wird jedoch empfohlen, die Master- und Worker-Maschinentypen in Ihrer Clusterkonfiguration explizit festzulegen (z. B. auf n4-standard-4), um konsistente Kosten und Leistung zu gewährleisten. Wenn Sie diese Angabe weglassen, werden die Standardmaschinentypen dynamisch anhand der Ressourcenverfügbarkeit ausgewählt.

    from google.cloud import dataproc_v1 as dataproc


def create_cluster(project_id, region, cluster_name):
    """This sample walks a user through creating a Cloud Dataproc cluster
    using the Python client library.

    Args:
        project_id (string): Project to use for creating resources.
        region (string): Region where the resources should live.
        cluster_name (string): Name to use for creating a cluster.
    """

    # Create a client with the endpoint set to the desired cluster region.
    cluster_client = dataproc.ClusterControllerClient(
        client_options={"api_endpoint": f"{region}-dataproc.googleapis.com:443"}
    )

    # Create the cluster config.
    cluster = {
        "project_id": project_id,
        "cluster_name": cluster_name,
        "config": {
            "master_config": {"num_instances": 1, "machine_type_uri": "n1-standard-2"},
            "worker_config": {"num_instances": 2, "machine_type_uri": "n1-standard-2"},
        },
    }

    # Create the cluster.
    operation = cluster_client.create_cluster(
        request={"project_id": project_id, "region": region, "cluster": cluster}
    )
    result = operation.result()

    # Output a success message.
    print(f"Cluster created successfully: {result.cluster_name}")