Nifi测试:输入端口和输出端口
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Nifi测试:输入端口和输出端口相关的知识,希望对你有一定的参考价值。
我有一个带有一个输入和两个输出流的流程(快乐路径和故障路径)。我想测试流程,考虑将消息直接放到输入流并验证输出流。可能的选择是使用REST api或site-2-site与事务?我设法使用站点到站点进行写入和读取,但我注意到输出端口即使在使用它之后也留下了消息(我确实提交了事务,即.event.confirm()&transaction.complete()) 。
有人设法让这个工作,并可以共享示例代码?请或其他任何方式来测试这个?
答案
我建议将此流放入进程组和根(或祖先进程组)画布,使用GenerateFlowFile
处理器生成测试夹具数据并将其路由到PG输入端口。然后使用一个或多个LogAttribute
处理器来消耗成功/失败输出并验证它。这种特殊的测试工具将使您的流程更加轻松。
以上是关于Nifi测试:输入端口和输出端口的主要内容,如果未能解决你的问题,请参考以下文章
使用1个端口或具有10,000+个传感器数据的多个端口进行nifi摄取?