执行 Cloud Run 作业，处理保存在 Cloud Storage 中的事件数据

您可以使用 Workflows 来执行 Cloud Run 作业，作为工作流的一部分，以执行更复杂的数据处理或编排现有作业的系统。

本教程演示了如何使用 Workflows 执行 Cloud Run 作业，该作业用于处理存储在 Cloud Storage 存储桶中的事件数据。将事件载荷存储在 Cloud Storage 存储桶中，可让您使用客户管理的加密密钥来加密数据，而如果您将事件数据作为环境变量传递给 Cloud Run 作业，则无法实现这一点。

下图提供了简要概览：

目标

在此教程中，您将学习以下操作：

1. 创建 Cloud Run 作业，以处理存储在 Cloud Storage 存储桶中的事件数据。
2. 部署执行以下操作的工作流：
   1. 接收事件作为实参。
   2. 将事件载荷数据写入 Cloud Storage 存储桶。
   3. 使用 Cloud Run Admin API 连接器执行 Cloud Run 作业。
3. 创建一个 Pub/Sub 主题，以便您可以向其发布消息。 本教程以 Pub/Sub 事件为例，说明如何使用 Workflows 路由事件，并将事件保存到 Cloud Storage，以便 Cloud Run 作业可以处理事件数据。
4. 创建一个 Eventarc 触发器，用于在消息写入 Pub/Sub 主题时执行工作流。
5. 通过向 Pub/Sub 主题写入消息来触发工作流。

费用

在本文档中，您将使用 Google Cloud的以下收费组件：

• Artifact Registry
• Cloud Build
• Cloud Run
• Cloud Storage
• Eventarc
• Workflows

如需根据您的预计使用情况来估算费用，请使用价格计算器。

新 Google Cloud 用户可能有资格申请免费试用。

准备工作

您的组织定义的安全限制条件可能会导致您无法完成以下步骤。如需了解相关问题排查信息，请参阅在受限的 Google Cloud 环境中开发应用。

在开始本教程之前，您必须启用特定 API 并创建用户代管式服务账号。您必须为服务账号授予必要的角色和权限，以便您可以使用 Eventarc 触发器路由事件并执行工作流。

请注意，如果您使用 Cloud Shell 试用本教程，可能需要向 Compute Engine 默认服务账号授予其他角色。如需了解详情，请参阅本文档中的创建 Cloud Run 作业部分。

控制台

登录您的 Google Cloud 账号。如果您是 Google Cloud新手，请 创建一个账号来评估我们的产品在实际场景中的表现。新客户还可获享 $300 赠金，用于运行、测试和部署工作负载。

In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

Roles required to select or create a project

• Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
• Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

Note: If you don't plan to keep the resources that you create in this procedure, create a project instead of selecting an existing project. After you finish these steps, you can delete the project, removing all resources associated with the project.

Go to project selector

Verify that billing is enabled for your Google Cloud project.

Enable the Artifact Registry, Cloud Build, Cloud Run, Cloud Storage, Compute Engine, Eventarc, and Workflows APIs.

Roles required to enable APIs

To enable APIs, you need the Service Usage Admin IAM role (roles/serviceusage.serviceUsageAdmin), which contains the serviceusage.services.enable permission. Learn how to grant roles.

Enable the APIs

Create a service account:

1. Ensure that you have the Create Service Accounts IAM role (roles/iam.serviceAccountCreator) and the Project IAM Admin role (roles/resourcemanager.projectIamAdmin). Learn how to grant roles.

2. In the Google Cloud console, go to the Create service account page.

   Go to Create service account
3. Select your project.

4. In the Service account name field, enter a name. The Google Cloud console fills in the Service account ID field based on this name.

   In the Service account description field, enter a description. For example, Service account for quickstart.

5. Click Create and continue.

6. Grant the following roles to the service account: Cloud Run Admin, Eventarc Event Receiver, Logs Writer, Storage Object Creator, Workflows Invoker.

   To grant a role, find the Select a role list, then select the role.

   To grant additional roles, click Add another role and add each additional role.

   Note: The Role field affects which resources the service account can access in your project. You can revoke these roles or grant additional roles later.
