apache-nifi - 在 Nifi 中将计数器实现为流文件属性

Question

使用 Nifi，我想处理处理器的错误。

如果处理器将流文件发送到失败链接，我想将它发送回 x 次给未能处理它的处理器。

为此，我想在流文件属性中实现一个计数器。但是，我面临两个问题

• 如何检查流文件是否包含 counter 属性？
• 如何增加 counter 属性(如果存在)？

到目前为止，我有以下流程:

我卡在了“更新计数器”处理器上。我不明白如何实现这一目标。

counter这个属性在flowfile刚进来的时候是不存在的，我想看看它是否存在，如果不存在，就把它添加到flowfile中。当它在执行过程中稍后出现时，如果它存在，我想增加它。这怎么可能？

Answer 1

使用这个表达式。

${counter:replaceNull(0):plus(1)}

如果 counter 属性不存在，这将创建带有 1 的值，如果 counter 属性存在，它将被更新+1。