java - 扩展原生 NiFi 处理器

Question

我已经知道如何编写自定义处理器(扩展org.apache.nifi.processor.AbstractProcessor)。我已经使用了这种技术，并且也可以轻松创建自定义 org.apache.nifi.components.PropertyDescriptor 和 org.apache.nifi.processor.Relationship 字段覆盖 onTrigger 方法。此外，我知道如何设置构建、建立 list 并创建我的 .nar 文件。

我一直无法弄清楚是否存在扩展原生 NiFi 处理器的合理模式。我的希望是扩展 native 处理器，以便我可以使用我的扩展类(而不是其他类)进行新的单元测试。

至少，我想做的就是扩展处理器并为其定义的特定 PropertyDescriptor 设置值。镀金可能会阻止用户(例如通过 NiFi Canvas )更改此配置。

有人可以提供任何指导或提供一些引用资料吗？

谢谢!

<小时/>

其他详细信息:我的具体目标是设置原生 JoltTransformJSON processor 中 JOLT_SPEC 的值。尽管如此，我希望有一个约定来设置超出此特定类和字段的 PropertyDescriptor 值。

Answer 1

没有什么可以阻止您使用这些自定义行为的子类化特殊实现来构建 NAR，但对我来说这听起来没有必要。您并不是用新行为来扩展这些处理器的功能，您只是预先配置值并限制访问。这两个步骤都可以使用 native NiFi 功能来完成。

我建议查看 API或使用类似 NiFi CLI 的工具或NiPyAPI要编写此行为的脚本 - 从静态资源中读取 JOLT_SPEC，将其提供为 PropertyDescriptor 值，并将处理器上的 ACL 设置为对特定用户只读。