7. Click Continue.

8. Click Done to finish creating the service account.

In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

Roles required to select or create a project

• Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
• Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

Note: If you don't plan to keep the resources that you create in this procedure, create a project instead of selecting an existing project. After you finish these steps, you can delete the project, removing all resources associated with the project.

Go to project selector

Verify that billing is enabled for your Google Cloud project.

Enable the Artifact Registry, Cloud Build, Cloud Run, Cloud Storage, Compute Engine, Eventarc, and Workflows APIs.

Roles required to enable APIs

To enable APIs, you need the Service Usage Admin IAM role (roles/serviceusage.serviceUsageAdmin), which contains the serviceusage.services.enable permission. Learn how to grant roles.

Enable the APIs

Create a service account:

1. Ensure that you have the Create Service Accounts IAM role (roles/iam.serviceAccountCreator) and the Project IAM Admin role (roles/resourcemanager.projectIamAdmin). Learn how to grant roles.

2. In the Google Cloud console, go to the Create service account page.

   Go to Create service account
3. Select your project.

4. In the Service account name field, enter a name. The Google Cloud console fills in the Service account ID field based on this name.

   In the Service account description field, enter a description. For example, Service account for quickstart.

5. Click Create and continue.

6. Grant the following roles to the service account: Cloud Run Admin, Eventarc Event Receiver, Logs Writer, Storage Object Creator, Workflows Invoker.

   To grant a role, find the Select a role list, then select the role.

   To grant additional roles, click Add another role and add each additional role.

   Note: The Role field affects which resources the service account can access in your project. You can revoke these roles or grant additional roles later.
7. Click Continue.

8. Click Done to finish creating the service account.

1. 如果您在 2021 年 4 月 8 日或之前启用了 Cloud Pub/Sub 服务代理，以支持经过身份验证的 Pub/Sub 推送请求，请向该服务代理授予 Service Account Token Creator 角色 (roles/iam.serviceAccountTokenCreator)。否则，系统会默认授予此角色：
   1. 在 Google Cloud 控制台中，前往 IAM 页面。
      

      转到 IAM

   2. 选中包括 Google 提供的角色授权复选框。
   3. 在名称列中，找到 Cloud Pub/Sub 服务账号，然后点击相应行中的 修改主账号。
   4. 点击添加角色或添加其他角色。
   5. 在选择角色列表中，过滤出 Service Account Token Creator，然后选择该角色。
   6. 点击保存。

2. 在 Google Cloud 控制台中，激活 Cloud Shell。

   激活 Cloud Shell

   Cloud Shell 会话随即会在 Google Cloud 控制台的底部启动，并显示命令行提示符。Cloud Shell 是一个已安装 Google Cloud CLI 且已为当前项目设置值的 Shell 环境。该会话可能需要几秒钟时间来完成初始化。

Cloud Shell 支持本教程中的命令行步骤。

gcloud

登录您的 Google Cloud 账号。如果您是 Google Cloud新手，请 创建一个账号来评估我们的产品在实际场景中的表现。新客户还可获享 $300 赠金，用于运行、测试和部署工作负载。
安装 Google Cloud CLI。
如果您使用的是外部身份提供方 (IdP)，则必须先使用联合身份登录 gcloud CLI。
如需初始化 gcloud CLI，请运行以下命令：
gcloud init
创建或选择 Google Cloud 项目。
选择或创建项目所需的角色
• 选择项目：选择项目不需要特定的 IAM 角色，您可以选择已获授角色的任何项目。
• 创建项目：如需创建项目，您需要拥有 Project Creator 角色 (roles/resourcemanager.projectCreator)，该角色包含 resourcemanager.projects.create 权限。了解如何授予角色。
注意：如果您不打算保留在此过程中创建的资源，请创建新的项目，而不要选择现有的项目。完成本教程介绍的步骤后，您可以删除所创建的项目，并移除与该项目关联的所有资源。
• 创建 Google Cloud 项目：

  gcloud projects create PROJECT_ID

  将 PROJECT_ID 替换为您要创建的 Google Cloud 项目的名称。

