regex - 使用水槽拦截器逐行过滤文件

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

我希望代理逐行过滤文件。如果 Duration 不为空，则事件将发送到 hdfs/usr/admin/Good_Call，否则，事件将发送到另一个路径/usr/admin/Bad_Call。

如何使用水槽配置、拦截器做到这一点

Answer 1

您可以使用 taildir sink和 regex extractor interceptor .作为正则表达式提取器的结果，“好”和“坏”行将有不同的标题。最后，添加 multiplexing channel selector这将根据 header 的值决定将事件发送到哪里。