Nifi 合并 Json 个文件然后变成 Json 个数组

Nifi Merge Json Files Then Turn into JsonArray

当我想将合并在一起(使用 MergeContent)的 JsonMessages 转换为 JsonArray 时,是否有我没有考虑的处理器/流程?我想尝试从多个文件构建 JsonArrays,然后将 QueryRecord 传递给 运行 SQL。很有可能我错过了一个开箱即用/明显的方法来做到这一点。任何帮助将不胜感激。

我可以使用 groovy 执行脚本,但我想尽可能避免自定义代码。谢谢!

消息输入 -> MergeContent -> ConvertToJsonArray -> QueryRecord。

您可以使用 MergeContent 并将分隔符策略设置为 "Text",然后分别为页眉、分界符和页脚输入 [ , ]。

这将在流文件的开头插入页眉,在每个流文件之间插入分界符,并在末尾插入页脚。

或者,由于看起来您正在使用记录的东西,如果您使用 JsonTreeReader 和 JsonRecordSetWriter,最新版本应该有一个 MergeRecord 处理器来为您处理这个问题。