Apache NiFi中的条件路由

Ami*_*IFI 4 etl apache-kafka apache-nifi

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

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

Bry*_*nde 8

这肯定是可能的,流程可能是这样的......

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

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

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

4)RouteOnAttribute路由id属性包含"aaabbb"的流文件

5)PutKafka提供RouteOnAttribute的任何匹配结果