Nifi测试:输入端口和输出端口

问题描述 投票:0回答:1

我有一个带有一个输入和两个输出流的流程(快乐路径和故障路径)。我想测试流程,考虑将消息直接放到输入流并验证输出流。可能的选择是使用REST api或site-2-site与事务?我设法使用站点到站点进行写入和读取,但我注意到输出端口即使在使用它之后也留下了消息(我确实提交了事务,即.event.confirm()&transaction.complete()) 。

有人设法让这个工作,并可以共享示例代码?请或其他任何方式来测试这个?

testing input apache-nifi flow ports
1个回答
0
投票

我建议将此流放入进程组和根(或祖先进程组)画布,使用GenerateFlowFile处理器生成测试夹具数据并将其路由到PG输入端口。然后使用一个或多个LogAttribute处理器来消耗成功/失败输出并验证它。这种特殊的测试工具将使您的流程更加轻松。

© www.soinside.com 2019 - 2024. All rights reserved.