2

私のKTRは： ここに画像の説明を入力

MongoDB Json 入力は、次のように JSON を提供します。

{ "_id" : { "$oid" : "525cf3a7​​0fafa305d949ede0"} , "asset" : "RO2500AS1" , "Salt Rejection" : "82%" , "Salt Passage" : "18%" , "Recovery" : "56.33 %" , "Concentration Factor" : "2.3" , "status" : "critical" , "Flow Alarm" : "High Flow"}

そして、2 行を返す 1 つのテーブル入力:

ここに画像の説明を入力

StreamLookUp ステップでは、ルックアップするキーは、asset = AssetName として構成されます。

私の最終的な出力は2つのjsonを返しています:

{"data":[{"推定コスト":"15 米ドル","AssetName":"RO2500AS1","説明":"ポンプのメンテナンス","インデックス":1,"json":"{ \"_id\ " : { \"$oid\" : \"525cf3a7​​0fafa305d949ede0\"} , \"asset\" : \"RO2500AS1\" , \"ソルト リジェクション\" : \"82%\" , \"ソルト パッセージ\" : \"18%\" , \"回復\" : \"56.33%\" , \"集中係数\" : \"2.3\" , \"ステータス\" : \"クリティカル\" , \"フローアラーム\ " : \"High Flow\"}","Type":"Service","DeadLine":"2013 年 11 月 13 日"}]}

{"data":[{"推定費用":"35 米ドル","AssetName":"RO2500AS1","説明":"熱センサー","インデックス":2,"json":"{ \"_id\ " : { \"$oid\" : \"525cf3a7​​0fafa305d949ede0\"} , \"asset\" : \"RO2500AS1\" , \"ソルト リジェクション\" : \"82%\" , \"ソルト パッセージ\" : \"18%\" , \"回復\" : \"56.33%\" , \"集中係数\" : \"2.3\" , \"ステータス\" : \"クリティカル\" , \"フローアラーム\ " : \"High Flow\"}","Type":"Replacement","DeadLine":"2013 年 11 月 26 日"}]}

最終的な JSON 出力をマージして、show result を次のようにします。

{"data": [{"推定コスト":"USD 15", "AssetName":"RO2500AS1", "Description":"Pump Maintenance", "Index":1, "Type":"Service", "DeadLine" ":"2013 年 11 月 13 日"}, {"推定コスト":"35 米ドル", "AssetName":"RO2500AS1", "説明":"熱センサー", "インデックス":2, "種類":"交換" , "締切日":"2013 年 11 月 26 日"}],

"json":{ "_id" : "525cf3a7​​0fafa305d949ede0"} , "asset" : "RO2500AS1" , "Salt Rejection" : "82%" , "Salt Passage" : "18%" , "Recovery" : "56.33%" 、「濃度係数」：「2.3」、「ステータス」：「クリティカル」、「フローアラーム」：「高流量」}

これは、2 つの行をマージすることを意味します。

誰でも助けてください

4

2 に答える 2

3

Tableinput の後に MergeJoin を使用できます。これにより、Mysql 出力行の行がマージされ、出力として JSON が 1 つだけになります...

于 2013-10-15T17:12:34.370 に答える