为了分离逻辑,简化主要流程并重用处理器组,我正在寻找在 Apache NiFi 中实现进程间通信逻辑的东西。
到目前为止,我唯一能找到的是在主要流程中使用 InvokeHTTP 并在组中使用 HandleHTTPRequest/Response 对。但是,开放的 HTTP 端口过多可能会导致安全问题。有没有更好的方法来做同样的事情,即将流文件和属性路由到所需的处理器,然后返回?如果没有,我认为在 NiFi 中内置路由/拦截流处理器会很有帮助。
PS。我知道我可以将一个组变成一个模板并在流程中使用它,在这种情况下我不想这样做。我希望能够在多个流程中使用相同的逻辑。