Ami*_*IFI 4 etl apache-kafka apache-nifi
我正在使用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的任何匹配结果
归档时间: |
|
查看次数: |
3300 次 |
最近记录: |