Apache NiFi可以使用'Wait”处理器等待满足条件的FlowFile,然后将它们发送到处理器的下一个步骤。FlowFile的属性是在等待过程中确定条件的一种通用方法。以下是使用属性等待的示例:
拖放Wait/Notify模板之前的FlowFile:
配置'Wait”处理器:
配置'Notify”处理器:
使用这个流程,如果FlowFile具有'status”属性且其值为'wait”,它会被阻塞,并在FlowFile处理时推送到"notify"处理器,如果FlowFile没有'status”属性或它的值不是'wait”,它会直接发送到"next"处理器。