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")

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