Halaman ini menunjukkan cara menggunakan alat command line gcloud Google Cloud CLI untuk membuat cluster Managed Service untuk Apache Spark, menjalankan tugas Apache Spark di cluster, lalu mengubah jumlah worker di cluster.
Anda dapat mengetahui cara melakukan tugas yang sama atau serupa dengan Panduan Memulai Menggunakan API Explorer, konsol Google Cloud di Membuat cluster menggunakan Google Cloud konsol, dan menggunakan library klien di Membuat cluster menggunakan library klien.
Sebelum memulai
-
Instal Google Cloud CLI.
-
Konfigurasi gcloud CLI agar menggunakan identitas gabungan Anda.
Untuk mengetahui informasi selengkapnya, lihat Login ke gcloud CLI dengan identitas gabungan Anda.
-
Untuk melakukan inisialisasi gcloud CLI, jalankan perintah berikut:
gcloud init -
Buat atau pilih Google Cloud project.
Peran yang diperlukan untuk memilih atau membuat project
- Pilih project: Memilih project tidak memerlukan peran IAM tertentu—Anda dapat memilih project mana pun yang telah diberi peran.
-
Membuat project: Untuk membuat project, Anda memerlukan peran Project Creator
(
roles/resourcemanager.projectCreator), yang berisi izinresourcemanager.projects.create. Pelajari cara memberikan peran.
-
Buat Google Cloud project:
gcloud projects create PROJECT_ID
Ganti
PROJECT_IDdengan nama untuk Google Cloud project yang Anda buat. -
Pilih project Google Cloud yang Anda buat:
gcloud config set project PROJECT_ID
Ganti
PROJECT_IDdengan nama project Google Cloud Anda.
-
Pastikan Anda memiliki izin yang diperlukan untuk menyelesaikan panduan ini.
-
Verifikasi bahwa penagihan diaktifkan untuk project Google Cloud Anda.
Aktifkan Dataproc API:
Peran yang diperlukan untuk mengaktifkan API
Untuk mengaktifkan API, Anda memerlukan izin
serviceusage.services.enable. Jika Anda membuat project, kemungkinan Anda sudah memiliki izin ini melalui peran Pemilik (roles/owner). Jika tidak, Anda bisa mendapatkan izin ini melalui peran Admin Penggunaan Layanan (roles/serviceusage.serviceUsageAdmin). Pelajari cara memberikan peran.gcloud services enable dataproc.googleapis.com
Peran yang diperlukan
Peran IAM tertentu diperlukan untuk menjalankan contoh di halaman ini. Bergantung pada kebijakan organisasi, peran ini mungkin sudah diberikan. Untuk memeriksa pemberian peran, lihat Apakah Anda perlu memberikan peran?.
Untuk mengetahui informasi selengkapnya tentang pemberian peran, lihat Mengelola akses ke project,folder, dan organisasi.
Peran pengguna
Untuk mendapatkan izin yang Anda perlukan untuk membuat cluster Managed Service untuk Apache Spark, minta administrator untuk memberi Anda peran IAM berikut:
- Dataproc Editor (
roles/dataproc.editor) di project - Pengguna Akun Layanan (
roles/iam.serviceAccountUser) di akun layanan default Compute Engine
Peran akun layanan
Untuk memastikan bahwa akun layanan default Compute Engine memiliki izin yang diperlukan untuk membuat cluster Managed Service untuk Apache Spark, minta administrator Anda untuk memberikan peran IAM berikut ke akun layanan default Compute Engine di project:
-
Semua:
Dataproc Worker (
roles/dataproc.worker)
Membuat cluster
Untuk membuat cluster bernama example-cluster, jalankan perintah gcloud
Managed Service for Apache Spark clusters
create berikut.
gcloud dataproc clusters create example-cluster --region=REGION
Ganti kode berikut:
REGION: Tentukan region tempat cluster akan berada.
Mengirim tugas
Untuk mengirimkan contoh tugas Spark yang menghitung nilai kasar untuk pi, jalankan perintah gcloud Managed Service untuk Apache Spark jobs submit spark berikut:
gcloud dataproc jobs submit spark --cluster example-cluster \ --region=REGION \ --class org.apache.spark.examples.SparkPi \ --jars file:///usr/lib/spark/examples/jars/spark-examples.jar -- 1000
Catatan:
Ganti kode berikut:
REGION: Tentukan region cluster.
- Tugas berjalan di
example-cluster. classberisi metode utama untuk SparkPi, yang menghitung perkiraan nilai aplikasipi.File jar berisi kode tugas. Catatan:
file:///usr/lib/spark/examples/jars/spark-examples.jaradalah contoh jar yang telah diinstal sebelumnya di cluster. Untuk tugas kustom, tentukan file jar Anda di Cloud Storage (lihat Mengirimkan tugas).1000adalah parameter tugas. Parameter ini menentukan jumlah tugas (iterasi) yang dilakukan tugas untuk menghitung nilaipi.
Tugas sedang berjalan dan output terakhir ditampilkan di jendela terminal:
Waiting for job output... ... Pi is roughly 3.14118528 ... Job finished successfully.
Mengupdate cluster
Untuk mengubah jumlah worker di cluster menjadi lima, jalankan perintah berikut:
gcloud dataproc clusters update example-cluster \ --region=REGION \ --num-workers 5
Output perintah menampilkan detail cluster:
workerConfig: ... instanceNames: - example-cluster-w-0 - example-cluster-w-1 - example-cluster-w-2 - example-cluster-w-3 - example-cluster-w-4 numInstances: 5 statusHistory: ... - detail: Add 3 workers.
Untuk mengurangi jumlah worker node ke nilai asli 2, jalankan perintah
berikut:
gcloud dataproc clusters update example-cluster \ --region=REGION \ --num-workers 2
Pembersihan
Agar akun Google Cloud Anda tidak dikenai biaya untuk resource yang digunakan di halaman ini, ikuti langkah-langkah berikut.
- Untuk menghapus
example-cluster, jalankan perintahclusters delete:gcloud dataproc clusters delete example-cluster \ --region=REGION
Langkah berikutnya
- Pelajari cara menulis dan menjalankan tugas Spark Scala.