• 选择您创建的 Google Cloud 项目：

  gcloud config set project PROJECT_ID

  将 PROJECT_ID 替换为您的 Google Cloud 项目名称。
验证是否已为您的 Google Cloud 项目启用结算功能。
启用 Artifact Registry API、Cloud Build API、Cloud Run API、Cloud Storage API、Compute Engine API、Eventarc API 和 Workflows API：
启用 API 所需的角色
如需启用 API，您需要拥有 Service Usage Admin IAM 角色 (roles/serviceusage.serviceUsageAdmin)，该角色包含 serviceusage.services.enable 权限。了解如何授予角色。
gcloud services enable artifactregistry.googleapis.com cloudbuild.googleapis.com compute.googleapis.com run.googleapis.com storage.googleapis.com eventarc.googleapis.com workflows.googleapis.com
设置身份验证：
1. 确保您拥有 Create Service Accounts IAM 角色 (roles/iam.serviceAccountCreator) 和 Project IAM Admin 角色 (roles/resourcemanager.projectIamAdmin)。了解如何授予角色。

2. 创建服务账号：

   gcloud iam service-accounts create SERVICE_ACCOUNT_NAME

   将 SERVICE_ACCOUNT_NAME 替换为服务账号的名称。

3. 向服务账号授予角色。对以下每个 IAM 角色运行以下命令一次：roles/eventarc.eventReceiver, roles/logging.logWriter, roles/run.admin, roles/storage.objectCreator, roles/workflows.invoker

   gcloud projects add-iam-policy-binding PROJECT_ID --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" --role=ROLE

   请替换以下内容：

   • SERVICE_ACCOUNT_NAME：服务账号的名称
   • PROJECT_ID：您在其中创建服务账号的项目的 ID
   • ROLE：要授予的角色
   注意：--role 标志会影响服务账号可以访问项目中的哪些资源。您可以撤消这些角色或稍后授予其他角色。

安装 Google Cloud CLI。

如果您使用的是外部身份提供方 (IdP)，则必须先使用联合身份登录 gcloud CLI。

如需初始化 gcloud CLI，请运行以下命令：

gcloud init

创建或选择 Google Cloud 项目。

选择或创建项目所需的角色

• 选择项目：选择项目不需要特定的 IAM 角色，您可以选择已获授角色的任何项目。
• 创建项目：如需创建项目，您需要拥有 Project Creator 角色 (roles/resourcemanager.projectCreator)，该角色包含 resourcemanager.projects.create 权限。了解如何授予角色。

注意：如果您不打算保留在此过程中创建的资源，请创建新的项目，而不要选择现有的项目。完成本教程介绍的步骤后，您可以删除所创建的项目，并移除与该项目关联的所有资源。

• 创建 Google Cloud 项目：

  gcloud projects create PROJECT_ID

  将 PROJECT_ID 替换为您要创建的 Google Cloud 项目的名称。

• 选择您创建的 Google Cloud 项目：

  gcloud config set project PROJECT_ID

  将 PROJECT_ID 替换为您的 Google Cloud 项目名称。

验证是否已为您的 Google Cloud 项目启用结算功能。

启用 Artifact Registry API、Cloud Build API、Cloud Run API、Cloud Storage API、Compute Engine API、Eventarc API 和 Workflows API：

启用 API 所需的角色

如需启用 API，您需要拥有 Service Usage Admin IAM 角色 (roles/serviceusage.serviceUsageAdmin)，该角色包含 serviceusage.services.enable 权限。了解如何授予角色。

gcloud services enable artifactregistry.googleapis.com cloudbuild.googleapis.com compute.googleapis.com run.googleapis.com storage.googleapis.com eventarc.googleapis.com workflows.googleapis.com

设置身份验证：

1. 确保您拥有 Create Service Accounts IAM 角色 (roles/iam.serviceAccountCreator) 和 Project IAM Admin 角色 (roles/resourcemanager.projectIamAdmin)。了解如何授予角色。

