在 Nifi 中实现计数器作为流文件属性

Question

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

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

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

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

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

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

流文件第一次进来时该属性counter不存在。我想检查它是否存在，如果不存在，则将其添加到流文件中。当它在执行过程中稍后出现时，如果存在，我想增加它。这怎么可能？

Answer 1

使用这个表达方式。

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

如果该counter属性不存在，则将创建该值1，如果该counter属性存在，则将更新+1。