Apache NiFi中的条件路由

胺CHERIFI

我正在使用NiFi从Oracle数据库中获取数据,并将某些数据放入Kafka(使用处理器PutKafka)。示例:如果属性“ id”包含“ aaabb”

在Apache NiFi中有可能吗?我该怎么做?

布莱恩·本德

这绝对应该是可能的,流程可能是这样的……

1)ExecuteSQL或QueryDatabaseTable从数据库中获取数据,这些产生Avro

2)ConvertAvroToJson处理器将Avro转换为Json

3)EvaluateJsonPath将id字段提取到属性中

4)RouteOnAttribute路由其中id属性包含“ aaabbb”的流文件

5)PutKafka从RouteOnAttribute传递任何匹配结果

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章