微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

tailfile 和 routeText 在 nifi 中无法正常工作

如何解决tailfile 和 routeText 在 nifi 中无法正常工作

我是 nifi 的新手。我正在尝试解析一个每秒更新一次的日志文件,其中我需要根据某些条件执行 tailFile 和随后的 RouteText。

INPUT DATA :
[ 19/Mar/2021@00:10:01.946 :18:Thread-0:PrintEvents.java:eve:199 ] Domain: sq,Event Type: ATT_VALUE_CHANGE
[0] notificationId := 2820417
[1] ObjectName := {ET=HOAL_SET} {NE=10.253.207.114} {LOCATION=/remote_unit=1-1-12/shelf=1}
[2] ObjectType := LOC
[3] emsTime := 20210319001001.0
[4] neTime := 19700101052959.0
[5] edgePointRelated := false
[6] AttributeList := { AdditionalInfo = { {AVAILTIME=1616092801888} {distance=752}  }  }

[ 19/Mar/2021@00:10:26.247 :18:Thread-0:PrintEvents.java:eve:199 ] Domain: sq,Event Type: ATT_VALUE_CHANGE
[0] notificationId := 2820419
[1] ObjectName := {ET=HOAL_SET} {ManagedElement=10.253.204.178} {LOCATION=/remote_unit=1-2-3/shelf=1}
[2] ObjectType := LOC
[3] emsTime := 20210319001026.0
[4] neTime := 19700101052959.0
[5] edgePointRelated := false
[6] AttributeList := { AdditionalInfo = { {AVAILTIME=1616092777000} {dt=6510} {st=2} {opttime=1616092826143}  }  }


ROUTE CONDITION :

enter image description here

问题是,从输入中,notificationID 2820417 在 RouteText 中没有得到匹配,因此更多这样的通知被错过了。我认为 tailFile 也没有逐行读取所有数据。请在此处提供帮助。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。