Apache NiFi - 处理器关系


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

配置处理器

正如您在上图中看到的,黑色矩形中的复选框是关系。如果开发人员选择这些复选框,则当关系成功或失败或两者兼而有之时,流文件将在该特定处理器中终止。

成功

当处理器成功处理流文件(例如从任何数据源存储或获取数据)而没有获得任何连接、身份验证或任何其他错误时,流文件将进入成功关系。

失败

当处理器无法在没有错误(如身份验证错误或连接问题等)的情况下处理流文件时,流文件将进入失败关系。

开发人员还可以使用连接将流文件传输到其他处理器。开发者可以选择并对其进行负载均衡,但负载均衡在1.8版本才发布,本教程不会涉及。

失败

正如您在上图中看到的,标记为红色的连接具有故障关系,这意味着所有有错误的流文件将转到左侧的处理器,而所有没有错误的流文件将分别传输到标记为绿色的连接。

现在让我们继续处理其他关系。

通讯故障

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

未找到

我们从远程服务器收到“未找到”消息的任何流文件都将转移到not.found关系。

没有权限

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