flumeインターセプタを使用してファイルを1行ずつフィルタリングします。

Question

.csvまたは.xl3から読み取るflumeエージェントを設定しようとしています。ファイルの例：

ClientA ClientB Start-time End-time Duration Status 
35862515 36958452 16/01/2017 16/01/2017 10   good 
32456988 22583694 16/01/2017 16/01/2017 05   good 
35968478 36985724 16/01/2017 16/01/2017 
32456988 22583694 16/01/2017 16/01/2017 01   good 

私はエージェントフィルタをファイルごとに1行ずつ取りたいです。 Durationがnullでない場合、イベントはhdfs/usr/admin/Good_Callに送信されます。そうでない場合、イベントは別のパス/ usr/admin/Bad_Callに送信されます。水路設定を使用して、インターセプタ

Answer 1

あなたはtaildir sinkとregex extractor interceptorを使用できることを

はどのように行います。正規表現抽出プログラムの結果として、 "良い"と "悪い"行のヘッダーが異なります。最後に、 multiplexing channel selectorを追加します。これは、イベントを送信するヘッダの値に応じて決定します。