Apache NiFi中SplitJson拆分后如何合并FlowFiles还原数组

你可以直接用NiFi的MergeContent处理器完成合并，核心是利用SplitJson自动生成的分片属性来重组原始数组，具体配置步骤如下：

• 配置MergeContent核心参数：

  • Merge Strategy: 设置为 Defragment，这个策略会基于FlowFile的分片属性自动识别并重组同一原始数组的所有分片。
  • Attribute to Use for Fragment Identifier: 填入 fragment.identifier —— 这是SplitJson给同一份原始数组拆分出的所有FlowFile打上的唯一标识，用来区分不同的原始数组分片组。
  • Delimiter Strategy: 选择 Text，设置Delimiter为 ,，同时配置Header为 [、Footer为 ]。这样合并后的内容会自动包裹成标准JSON数组格式，元素间用逗号分隔。
  • Minimum Number of Entries: 设为1即可，Defragment策略会自动等待同一fragment.identifier下的所有分片（数量等于fragment.count）全部到达后才执行合并，无需额外设置最大条目数。

• 关键注意事项：

  • 处理流程中不要删除或修改SplitJson生成的fragment.index、fragment.count、fragment.identifier这三个属性，MergeContent完全依赖它们完成正确排序和合并。
  • 只要每个拆分后的FlowFile仍为单个合法JSON元素，哪怕内容经过修改（比如字段更新），上述配置都能正常合并出目标数组。

如果你的数据基于记录格式，也可以考虑用MergeRecord处理器，但MergeContent在这种JSON数组拆分合并的场景下更直接高效。

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