跳到主要内容

数据聚合器(Aggregator)

预计学习时间:4分钟

数据聚合器是一种模块,其主要功能是将多个数据包整合成一个单一数据包。

数据聚合器操作的流程如下:

  1. 收集其在单个源模块操作期间接收到的所有数据包。
  2. 输出一个数据包,其中包含一个数组,数组中的每个元素对应一个累积的数据包。数组中各元素的具体内容取决于聚合器模块的具体设置和类型。

典型的聚合器模块实例是数组聚合器。聚合器通常包括以下配置字段:

源模块| 数据聚合的起点模块。源模块通常是一个迭代器或搜索模块,负责输出一系列数据包。设定源模块后(并结束聚合器的配置),源模块与聚合器之间的连接路径会以灰色区域显示,以标示数据聚合的开始与结束。

---|---
分组依据| 聚合器输出的数据可以通过_分组依据_字段进行分组。_分组依据_字段中可以填写一个公式,该公式对每个输入数据包进行评估。聚合器根据公式的不同结果输出对应的数据包。每个数据包包括两项内容:

  • 关键值包含公式的独特结果。
  • 数组包含对应该关键值评估出的数据包所聚合的数据。

空聚合后停止处理| 默认情况下,即使没有任何数据包到达聚合器(如被中途筛选掉),聚合器仍会输出聚合结果。若启动_空聚合后停止处理_选项,聚合器在此种情况下将不输出任何数据包,并终止数据流。

来自源模块及源模块和聚合器模块之间的任何其他模块的数据包,不会由聚合器输出,因此在聚合器之后的模块中无法访问这些数据包中的条目。 如果您需要访问这些数据包中的条目,请在配置聚合器时包括这些条目,例如在数组聚合器的_聚合字段_设置中包含它们。

示例

实例应用:将所有电子邮件附件压缩后上传至Dropbox

以下场景说明如何操作:

  1. 监控邮箱以收取电子邮件:电子邮件 > 监控邮件触发器将输出一个数据包,其中包含一个数组,该数组内包括所有电子邮件附件。
  2. 遍历电子邮件附件:电子邮件 > 遍历附件迭代器逐一处理附件数组中的每一项,并将其作为独立的数据包进一步传输。
  3. 聚合由电子邮件 > 遍历附件模块输出的数据包:归档 > 创建归档聚合器收集所有接收到的数据包,并输出一个包含ZIP文件的单一数据包。
  4. 上传最终的ZIP文件至Dropbox:Dropbox > 上传文件,从归档 > 创建归档模块取得ZIP文件并上传至Dropbox。

文档图片

以下是归档 > 创建归档聚合器的配置示例:

文档图片