有没有办法在 NIFI 中将 JSON 转换为 Protobuf？

Question

我正在尝试实现一个 MQTT 数据流，该数据流需要使​​用火花塞规范发送最终交付。

但是，我无法找到将流文件的内容转换为 protobuf 格式的方法

有没有办法进行这种转换？

Answer 1

你有两个选择：

• 使用ExecuteScript processor（例如使用您喜欢的语言groovy）并实现与that等效的东西的“肮脏方式”

• 最简洁的方式是实现您自己的自定义处理器，您可以从使用这个https://github.com/whiver/nifi-protobuf-processor 开始，看看是否符合您的需要。