在数据流中添加RouteOnAttribute处理器。在属性添加处理器后,可以使用${}语句并使用NiFi表达式语言创建表达式。
在RouteOnAttribute处理器中使用以下表达式,可以检查属性值是否包含关键字。如果是,则将数据流路由到具有相应属性的连接。
${attribute:contains('keyWord')}
例如,假设数据流中的属性名为“attribute”,属性值为“value”,并且希望仅将包含“关键字”的属性值路由到下一个连接。这可以通过使用以下表达式来实现:
${attribute:contains('keyWord')}
在NiFi日志中记录RouteOnAttribute处理器的输出信息,可以通过在处理器配置中添加日志级别属性来实现。可以使用以下代码示例将日志级别更改为“DEBUG”:
org.apache.nifi.processors.RouteOnAttribute DEBUG
添加此代码后,处理器将记录输出信息和属性值路由情况的详细信息。这可以帮助调试和识别潜在问题。