2016-08-12 16 views
1

Apache NiFiクーザープロセッサを開発する際に、現在のフローファイルに属性を追加する方法を教えてください。
私がしたいのは、計算された値を持つ現在のフローファイルに新しい属性を追加する(または少なくとも現在の属性を更新する)ことです。
既に使用できるプロセッサがありますか?NiFiのコンテンツに基づいて属性を更新します

答えて

4

NiFiでは、使用するデータソースに応じて、属性を作成および更新するいくつかの方法がサポートされています。

UpdateAttribute - 静的値とNiFiの式言語の両方を使用してフローファイルの属性を更新します。

enter image description here

あなたは一つのプロセッサと同様に多くのプロパティを追加することができます。 Apache NiFi Expression Language Guideでスキャンして、自分ができることを感じることをおすすめします。

ExtractText - フローファイルコンテンツに正規表現を適用することによって、属性値を設定します。

ExecuteScript - ExecuteScript必要に応じて属性を更新するために使用できるカスタムスクリプトコードを実行します。

例えば、特定のコンテンツ・フォーマットのためのより多くがあります。

+0

用の一部を追加する方法はあります値としての属性へのフローファイルの内容? –

+0

はい!私は、フローファイルのコンテンツから属性を取得する方法を含めるように答えを広げました。 – James

関連する問題