代码之家  ›  专栏  ›  技术社区  ›  blong

扩展本机nifi处理器

  •  1
  • blong  · 技术社区  · 8 年前

    我已经知道如何编写自定义处理器(扩展 org.apache.nifi.processor.AbstractProcessor )中。我用过这种技术,而且我很乐意创建自定义 org.apache.nifi.components.PropertyDescriptor &安培 org.apache.nifi.processor.Relationship 字段,以及重写 onTrigger 方法此外,我知道如何设置构建、建立清单和创建 .nar 文件。

    我还没有弄清楚的是,是否有一个合理的模式来扩展本机nifi处理器。我希望扩展一个本机处理器,这样我就可以使用扩展类(而不是其他类)进行新的单元测试。

    至少,我要做的只是扩展一个处理器并为特定的 PropertyDescriptor 它定义了。镀金可能会阻止用户(例如通过nifi画布)更改此配置。

    有谁能提供指导或参考资料吗?

    谢谢!


    附加细节 :我的具体目标是设置 JOLT_SPEC 在本地 JoltTransformJSON processor 是的。不过,我希望有一个惯例 属性描述器 超出此特定类字段的值。

    1 回复  |  直到 8 年前
        1
  •  1
  •   Andy    8 年前

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

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