我刚刚开始探索NiFi功能,所以请和我一起裸露。
我已经成功创建了一个流程,该流程使用处理器ListenSyslog和PutFile捕获系统日志消息并将它们写入磁盘上的文件。
但是,我希望能够使用RouteOnAttribute处理器使用syslog消息的源IP路由这些传入的syslog消息。 ListenSyslog处理器信息页面列出了它写的属性“ syslog.hostname-Syslog消息的主机名或IP地址”,我想在RouteOnAttribute处理器中使用此属性。
我不清楚如何从RouteOnAttribute处理器配置属性内访问ListenSyslog处理器的书面属性来实现此目的。谁能指出我正确的方向?
谢谢。
每个属性都可以使用以下语法访问:${my_attribut}
。
根据您的情况:${syslog.hostname}
如果您想使用routeOnAttribut处理器,我建议您看一下表达式语言:
https://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html