【问题标题】:How to output original json along with transformed json in JoltTransformation如何在 Jolt Transformation 中输出原始 json 以及转换后的 json
【发布时间】:2019-01-08 20:55:37
【问题描述】:
我想使用相同的密钥将转换后的 json 和原始 json 保存到 Hbase。我正在使用 JoltTransformation + EvaluateJsonPath 来转换并从转换后的 json 中找到一个元素。我想使用这个元素来保存转换后的和原始的 json。
如果我可以得到原始 json 和转换后的 json,那么我可以使用相同的密钥保存它们。
谢谢,
阿尼
【问题讨论】:
标签:
json
apache-nifi
jolt
【解决方案1】:
JoltTransformJson 处理器只有成功和失败的关系,成功将是转换后内容的流文件。因此,获取原始内容的唯一方法是从 JoltTransformJson 之前路由流文件,使其进入 HBase 处理器和 JoltTransformJson 处理器。
您也可以先将原始 json 插入 hbase,然后继续进行转换,如下所示:
源 -> PutHBaseJson -> JoltTransformJson -> PutHBaseJson
第一个是插入原始 json,第二个是插入转换后的 json。只要您使用相同的行 ID,它们就会属于同一行。