Cloud Pub/Sub 触发器

借助 Cloud Pub/Sub 触发器，您可以根据 Pub/Sub 中间件中的事件运行集成。

使用此触发器时，只要发布者将消息写入您选择的主题，您就可以执行集成。此触发器执行时，它也会将已发布的消息写入 CloudPubSubMessage 输出变量。根据您的要求，您可以在下游触发器或任务中使用此变量。

准备工作

在配置 Cloud Pub/Sub 触发器之前，请确保在您的 Google Cloud 项目中执行以下任务。

  • 将以下 IAM 角色分配给您的默认服务账号 (service-PROJECT_NUMBER@gcp-sa-apigee.iam.gserviceaccount.com)：
  • 确认您具有 Pub/Sub 主题。如需创建新的 Pub/Sub 主题，请执行以下操作：
    1. 转到 Cloud 控制台中的 Pub/Sub 主题页面。

      转到 Pub/Sub 主题页面

    2. 点击创建主题。
    3. 在主题 ID 字段中，提供唯一的主题名称。
    4. 点击保存。

如需详细了解如何使用 IAM 角色管理访问权限，请参阅访问权限控制。

如需了解如何向主账号授予角色，请参阅授予、更改和撤消访问权限。

添加 Cloud Pub/Sub 触发器

要将 Cloud Pub/Sub 触发器添加到新的或现有的集成中，请按以下步骤操作：
  1. 在 Apigee 界面中，选择您的 Apigee 组织。
  2. 点击开发 > 集成。
  3. 选择现有集成，或通过点击创建集成来创建新集成。

    要创建新的集成，请执行以下操作：

    1. 在创建 Integrations对话框中输入名称和说明。
    2. 从支持的区域列表中选择集成的区域。
    3. 点击创建。

    这将在集成设计器中打开集成。

  4. 在集成设计器导航栏中，点击 + 添加任务/触发器 > 触发器以查看可用触发器列表。
  5. 点击 Cloud Pub/Sub 触发器元素，并将其放置在设计器中。

配置 Cloud Pub/Sub 触发器

点击集成编辑器中的 Cloud Pub/Sub 触发器元素以查看触发器配置窗格，然后执行以下任务：

按照以下格式在 Pub/Sub 主题字段中指定触发器应监听的主题：

projects/PROJECT_ID/topics/TOPIC_ID

如需查看 Google Cloud 项目中所有可用的主题，请查看主题中的主题名称列。

其中：
  • PROJECT_ID 是在其中创建主题的 Google Cloud 项目。
  • TOPIC_ID 是您的 Pub/Sub 主题的 ID。

触发器输出

对于每个事件，Cloud Pub/Sub 触发器会生成一个 CloudPubSubMessage 输出变量，您可以在下游任务中使用该变量。该变量采用 JSON 格式，并且具有 PubsubMessage 结构。

注意事项

  • Pub/Sub 消息的大小上限为 10 MB。如需了解 Pub/Sub 的所有限制，请参阅 Pub/Sub 配额和限制。
  • Pub/Sub 可能会将同一消息多次写入一个主题。要了解 Pub/Sub 的此行为，请参阅至少传送一次。因此，您必须将集成设计为具有幂等性，以免允许将消息多次写入一个主题。