我正在使用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] 删除。
我来说两句