Menggunakan Dataproc Hub

Tujuan

  1. Menggunakan Dataproc Hub untuk membuat lingkungan notebook JupyterLab satu pengguna yang berjalan di cluster Managed Service untuk Apache Spark.

  2. Membuat notebook dan menjalankan tugas Spark di cluster Managed Service untuk Apache Spark.

  3. Menghapus cluster dan menyimpan notebook di Cloud Storage.

Sebelum memulai

  1. Administrator harus memberi Anda izin notebooks.instances.use (lihat Menetapkan peran Identity and Access Management (IAM)).

Membuat cluster Dataproc JupyterLab dari Dataproc Hub

  1. Pilih tab User-Managed Notebooks di halaman Dataproc→Workbench di Google Cloud konsol.

  2. Klik Open JupyterLab di baris yang mencantumkan instance Dataproc Hub yang dibuat oleh administrator.

    1. Jika Anda tidak memiliki akses ke Google Cloud konsol, masukkan URL instance Dataproc Hub yang dibagikan administrator kepada Anda di browser web.
  3. Di halaman Jupyterhub→Dataproc Options, pilih konfigurasi cluster dan zona. Jika diaktifkan, tentukan penyesuaian apa pun, lalu klik Create.

    Setelah cluster Managed Service untuk Apache Spark dibuat, Anda akan dialihkan ke antarmuka JupyterLab yang berjalan di cluster.

Membuat notebook dan menjalankan tugas Spark

  1. Di panel kiri antarmuka JupyterLab, klik GCS (Cloud Storage).

  2. Buat notebook PySpark dari peluncur JupyterLab.

  3. Kernel PySpark menginisialisasi SparkContext (menggunakan variabel sc). Anda dapat memeriksa SparkContext dan menjalankan tugas Spark dari notebook.

    rdd = (sc.parallelize(['lorem', 'ipsum', 'dolor', 'sit', 'amet', 'lorem'])
           .map(lambda word: (word, 1))
           .reduceByKey(lambda a, b: a + b))
    print(rdd.collect())
    
  4. Beri nama dan simpan notebook. Notebook akan disimpan dan tetap berada di Cloud Storage setelah cluster Managed Service untuk Apache Spark dihapus.

Matikan cluster Dataproc

  1. Dari antarmuka JupyterLab, pilih File→Hub Control Panel untuk membuka halaman Jupyterhub.

  2. Klik Stop My Cluster untuk menonaktifkan (menghapus) server JupyterLab, yang akan menghapus cluster Managed Service untuk Apache Spark.

Langkah berikutnya