使用水槽攔截器逐行過濾文件

Question

我正在嘗試配置從.csv或.xl3讀取的水槽代理。文件示例：

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 

我希望代理逐行過濾文件。如果持續時間不爲空，該事件將被髮送到hdfs/usr/admin/Good_Call，否則，該事件將被髮送到另一個路徑/ usr/admin/Bad_Call。

如何做到這一點用水槽的配置，攔截

Answer 1

您可以使用taildir sink和regex extractor interceptor。由於正則表達式提取器，你會有不同的頭「好」和「壞」線。最後，添加multiplexing channel selector，這將取決於發送事件的標頭的值。