-
PutSQLを停止します プロセッサを使用して、フローファイルをキューに入れます。 - キューに入れたら、
successを右クリックします
UpdateAttribute間の関係 およびPutSQLList Queueを選択します 。 - 任意の1つのフローファイルを選択し、
Attributesに移動します タブをクリックして、属性absolute.pathを確認します およびflowfilename存在し、
存在する場合は、期待値が設定されているかどうかを確認します。あなたの場合、absolute.path値は/path/in/nifi/node/to/fileである必要があります およびflowfilename値は/data.csvである必要があります
質問:UpdateAttributeを使用してこれらの属性を自分で設定していますか 、理由は、NiFiがflowfilenameという名前の属性を生成しないためです。 、filenameという名前のファイルを生成します 。
もう1つ、absolute.pathのいずれかの値を確認してください /で終わります 最後に、またはflowfilenameの値 /で始まります 。そうでない場合は、それらが追加され、結果は/path/in/nifi/node/to/filedata.csvになります。 。 appendを試すことができます @Mahendraが提案した関数。それ以外の場合は、${absolute.path}/${flowfilename}を使用できます。 。
更新
absolute.pathに気づきました filenameのようなコア属性です 、filesize 、mime.type 、など。一部のプロセッサはすべてのコア属性を使用しますが、一部のプロセッサは必要なものをほとんど使用しません。 GenerateTableFetch absolute.pathを書き込みます しかし、それについては何も設定していません。そのため、./があります これがデフォルト値です。
したがって、作業へのアプローチに関する私の提案は、absolute.pathを手動で設定/上書きできることです。 UpdateAttributeを使用した属性 (filenameを上書きしたように )そして/path/in/nifi/node/to/fileである希望の値を設定します