Apache NiFi - 处理器关系



在 Apache NiFi 数据流中,FlowFile 通过连接从一个处理器移动到另一个处理器,连接的有效性通过处理器之间的关系进行验证。每当创建连接时,开发人员都会选择这些处理器之间的一种或多种关系。

Configure Processor

如上图所示,黑色矩形中的复选框是关系。如果开发人员选中这些复选框,则当关系成功或失败或两者兼有时,FlowFile 将终止于该特定处理器。

成功

当处理器成功处理 FlowFile(例如从任何数据源存储或获取数据,而不会遇到任何连接、身份验证或任何其他错误)时,FlowFile 将进入成功关系。

失败

当处理器无法无错误地处理 FlowFile(例如身份验证错误或连接问题等)时,FlowFile 将进入失败关系。

开发人员还可以使用连接将 FlowFile 传输到其他处理器。开发人员可以选择并进行负载均衡,但负载均衡只是在 1.8 版本中发布的,本教程中不会介绍。

Failure

如上图所示,红色标记的连接具有失败关系,这意味着所有带有错误的 FlowFile 将进入左侧的处理器,相应地,所有没有错误的 FlowFile 将传输到绿色标记的连接。

现在让我们继续讨论其他关系。

comms.failure

当由于通信故障无法从远程服务器获取 FlowFile 时,将满足此关系。

not.found

对于我们从远程服务器收到“未找到”消息的任何 FlowFile,都将移动到**not.found**关系。

permission.denied

当 NiFi 由于权限不足而无法从远程服务器获取 FlowFile 时,它将通过此关系移动。

广告