2. 创建服务账号：

   gcloud iam service-accounts create SERVICE_ACCOUNT_NAME

   将 SERVICE_ACCOUNT_NAME 替换为服务账号的名称。

3. 向服务账号授予角色。对以下每个 IAM 角色运行以下命令一次：roles/eventarc.eventReceiver, roles/logging.logWriter, roles/run.admin, roles/storage.objectCreator, roles/workflows.invoker

   gcloud projects add-iam-policy-binding PROJECT_ID --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" --role=ROLE

   请替换以下内容：

   • SERVICE_ACCOUNT_NAME：服务账号的名称
   • PROJECT_ID：您在其中创建服务账号的项目的 ID
   • ROLE：要授予的角色
   注意：--role 标志会影响服务账号可以访问项目中的哪些资源。您可以撤消这些角色或稍后授予其他角色。
1. 如果您在 2021 年 4 月 8 日或之前启用了 Cloud Pub/Sub 服务代理，以支持经过身份验证的 Pub/Sub 推送请求，请向该服务代理授予 Service Account Token Creator 角色 (roles/iam.serviceAccountTokenCreator)。否则，系统会默认授予此角色：

   gcloud projects add-iam-policy-binding PROJECT_ID \
       --member=serviceAccount:[e-mail] \
       --role=roles/iam.serviceAccountTokenCreator

将 PROJECT_NUMBER 替换为您的 Google Cloud项目编号。您可以在 Google Cloud 控制台的欢迎页面上，或通过运行以下命令来查找项目编号：

gcloud projects describe PROJECT_ID --format='value(projectNumber)'

创建 Cloud Run 作业

本教程使用可在 GitHub 上找到的示例代码。部署脚本会构建一个容器映像，以创建名为 message-payload-job 的 Cloud Run 作业。

该脚本还会创建一个 Cloud Storage 存储桶，并使用 uuidgen（一种通常已安装在 Linux、macOS 和 Windows 上的实用程序）为其名称生成一个通用唯一标识符 (UUID)。

Cloud Run 作业会读取 Cloud Storage 存储桶中存储的所有事件数据，然后输出这些事件数据。

注意： 如果您收到“存储桶已存在”消息，请确保存储桶的所有权及其权限已按预期配置，然后再继续操作。

1. 如果您在 Cloud Shell 中运行部署脚本，并且 Compute Engine 默认服务账号没有 Editor 角色，请向 Compute Engine 默认服务账号授予项目中的以下角色。（否则，您可以跳过此步骤，并在下一步中继续克隆示例应用代码库。）

   注意 ：iam.automaticIamGrantsForDefaultServiceAccounts 组织政策限制条件可以防止将 Editor 角色自动授予默认服务账号。如果您的组织是在 2024 年 5 月 3 日之后创建的，则默认情况下会强制执行此限制条件。

   1. 授予 Artifact Registry Writer 角色 (roles/artifactregistry.writer)：

      gcloud projects add-iam-policy-binding PROJECT_ID \
          --member=serviceAccount:[e-mail] \
          --role=roles/artifactregistry.writer

      将 PROJECT_NUMBER 替换为您的 Google Cloud项目编号。您可以在 Google Cloud 控制台的欢迎页面上，或通过运行以下命令来查找项目编号：

      gcloud projects describe PROJECT_ID --format='value(projectNumber)'

   2. 授予 Storage Object User 角色 (roles/storage.objectUser)：

      gcloud projects add-iam-policy-binding PROJECT_ID \
          --member=serviceAccount:[e-mail] \
          --role=roles/storage.objectUser

   3. 授予 Logging Logs Writer 角色 (roles/logging.logWriter)：

      gcloud projects add-iam-policy-binding PROJECT_ID \
          --member=serviceAccount:[e-mail] \
          --role=roles/logging.logWriter

2. 通过将示例应用代码库克隆到本地机器来获取示例代码：

   git clone https://github.com/GoogleCloudPlatform/workflows-demos.git

   或者，您也可以下载该示例的 ZIP 文件。

3. 转到包含示例代码的目录：

   cd workflows-demos/cloud-run-jobs-payload-gcs/message-payload-job

