Apache Nifi自定义处理器对另一个处理器的依赖性



根据我的要求,我需要创建一个Nifi自定义处理器,它将对消息进行结构化,然后向Splunk写入。

我遵循下面的链接创建自定义处理器,但不清楚如何在自定义处理器代码中使用invokeHttpProcessor/putSplunk处理器。欢迎任何建议

https://help.syncfusion.com/data-integration/how-to/create-a-custom-processor

一般来说,像InvokeHttp和PutSplunk这样的实际处理器实现并不意味着被划分为as-is子类,如果有代码可以在处理器之间重用,请随时联系社区(例如通过邮件列表(,我们可以讨论将这些代码转移到API。

同时,我不确定将实现NAR作为自定义处理器NAR的父级是否有效,但您可以尝试,它可能会让您对实现进行子类化,但不建议这样做。

另一种选择是从您想要的处理器中复制代码,并直接在自定义处理器中使用重复的代码。当然,这里有一些可维护性的更改,但如果您将自定义处理器封装在复制的NiFi处理器之外,您只需要留意对NiFi处理程序所做的任何更改,并相应地更新您的副本。

最新更新