Apache NiFi - Processor(处理器)关系

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

配置Processor(处理器)

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

成功

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

失败

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

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

失败

如上图所示,红色标记的连接有故障关系,这意味着所有有错误的流文件将转到左侧的Processor(处理器),而所有没有错误的流文件将分别传输到绿色标记的连接。

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

comms.failure

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

not.found

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

permission.denied

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