使用 Dataproc 中心

目标

  1. 使用 Dataproc Hub 创建单用户 在 Dataproc 集群上运行的 JupyterLab 笔记本环境。

  2. 在 Dataproc 集群上创建笔记本并运行 Spark 作业。

  3. 删除集群并在 Cloud Storage 中保留您的笔记本。

准备工作

  1. 管理员必须为您授予 notebooks.instances.use 权限（请参阅设置 Identity and Access Management (IAM) 角色）。

通过 Dataproc Hub 创建 Dataproc JupyterLab 集群

  1. 选择用户管理的笔记本标签页（位于 Dataproc→Workbench 页面。

  2. 点击 Open JupyterLab（打开 JupyterLab） 列出管理员创建的 Dataproc Hub 实例。

    1. 如果您无权访问 Google Cloud 控制台，请输入 Dataproc Hub 实例网址 。

  3. 在 Jupyterhub→Dataproc 选项页面上，选择 集群配置和可用区启用后，请指定任意自定义项，然后点击创建。

    Dataproc 集群创建后，系统会将您重定向 连接到集群上运行的 JupyterLab 接口。

创建笔记本并运行 Spark 作业

  1. 在 JupyterLab 界面的左侧面板中，点击 GCS (Cloud Storage)。

  2. 通过 JupyterLab 启动器创建 PySpark 笔记本。

  3. PySpark 内核会初始化 SparkContext（使用 sc 变量）。您可以从笔记本中检查 SparkContext 并运行 Spark 作业。

    rdd = (sc.parallelize(['lorem', 'ipsum', 'dolor', 'sit', 'amet', 'lorem'])
       .map(lambda word: (word, 1))
       .reduceByKey(lambda a, b: a + b))
print(rdd.collect())

  4. 为笔记本命名并保存。在删除 Dataproc 集群后，笔记本将保存并保留在 Cloud Storage 中。

关停 Dataproc 集群

  1. 在 JupyterLab 界面中，依次选择文件→中心控制台以打开 Jupyterhub 页面。

  2. 点击停止我的集群，以关闭（删除）JupyterLab 服务器， 删除 Dataproc 集群。

后续步骤