4. 运行部署脚本，创建 Cloud Run 作业：

   ./deploy-job.sh

   输出应类似如下所示：

   STATUS: SUCCESS
   Creating input bucket message-payload-UNIQUE_ID
   ...
   Creating Cloud Run job [message-payload-job] in project [PROJECT_ID] region [us-central1]
   Creating job...
   Done.
   Job [message-payload-job] has successfully been created.
   

   记下为 Cloud Storage 存储桶名称生成的 UUID。部署工作流时，您将需要此标识符。

部署用于执行 Cloud Run 作业的工作流

定义并部署一个工作流，用于执行您刚刚创建的 Cloud Run 作业。工作流定义由一系列使用 Workflows 语法描述的步骤组成。

工作流接收事件，将事件数据保存到 Cloud Storage 存储桶，然后执行 Cloud Run 作业来处理事件数据。

控制台

1. 在 Google Cloud 控制台中，前往 Workflows 页面：

   进入 Workflows

2. 点击 创建。

3. 输入新工作流的名称，例如 message-payload-workflow。

4. 选择适当的区域，例如 us-central1。

5. 在服务账号字段中，选择您之前创建的服务账号。

   该服务账号充当工作流的身份。您应该已向服务账号授予以下角色：

   • Cloud Run Admin：用于执行 Cloud Run 作业
   • Logs Writer：用于写入日志条目
   • Storage Object Creator：用于在 Cloud Storage 中创建对象

6. 点击下一步。

7. 在工作流编辑器中，输入工作流的以下定义：

   main:
       params: [event]
       steps:
           - init:
               assign:
                   - project_id: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
                   - event_bucket: message-payload-UNIQUE_ID
                   - event_file: ${event.id + ".data.json"}
                   - job_name: message-payload-job
                   - job_location: us-central1
           - log_event:
               call: sys.log
               args:
                   data: ${event}
           - write_payload_to_gcs:
               call: http.post
               args:
                   url: ${"https://storage.googleapis.com/upload/storage/v1/b/" + event_bucket + "/o"}
                   auth:
                       type: OAuth2
                   query:
                       name: ${event_file}
                   body:
                       ${event.data}
           - run_job_to_process_payload:
               call: googleapis.run.v1.namespaces.jobs.run
               args:
                   name: ${"namespaces/" + project_id + "/jobs/" + job_name}
                   location: ${job_location}
                   body:
                       overrides:
                           containerOverrides:
                               env:
                                   - name: INPUT_BUCKET
                                     value: ${event_bucket}
                                   - name: INPUT_FILE
                                     value: ${event_file}
               result: job_execution
           - finish:
               return: ${job_execution}

   将 UNIQUE_ID 替换为为您的 Cloud Storage 存储桶名称生成的 UUID，该 UUID 是您之前记下的。

8. 点击部署。

gcloud

1. 为工作流创建源代码文件：

   touch message-payload-workflow.yaml

2. 将以下工作流定义复制到 message-payload-workflow.yaml：

   main:
       params: [event]
       steps:
           - init:
               assign:
                   - project_id: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
                   - event_bucket: message-payload-UNIQUE_ID
                   - event_file: ${event.id + ".data.json"}
                   - job_name: message-payload-job
                   - job_location: us-central1
           - log_event:
               call: sys.log
               args:
                   data: ${event}
           - write_payload_to_gcs:
               call: http.post
               args:
                   url: ${"https://storage.googleapis.com/upload/storage/v1/b/" + event_bucket + "/o"}
                   auth:
                       type: OAuth2
                   query:
                       name: ${event_file}
                   body:
                       ${event.data}
           - run_job_to_process_payload:
               call: googleapis.run.v1.namespaces.jobs.run
               args:
                   name: ${"namespaces/" + project_id + "/jobs/" + job_name}
                   location: ${job_location}
                   body:
                       overrides:
                           containerOverrides:
                               env:
                                   - name: INPUT_BUCKET
                                     value: ${event_bucket}
                                   - name: INPUT_FILE
                                     value: ${event_file}
               result: job_execution
           - finish:
               return: ${job_execution}

   将 UNIQUE_ID 替换为为您的 Cloud Storage 存储桶名称生成的 UUID，该 UUID 是您之前记下的。

