请参阅 Application Integration 支持的连接器。

“针对每一项并行”任务

借助针对每一项并行任务，您可以从主集成中运行其他集成（子集成）。根据任务名称的建议，子集成并行运行。

此任务使用 API 触发器 ID 作为手柄来识别要运行的集成。例如，如果您将 API 触发器 ID 指定为 api_trigger/APITriggerX，则任务会运行具有 api_trigger/APITriggerX 触发器 ID 的所有子集成。

运行子集成后，您还可以读取主集成中的子集成响应。使用此任务将子集成作为主集成的依赖项运行。

准备工作

配置“针对每个并行”任务

如需配置针对每一项并行任务，请执行以下操作：

  1. 在 Google Cloud 控制台中，前往 Application Integration 页面。

    转到 Application Integration

  2. 在导航菜单中，点击集成。

    系统会显示集成页面，其中列出了 Google Cloud 项目中可用的所有集成。

  3. 选择现有集成，或点击创建集成以创建新的集成。

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

    1. 在创建集成窗格中输入名称和说明。
    2. 选择集成的区域。
    3. 选择用于集成的服务账号。您可以随时在集成工具栏的 集成摘要窗格中更改或更新集成的服务账号详细信息。
    4. 点击创建。

    系统随即会在集成编辑器中打开该集成。

  4. 在集成编辑器导航栏中，点击任务查看可用任务和连接器的列表。
  5. 点击针对每一项并行任务元素，并将其放入集成编辑器中。
  6. 点击设计器上的针对每一项并行任务元素以打开针对每一项并行任务配置窗格。
  7. 使用任务的配置属性配置显示的字段，详见下表。

    系统会自动保存对属性的所有更改。

配置属性

本部分介绍了针对每一项并行任务的配置属性。

输入属性

属性名称 参数名称 数据类型 说明
数组选择 List to iterate 类型为 String、Integer、Double 或 JSON 的数组。 子集成必须运行的值列表。将为列表中的每个值运行一个单独的子集成线程，并且所有线程均并行运行。

您可以通过设置映射单个数组元素的位置字段，将迭代值传递给子集成。

您还可以从映射到其他子集成输入字段中将主集成中的其他值传递到子集成。
子集成详细信息 API Trigger ID 字符串 要运行的已发布子集成的触发器 ID。

此值可在子集成中的 API 触发器的触发器 ID 字段中找到。

Execution strategy 无

SYNC：在同步模式下运行子集成。在此模式下，主集成会等待子集成完成，然后再继续执行下游任务。

ASYNC：以异步模式运行子集成。在此模式下，主集成不会等待子集成完成。在调用子集成后，主集成会立即运行下游任务。
Run all integrations with this API Trigger ID 不适用 运行具有相同 API 触发器 ID 的所有集成。

例如，如果集成 A 和集成 B 具有相同的 API 触发器 ID，则会针对 List to iterate 中的每个项运行集成 A 和 B。

注意：如果您选择此选项，则主集成中不提供子集成的响应。如果要使用子集成的响应，请选择运行单个集成选项。
Run a single integration 不适用 仅运行集成名称字段中指定的集成。您可以通过配置 Collect values from subintegration output(s)（从子集成输出收集值）部分来使用子集成的响应。
每次执行时 Where to map individual array elements 字符串 应映射数组元素的子集成输入变量的名称。数组元素可以直接映射到子集成输入变量。如果选择了单个子集成，则可以从下拉列表中选择子集成输入变量。
Map to additional sub-integration input(s) 字符串 其他子集成映射选项。
  • 要从中映射的集成变量：要传递给子集成的输入变量的当前集成中变量的名称。
  • 要映射到的子集成输入：要映射到的子集成输入变量的名称。

此字段采用键值对形式的值，其中键是主集成中的一个变量，值是子集成中的相应输入变量。

例如，假设您的主集成具有 productID 变量，并要将此变量映射到 subIntProductID 子集成变量；您必须从 Integration variable to map from（要从中映射的集成变量）字段中选择 productID，然后在 Subintegration input to map to（要映射到的子集成输入）字段中输入 subIntProductID。
Collect values from sub-integration output(s) 字符串 如果执行策略是同步 (SYNC) 并且选择了单个子集成 (Run a single integration)，则可以将子集成的输出收集到当前集成的数组变量中。
  • 要从中收集的子集成输出：要聚合的子集成输出变量的名称。
  • 要收集到的集成变量：用于收集集成的输出的当前集成中变量的名称。
执行设置 Integrations to execute at a time (parallel) 整数 子集成的允许的最大并行执行数量。默认值为 50（最大值为 10000）。

同一批次中的所有子集成会在下一批次的子集成运行之前完全运行。
Ignore failures 布尔值

您可以指定以下任一值：

  • True：任务会忽略子集成失败，并运行所有执行。
  • False：任务因子集成失败而失败，并结束所有执行。

最佳做法

使用针对每一项并行任务时，我们建议遵循以下最佳做法：

  • 根据子集成的配额限制来设置批次大小。
  • 如果要收集子集成的输出以供后续使用，请使用 SYNC 执行策略。
  • 如果子集成运行时间可能超过 2 分钟，请使用 ASYNC 执行策略。

如需了解适用于针对每一项并行任务的用量限额，请参阅用量限额。

注意事项

一般来说，如果子集成的运行时间超过 2 分钟，或者您打算将此任务与自然异步任务（例如“审批”任务）搭配使用，请勿使用 SYNC 执行策略。

错误处理策略

任务的错误处理策略指定当任务因暂时性错误而失败时要执行的操作。如需了解如何使用错误处理策略，以及了解不同类型的错误处理策略，请参阅错误处理策略。

配额和限制

如需了解配额和限制，请参阅配额和限制。

后续步骤