Nifi Merge Json Files然后变成JsonArray

sca*_*cci 2 apache-nifi

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

我可以使用groovy执行脚本,但如果可能的话,我想避免使用自定义代码.谢谢!

消息在 - > MergeContent - > ConvertToJsonArray - > QueryRecord.

Bry*_*nde 6

您可以使用MergeContent并将Delimiter策略设置为"Text",然后分别为header,demarcator和footer输入[,].

这将在流文件的开头插入标题,每个流文件之间的分界符和结尾的页脚.

或者,因为看起来你正在使用记录内容,所以最新版本应该有一个MergeRecord处理器,如果您使用了JsonTreeReader和JsonRecordSetWriter,它将为您处理.