2017-11-16 16 views
0

ETLプロセスと同様に動作するnifiプロセスを構築したい(つまり)nifiプロセスは1日に1回実行され、特定のディレクトリからファイルを選択します。ファイルには日付が含まれています。これを環境変数として保存したい場合は、プロセスが実行される翌日にファイルから日付をVariableに格納された日付と比較したいのですが、これをNIFIで実現できる方法はありますか任意のテーブルに日付の値を格納せずに?私は完全に動作するファイルに格納しようとしましたが、それを行うためのよりよい方法がありますか?nifi値を設定/設定解除する変数を設定しています

答えて

0

@Jai、 あなたが1.Pickに特定のディレクトリ使用GetHDFSからファイルを

を使用してNiFiを使用していることを行うことができ、リスト/ FetchHDFS(または)GETFILE、リスト/ FetchFile 2.Extract日抽出テキストプロセッサを使用して、属性として日付を抽出できるregexで新しいプロパティを追加します。 3.抽出した属性を格納します。Distributemapcache Processorを使用して、抽出日属性を格納します。

4.次の日には、Fetch Distributecachemapプロセッサを使用して、格納された日付を取り出し、変数がすでに存在する変数と比較して、 distributemapcache processorに置き換えます。

関連する問題