1

SpringXD を使用して、いくつかの JSON メトリック データを Oracle データベースにストリーミングしようとしています。

ここからこの例を使用しています: SpringXD の例

HTTP 呼び出しが行われている:地震の JsonExample

私のシェルコマンド。

 stream create earthData --definition "trigger|usgs| jdbc --columns='mag,place,time,updated,tz,url,felt,cdi,mni,alert,tsunami,status,sig,net,code,ids,souces,types,nst,dmin,rms,gap,magnitude_type' --driverClassName=driver --username=username --password --url=url --tableName=Test_Table" --deploy

この JSON 応答のプロパティ部分だけを特定のテーブル列にキャプチャしたいと思います。ハッシュでエラーが発生しないところまで到達しましたが、代わりに一連のヌルを列にデポジットするだけです。

私の問題は、JSON 自体の解析だと思います。実際にはプロパティは Features 配列にあるためです。SpringXD はすぐにこれを識別できますか、それともカスタム プロセッサを作成する必要がありますか?

cmd が成功した後のデータベースの外観を次に示します。

データベースに入れられるもの

何かアドバイス？この方法で JSON を解析するのは初めてで、SpringXD 自体でより多くのドキュメントや例を見つける方法がよくわかりません。

ドキュメントへの参照は次のとおりです: SpringXD Doc

4

1 に答える 1

2

JDBC シンクのトランスフォーマーは、キー/値のマップに変換できる単純なドキュメントを想定しています。usgsおそらくプロセッサまたは別のプロセッサに、トランスフォーマーをアップストリームに追加する必要があります。#jsonPath式を使用してプロパティ キーを抽出し、それをペイロードにすることができます。

于 2014-10-30T20:48:20.277 に答える