如何将多个FlowFile合并为一个？队列末尾需输出单个FlowFile

在Apache NiFi中，合并多个FlowFile最常用的组件是MergeContent处理器，具体配置和操作步骤如下：

• 选择合适的合并策略
  根据你的业务需求选择对应策略：

  • 按固定数量合并：选Bin Count策略，设置合并后单个FlowFile包含的源文件数量范围
  • 按总大小合并：选Bin Size策略，设置合并后文件的大小阈值
  • 按时间窗口合并：选Bin Duration策略，设置收集FlowFile的时间周期

• 配置核心参数

  • Minimum Number of Entries：触发合并操作的最少FlowFile数量
  • Maximum Number of Entries：单个合并后FlowFile允许包含的最多源文件数量
  • Correlation Attribute Name（可选）：如果需要按特定属性分组合并（比如同类型数据），填写对应的属性名，确保同属性的FlowFile被归为一组合并
  • Delimiter Strategy：根据数据格式需求选择分隔符，比如选Text添加换行符，Custom Text自定义分隔符，无需分隔符则选None

• 调整连接关系
  将上游输出的FlowFile（包括你现有队列中的文件）路由到MergeContent处理器，再把MergeContent的success关系连接到你需要输出结果的目标队列。如果现有队列已有文件，可直接将队列连接到MergeContent进行处理。

• 验证合并结果
  启动MergeContent处理器后，查看目标队列的FlowFile，右键选择View Content确认内容是否为多个源文件的合并结果，格式是否符合预期。

内容的提问来源于stack exchange，提问作者zolwik