Apache-NiFi从python脚本调用jar文件

Question

我有一个ExecuteScript处理器，它调用Python脚本来转换数据流。这可以很好地工作，但我需要调用一个jar文件并获得一段数据的结果。我找到了以下代码，但这不起作用，因为我不能在Jython中导入子进程。有没有其他可以调用的库，或者可以使用的替代代码？试图找到Jython for NiFi脚本指南似乎是徒劳的查询。

...command = "java -jar <filename.jar> <args>" result = suprocess.Popen(command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE).communicate()

谢谢

Answer 1

这确实起作用了，当我试图读取结果时，我的错误还在下面。NiFi错误并不总是很容易破解，很少落在错误实际存在的代码行上。

在读取结果时，如果您希望转换为字符串，请使用以下代码。

...value = result[0].decode("utf-8")

当然，根据需要替换适当的索引。