我使用nifi从oracle数据库获取数据，并将其中一些数据放入kafka（使用putkafka处理器）。示例：如果属性“id”包含“aaabb”这在apache nifi中可能吗？我该怎么做？
b4lqfgs41#
为了补充bryan的示例流，我想向您介绍一些很好的文档，这些文档可以帮助您了解apachenifi。首先，我建议查看nifi文档。这是非常好的，应该帮助很多。除了提供有关bryan提到的每个处理器的详细信息外，它还提供了针对每种类型用户的通用文档。有关构建nifi流的基本介绍，请查看此视频。例如，模板检查这个回购。它的根级别有一个excel文件，其中包含每个模板的描述和处理器列表。
ut6juiuv2#
这肯定是可能的，流可能是这样的。。。1） executesql或querydatabasetable从数据库中获取数据，这些生成avro2） convertavrotojson处理器将avro转换为json3） evaluatejsonpath将id字段提取到属性中4） routeonattribute以路由id属性包含“aaabbb”的流文件5） putkafka从routeonattribute传递任何匹配结果
2条答案
按热度按时间b4lqfgs41#
为了补充bryan的示例流，我想向您介绍一些很好的文档，这些文档可以帮助您了解apachenifi。
首先，我建议查看nifi文档。这是非常好的，应该帮助很多。除了提供有关bryan提到的每个处理器的详细信息外，它还提供了针对每种类型用户的通用文档。
有关构建nifi流的基本介绍，请查看此视频。
例如，模板检查这个回购。它的根级别有一个excel文件，其中包含每个模板的描述和处理器列表。
ut6juiuv2#
这肯定是可能的，流可能是这样的。。。
1） executesql或querydatabasetable从数据库中获取数据，这些生成avro
2） convertavrotojson处理器将avro转换为json
3） evaluatejsonpath将id字段提取到属性中
4） routeonattribute以路由id属性包含“aaabbb”的流文件
5） putkafka从routeonattribute传递任何匹配结果