我的KTR是:
MongoDB Json Input提供的JSON如下:
{“ _id”:{“ $ oid”:“ 525cf3a70fafa305d949ede0”},“ asset”:“ RO2500AS1”,“ Salt Rejection”:“ 82%”,“ Salt Passage”:“ 18%”,“ Recovery”:“ 56.33 %”,“浓度系数”:“ 2.3”,“状态”:“严重”,“流量警报”:“高流量”}
一个Table输入返回2行:
在StreamLookUp步骤中,将要查找的关键字配置为asset = AssetName
我的最终输出返回2个json:
{“ data”:[{“ Estimated Cost”:“ USD 15”,“ AssetName”:“ RO2500AS1”,“ Description”:“ Pump Maintenance”,“ Index”:1,“ json”:“ {\” _ id \ “:{\” $ oid \“:\” 525cf3a70fafa305d949ede0 \“},\”资产\“:\” RO2500AS1 \“,\”排盐率“:\” 82%\“,\”盐度通道\“: \“ 18%\”,\“恢复率”:\“ 56.33%\”,\“浓度因子”:\“ 2.3 \”,\“状态\”:\“严重\”,\“流量报警\” “:\”高流量\“}”,“类型”:“服务”,“截止期限”:“ 2013年11月13日”}]}
{“ data”:[{“ Estimated Cost”:“ USD 35”,“ AssetName”:“ RO2500AS1”,“ Description”:“ Heat Sensor”,“ Index”:2,“ json”:“ {\” _ id \ “:{\” $ oid \“:\” 525cf3a70fafa305d949ede0 \“},\”资产\“:\” RO2500AS1 \“,\”除盐\“:\” 82%\“,\”盐通道“:: \“ 18%\”,\“恢复率”:\“ 56.33%\”,\“浓度因子”:\“ 2.3 \”,\“状态\”:\“严重\”,\“流量报警\” “:\”高流量\“}”,“类型”:“替换”,“截止期限”:“ 2013年11月26日”}]}
我希望最终的JSON输出合并显示结果,例如:
{“数据”:[{“估计的费用”:“ USD 15”,“资产名称”:“ RO2500AS1”,“描述”:“泵维护”,“索引”:1,“类型”:“服务”,“ DeadLine “:” 2013年11月13日“},{”估计成本“:” 35美元“,”资产名称“:” RO2500AS1“,”描述“:”热传感器“,”索引“:2,”类型“:”替换“ ,“ DeadLine”:“ 2013年11月26日”}],
“ json”:{“ _id”:“ 525cf3a70fafa305d949ede0”},“ asset”:“ RO2500AS1”,“ Salt Rejection”:“ 82%”,“ Salt Passage”:“ 18%”,“ Recovery”:“ 56.33%” ,“浓度系数”:“ 2.3”,“状态”:“严重”,“流量警报”:“高流量”}
这意味着合并2行。
有人可以帮忙吗
您可以在Tableinput之后使用MergeJoin。这将合并Mysql输出行中的行,并且您将只有一个JSON作为输出...
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句