3. 输入以下命令以部署工作流：

   gcloud workflows deploy message-payload-workflow \
       --location=us-central1 \
       --source=message-payload-workflow.yaml \
       --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com

   替换以下内容：

   • SERVICE_ACCOUNT_NAME：您之前创建的服务账号的名称
   • PROJECT_ID：您的Google Cloud 项目的 ID

   该服务账号充当工作流的身份。您应该已向服务账号授予以下角色：

   • roles/logging.logWriter：用于写入日志条目
   • roles/run.admin：用于执行 Cloud Run 作业
   • roles/storage.objectCreator：在 Cloud Storage 中创建对象

该工作流会执行以下操作：

1. init 步 - 接受一个事件作为实参，并设置必要的变量。

2. log_event 步 - 使用函数 sys.log 在 Cloud Logging 中创建日志条目。

3. write_payload_to_gcs 步 - 发出 HTTP POST 请求，并将事件载荷数据写入 Cloud Storage 存储桶文件。

4. run_job_to_process_payload 步 - 使用 Cloud Run Admin API 连接器方法 googleapis.run.v1.namespaces.jobs.run 执行作业。Cloud Storage 存储桶和数据文件名会作为替换变量从工作流传递到作业。

5. finish 步骤 - 返回有关作业执行的信息，作为工作流的结果。

创建 Pub/Sub 主题

创建一个 Pub/Sub 主题，以便您可以向其发布消息。 Pub/Sub 事件用于演示如何使用 Workflows 路由事件，以及如何将事件保存到 Cloud Storage，以便 Cloud Run 作业可以处理事件数据。

控制台

1. 在 Google Cloud 控制台中，前往主题页面。

   打开“主题”。

2. 点击 创建主题。

3. 在主题 ID 字段中，输入主题的 ID，例如 message-payload-topic。

4. 保留添加默认订阅选项。

5. 请勿选择其他选项。

6. 点击创建。

gcloud

如需创建 ID 为 message-payload-topic 的主题，请运行 gcloud pubsub topics create 命令：

gcloud pubsub topics create message-payload-topic

创建 Eventarc 触发器以将事件路由到工作流

如需自动执行工作流并进而执行 Cloud Run 作业，请创建一个可响应 Pub/Sub 事件并将事件路由到工作流的 Eventarc 触发器。每当有消息写入 Pub/Sub 主题时，该事件都会触发工作流的执行。

控制台

1. 在 Google Cloud 控制台中，前往 Workflows 页面：

   进入 Workflows

2. 点击工作流的名称，例如 message-payload-workflow。

3. 在工作流详细信息页面上，点击 修改。

4. 在修改工作流页面上的触发器部分中，点击添加新触发器 > Eventarc。

   Eventarc 触发器窗格随即会打开。

5. 在触发器名称字段中，输入触发器的名称，例如 message-payload-trigger。

6. 从事件提供方列表中，选择 Cloud Pub/Sub。

7. 从事件列表中，选择 google.cloud.pubsub.topic.v1.messagePublished。

8. 从选择 Cloud Pub/Sub 主题列表中，选择您之前创建的 Pub/Sub 主题。

9. 在服务账号字段中，选择您之前创建的服务账号。

   该服务账号充当触发器的身份。您应该已向服务账号授予以下角色：

   • Eventarc Event Receiver：用于接收事件
   • Workflows Invoker：用于执行工作流

10. 点击保存触发器。

    Eventarc 触发器现在会显示在修改工作流页面上的触发器部分中。

11. 点击下一步。

12. 点击部署。

gcloud

运行以下命令，创建 Eventarc 触发器：

gcloud eventarc triggers create message-payload-trigger \
    --location=us-central1 \
    --destination-workflow=message-payload-workflow \
    --destination-workflow-location=us-central1 \
    --event-filters="type=google.cloud.pubsub.topic.v1.messagePublished" \
    --transport-topic=projects/PROJECT_ID/topics/message-payload-topic \
    --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com

