失败时NiFi块流文件

Question

我给自己设置了一个处理器故障关系，当一个流文件进程失败时，我希望它回到传入队列的顶部并重试，我也向管理员发送电子邮件通知，故障解决后，阻塞的流文件可以能够处理aggin。 NiFi 支持这个吗？

Answer 1

您可以从一个处理器中拖动多个关系，因此您可以有一个 failure 连接指向自身，还有一个 failure 连接指向PutEmail 处理器它将通知发送给管理员。如果您想对失败的流文件进行优先级排序，您可以使用 funnel 组件将传入队列与 failure 队列连接，并创建一个带有优先级的单一连接队列，用于“last进，先出”。