2017-06-20 17 views
1

Apache NIFIの新機能で、POCとしてのフローを構築しようとしています。あなたの指導が必要です。Apache Nifi解凍

ファイル 'sample_file'を含む 'sample.gz'という圧縮された 'gz'ファイルがあります。 私はsample.gzファイルを解凍し、 'sample_file'をhdfsの場所に保存する必要があります。

私は、GetFileプロセッサを使用してsample.gzファイルを取得しています。CompressContentプロセッサは解凍モードで、同じファイルは解凍し、PutHDFSプロセッサは解凍ファイルをHDFSに配置します。

フローを実行した後、元のsample.gzファイルはHDFSの場所にのみコピーされていましたが、gzファイル内のsample_fileをコピーする必要がありました。だから、減圧は実際に私のために働いていません。

私が直面している問題を説明できることを願っています。私のアプローチを変更する必要があるかどうかをお勧めします。

+0

nifiのバージョンは、使用しますが何ですか? – daggett

答えて

3

同じプロセッサシーケンスを使用しましたが、PutHDFSPutFileに変更しました。

GetFile --> CompressContent(decompress) --> PutFile 

nifi v1.3.0ではうまく動作します。

のみ注:私はCompressContentのパラメータUpdate Filename = falseを続けるならば、filename属性は(sample.gz)前と解凍後も同じまま。

しかし、コンテンツは解凍されます。

ので、場合、ファイル名についてのご質問:あなたはCompressContentプロセッサにパラメータUpdate Filename = trueを設定することで変更することができ

  1. 。この場合sample.gzは、解凍中にsampleに変更されます。
  2. filename属性を変更するために使用UpdateAttributeプロセッサ
+0

あなたのコメントをありがとう..それは働いた.. –