问题描述
我是 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 :
问题是,从输入中,notificationID 2820417 在 RouteText 中没有得到匹配,因此更多这样的通知被错过了。我认为 tailFile 也没有逐行读取所有数据。请在此处提供帮助。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)