的方法如下:
import json
# 获取输入流中的JSON数据
flowFile = session.get()
if flowFile is not None:
# 读取JSON数据
json_data = flowFile.read().decode('utf-8')
# 将JSON数据解析为Python对象
data = json.loads(json_data)
# 将Python对象写入文件
with open('/path/to/output.json', 'w') as f:
json.dump(data, f)
# 将处理后的数据传递给下一个节点
session.transfer(flowFile, REL_SUCCESS)
/path/to/output.json
是你想要将JSON数据写入的文件路径。你可以根据实际情况修改该路径。这样,当有JSON数据流经ExecuteScript节点时,它将被解析为Python对象,并写入指定的文件中。
注意:在使用ExecuteScript节点之前,你需要确保已经安装了Python环境,并且NiFi配置中已经正确设置了Python的路径。
领取专属 10元无门槛券
手把手带您无忧上云