apache-nifi - 如何限制 Nifi 处理器在集群中的单个节点上运行？

Question

我们正在使用 NiFi 构建数据工作流，并希望最终(自定义)处理器(运行重复数据删除逻辑)仅运行一个 NiFi 集群节点(而不是在所有节点上运行)。我看到 NiFi 1.7.0(尚未发布)有一个 PrimaryNodeOnly用于强制执行单个节点执行行为的注释。有没有办法或解决方法在 NiFi 1.6.0 中强制执行此类行为？

注意:除了 @PrimaryNodeOnly ，如果 NiFi 提供一种仅在单个节点上运行处理器的方法(即，诸如 @SingleNodeOnly 之类的注释)会更好。这样，执行节点不一定是主节点，因此将减少主节点上的负载。这只是对 future 的一个要求，并不是解决上述问题所必需的。

Answer 1

在以前的版本中没有特定的解决方法来强制执行它，数据流设计者可以将预期的处理器标记为仅在主节点上运行。您可以编写一个脚本来查询特定类型或名称的处理器的 NiFi API，然后检查/设置策略为 Primary Node Only。