sql >> データベース >  >> RDS >> Mysql

フローファイル絶対パスNifi

    • PutSQLを停止します プロセッサを使用して、フローファイルをキューに入れます。
    • キューに入れたら、successを右クリックします
      UpdateAttribute間の関係 およびPutSQL List 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のようなコア属性です 、filesizemime.type 、など。一部のプロセッサはすべてのコア属性を使用しますが、一部のプロセッサは必要なものをほとんど使用しません。 GenerateTableFetch absolute.pathを書き込みます しかし、それについては何も設定していません。そのため、./があります これがデフォルト値です。

    したがって、作業へのアプローチに関する私の提案は、absolute.pathを手動で設定/上書きできることです。 UpdateAttributeを使用した属性 (filenameを上書きしたように )そして/path/in/nifi/node/to/fileである希望の値を設定します




    1. 1つの列でDISTINCTを選択

    2. MySQLが指定されたIDの行を選択しない

    3. Oracle.NETエラー-引数の数またはタイプが間違っています

    4. 括弧内の数字は本当にどういう意味ですか?