NiFi fetchFileプロセッサでダイナミックアトリビュートが使用できない

Question

一部のNiFiプロセッサでダイナミックアトリビュートが使用できない理由は何ですか？私は自分のワークフローの1つでFetchFileプロセッサを使用しており、最後のステップでそれを使用できるようにするためには、フロー全体を通していくつかのデータを渡す必要があります。しかし、FetchFileは、動的属性を許可しないことによって、FetchFileを破棄します。私はそれを行う別の方法があるのだろうか？ NiFiは特定のプロセッサで動的属性を許可しないのはなぜですか？

私の流れがExecuteScript

のようなものである - 私はマークできるように、いくつかのメタデータを送信したい>マーク・ワークフローを完全

- ファイル - > FetchFile-> SendtoS3を書く>カスタムプロセッサ - > EvaluateJSonワークフローは完了しました。私はそのデータを属性として渡していますが、FetchFileで破損しています。

Answer 1

プロセッサのユーザー定義プロパティとフローファイル属性の2つの概念があります。

ユーザー定義のプロパティを使用すると、プロセッサは、事前に定義できなかった内容の入力をユーザーから受け取ります。たとえば、JSONパスがユーザー定義のプロパティで指定されている場合はEvaluateJsonPath、すべてのユーザー定義のプロパティがQueryパラメータとしてSolrに渡された場合はPutSolrContentStreamにあります。

FlowFile属性は、各データとともに渡されるキーと値のペアのマップです。これらの属性は、通常、プロセッサがフローファイルを生成または変更したとき、またはUpdateAttributeなどのプロセッサを使用して操作できるときに作成されます。

各プロセッサは、ユーザー定義のプロパティとその使用方法を決定する必要があります。 UpdateAttributeは、ユーザー定義のプロパティが新しいキー/値のペアとして各フローファイルに追加されるプロセッサですが、すべてのプロセッサがそれを行うのは意味がありません。