替换以下内容：

• PROJECT_ID：您的 Google Cloud 项目的 ID
• SERVICE_ACCOUNT_NAME：您之前创建的服务账号的名称。

该服务账号充当触发器的身份。您应该已向服务账号授予以下角色：

• roles/eventarc.eventReceiver：接收事件
• roles/workflows.invoker：执行工作流

触发工作流

通过向 Pub/Sub 主题发布消息并生成事件来测试端到端系统。如需了解详情，请参阅使用事件或 Pub/Sub 消息触发工作流。

1. 向 Pub/Sub 主题发布消息以生成事件：

   gcloud pubsub topics publish message-payload-topic --message="Hello World"
   

   事件会被路由到工作流，该工作流会记录事件消息、将事件数据保存到 Cloud Storage 存储桶，并执行 Cloud Run 作业来处理保存在 Cloud Storage 中的数据。此过程可能需要几分钟的时间。

2. 查看作业执行情况，确认 Cloud Run 作业是否按预期运行：

   gcloud run jobs executions list --job=message-payload-job

   您应该会在输出中看到新的作业执行。

3. 您可以通过查看 Cloud Storage 存储桶对象中的事件数据来确认结果是否符合预期。

   1. 检索您的存储桶名称：

      gcloud storage ls

      输出类似于以下内容：

      gs://message-payload-UNIQUE_ID/

   2. 列出存储桶中的对象：

      gcloud storage ls gs://message-payload-UNIQUE_ID/** --recursive

      输出应类似如下所示：

      gs://message-payload-UNIQUE_ID/OBJECT_ID.data.json

      请记下要在下一步中使用的 OBJECT_ID。

   3. 将存储桶中的对象下载为文件：

      gcloud storage cp gs://message-payload-UNIQUE_ID/OBJECT_ID.data.json message-event.txt

      将 OBJECT_ID 替换为上一步中返回的 ID。

   4. 在文本编辑器中，打开 message-event.txt 文件。写入到文件中的事件正文应类似于以下内容：

      {
        "message": {
          "data": "SGVsbG8gV29ybGQ=",
          "messageId": "8254002311197919",
          "publishTime": "2023-09-20T16:54:29.312Z"
        },
        "subscription": "projects/MY_PROJECT/subscriptions/eventarc-us-central1-message-payload-trigger-sub-741"
      }
      

      请注意，如果您从 Base64 格式对 SGVsbG8gV29ybGQ= 的数据值进行解码，则返回“Hello World”。

清理

如果您为本教程创建了一个新项目，请删除项目。 如果您使用的是现有项目，希望保留此项目且不保留本教程中添加的任何更改，请删除为教程创建的资源。

删除项目

为了避免产生费用，最简单的方法是删除您为本教程创建的项目。

要删除项目，请执行以下操作：

注意：删除项目会产生以下影响：

• 项目中的所有内容都会被删除。如果您将现有项目用于本文档中的任务，则删除该项目后，还将删除您已在该项目中完成的任何其他工作。
• 自定义项目 ID 丢失。创建此项目时，您可能创建了要在将来使用的自定义项目 ID。要保留使用该项目 ID 的网址（例如 appspot.com 网址），请删除项目内的所选资源，而不是删除整个项目。

如果您打算探索多个架构、教程或快速入门，则重复使用项目可以帮助您避免超出项目配额限制。

1. 在 Google Cloud 控制台中，前往管理资源页面。

   转到“管理资源”

2. 在项目列表中，选择要删除的项目，然后点击删除。
3. 在对话框中输入项目 ID，然后点击关闭以删除项目。

删除教程资源

删除您在本教程中创建的资源：

1. 删除 Pub/Sub 主题。

2. 删除 Eventarc 触发器。

3. 删除 Workflows 工作流。

4. 删除 Cloud Run 作业。

5. 删除 Cloud Storage 存储桶。

后续步骤

• 详细了解 Cloud Run 作业。
• 详细了解 Workflows 连接器。
• 详细了解工作流。