Dataproc-Cluster mit der Google Cloud -Console erstellen
Auf dieser Seite erfahren Sie, wie Sie mit der Google Cloud Console einen Dataproc-Cluster erstellen, einen einfachen Apache Spark-Job im Cluster ausführen und dann die Anzahl der Worker im Cluster ändern.
Eine detaillierte Anleitung dazu finden Sie direkt in der Google Cloud Console. Klicken Sie dazu einfach auf Anleitung:
Hinweise
- Sign in to your Google Cloud account. If you're new to Google Cloud, create an account to evaluate how our products perform in real-world scenarios. New customers also get $300 in free credits to run, test, and deploy workloads.
-
In the Google Cloud console, on the project selector page, select or create a Google Cloud project.
-
Make sure that billing is enabled for your Google Cloud project.
-
Enable the Dataproc API.
-
In the Google Cloud console, on the project selector page, select or create a Google Cloud project.
-
Make sure that billing is enabled for your Google Cloud project.
-
Enable the Dataproc API.
Cluster erstellen
Rufen Sie in der Google Cloud -Konsole die Seite Dataproc-Cluster auf.
Klicken Sie auf Cluster erstellen.
Klicken Sie im Dialogfeld Dataproc-Cluster erstellen in der Zeile Cluster in Compute Engine auf Erstellen.
Geben Sie im Feld Clustername
example-cluster
ein.Wählen Sie in den Listen Region und Zone eine Region und eine Zone aus.
Wählen Sie eine Region aus (z. B.
us-east1
odereurope-west1
), um Ressourcen wie VM-Instanzen (virtuelle Maschinen) und Cloud Storage- und Metadatenspeicherorte zu isolieren, die von Dataproc in der Region verwendet werden. Weitere Informationen finden Sie unter Verfügbare Regionen und Zonen und Regionale Endpunkte.Verwenden Sie für alle anderen Optionen die Standardeinstellungen.
Klicken Sie auf Erstellen, um den Cluster zu erstellen.
Der neue Cluster wird auf der Seite Cluster in einer Liste angezeigt. Der Status ist Wird bereitgestellt, bis der Cluster zur Verwendung bereit ist. Anschließend ändert sich der Status in Aktiv. Die Bereitstellung des Clusters kann einige Minuten dauern.
Spark-Job senden
Senden Sie einen Spark-Job, der einen Wert für Pi schätzt:
- Klicken Sie im Dataproc-Navigationsmenü auf Jobs.
Klicken Sie auf der Seite Jobs auf
Job senden und gehen Sie dann so vor:- Verwenden Sie im Feld Job-ID die Standardeinstellung oder geben Sie eine ID an, die für Ihr Google Cloud Projekt eindeutig ist.
- Wählen Sie im Drop-down-Menü Cluster die Option
example-cluster
aus. - Wählen Sie als Jobtyp die Option Spark aus.
- Geben Sie im Feld Hauptklasse oder JAR-Datei
org.apache.spark.examples.SparkPi
ein. - Geben Sie im Feld JAR-Dateien
file:///usr/lib/spark/examples/jars/spark-examples.jar
ein. Geben Sie im Feld Argumente den Wert
1000
ein, um die Anzahl der Aufgaben festzulegen.Klicken Sie auf Senden.
Ihr Job wird auf der Seite Jobdetails angezeigt. Der Jobstatus ist Wird ausgeführt oder Wird gestartet und ändert sich nach dem Einreichen zu Erfolgreich.
Wenn Sie das Scrollen in der Ausgabe vermeiden möchten, klicken Sie auf Zeilenumbruch: aus. Die Ausgabe sieht etwa so aus:
Pi is roughly 3.1416759514167594
Klicken Sie auf den Tab Konfiguration, um Jobdetails aufzurufen.
Cluster aktualisieren
So aktualisieren Sie Ihren Cluster, indem Sie die Anzahl der Worker-Instanzen ändern:
- Klicken Sie im Dataproc-Navigationsmenü auf Cluster.
- Klicken Sie in der Liste der Cluster auf
example-cluster
. Klicken Sie auf der Seite Clusterdetails auf den Tab Konfiguration.
Die Clustereinstellungen werden angezeigt.
Klicken Sie auf
Bearbeiten.Geben Sie im Feld Worker-Knoten den Wert
5
ein.Klicken Sie auf Speichern.
Der Cluster wurde aktualisiert. Verwenden Sie das gleiche Verfahren, um die Anzahl der Worker-Knoten auf den ursprünglichen Wert zu reduzieren.
Bereinigen
Mit den folgenden Schritten vermeiden Sie, dass Ihrem Google Cloud -Konto die auf dieser Seite verwendeten Ressourcen in Rechnung gestellt werden:
- Wenn Sie den Cluster löschen möchten, klicken Sie auf der Seite Clusterdetails für
example-cluster
auf Löschen. - Klicken Sie auf Löschen, um zu bestätigen, dass Sie den Cluster löschen möchten.
Nächste Schritte
- Probieren Sie diese Kurzanleitung mit anderen Tools aus:
- Robuste Firewallregeln beim Erstellen eines Projekts generieren
- Informationen, wie Sie einen Spark-Scala-Job schreiben und ausführen