2016-07-14 10 views
0

Apache NiFiを使用してWebサービスのデータフローを作成しようとしています。しかし、リクエストとレスポンスのHTTPプロセッサをセットアップしましたが、リクエスト・プロセッサからのフロー・ファイルを別の接続と言うデータで更新する方法がわかりません。誰かが私にこの行動を達成する方法を教えてもらえますか?Apache NiFi - データWebサービス

答えて

4

入ってくるフローファイルを受け取り、内容を結果に置き換えるプロセッサが必要です。 1つの例は、着信するフローファイルの内容をデータベースに照会した結果(Avro形式)で置き換えるExecuteSQLプロセッサです。つまり、HandleHttpRequest - > ExecuteSQL - > HandleHttpResponseの流れです。

1つの問題は、どこかからデータを取得する多くのプロセッサが、着信フローファイルを受け取ることを目的としていないことです。たとえば、GetSolr、GetHBase、その他多くのGetプロセッサのようなプロセッサは、独自のソースプロセッサを意図しています。

+0

こんにちはブライアン。はい、いくつかのプロセッサが着信接続を取ることを意図していないという事実は私の問題です。私は、HandleHttpRequestとHandleHttpResponseプロセッサの間に座るカスタムプロセッサを構築する必要があります。このカスタムプロセッサは、2番目の着信接続を受け入れることができ、そのフローファイルは、最初の接続でフローファイルの内容を置き換えるために使用されます。接続の「ルックアップ」プロセッサのソート。私はこれを試み、githubで利用できるようにします。 – Houston