json - 如何从 Nifi 中的 groovy 将 json 对象作为参数传递给 java 方法（作为 jar i ExecuteScript 提供）？

Question

我在流文件中得到一个 json 对象，我需要将它传递给一个以 json 对象作为参数的 java 方法。我通过在 ExecuteScript 处理器的模块目录属性中提供 java 方法 jar 来通过 groovy 脚本进行此调用。如果有人用 groovy 脚本帮助我，那就太好了。我通过执行脚本处理器浏览了食谱，它解释了几乎所有内容，如果您能提供帮助，请提前致谢

标签： jsongroovyapache-nifi

Answer 1

读取流内容的最简单的 groovy 将如下所示：

def ff = session.get()
if(!ff) return

def text = session.read(ff).withStream{ it.getText("UTF-8") }
//do here something with text...
session.transfer(ff, REL_SUCCESS)