集成和单元测试Nifi进程组

Question

我有几个Nifi进程组,我想在升级到生产之前运行集成测试.问题是我似乎无法找到有关如何操作的任何文档.

Data Provenance似乎是一个很有前途的工具来完成我想要的工作,但是,在flowfile的生命周期中,数据是发布到kafka或从文件系统发布的.结果,流文件UUID发生了变化,因此我无法使用它来查询它nifi-api.

另外,我知道Nifi提供了一个TestRunner运行测试的库,但是,这似乎只适用于通过代码而不是UI生成的处理器/处理器组.

有没有人知道用于集成和单元测试nifi进程组的工具,框架或模式.理想情况下,这将是一个解决方案,您可以编程地比较处理器/处理器组的输入/输出,而无需修改现有工作流程.

Answer 1

随着Apache NiFi 注册表的引入，我们看到用户将流程从开发/沙盒环境提升到测试/QE 环境，其中存在围绕“被测流程”的现有“测试工具”流程，以便他们可以发送可重复的和确定性（或真实生产数据的匿名样本），并将结果与​​预期值进行比较。

正如您所指出的，为单元测试提供了一个TestRunner类和一个完整的测试框架。虽然手动将 UI 构造的流程转换为编程构造可能很困难，但您也可以创建类似转换器的东西来接受流程模板或 flow.xml.gz 文件，并将其转换为测试框架可处理的内容。