Apache NiFi - 创建流

Apache NiFi 提供了大量组件来帮助开发人员为任何类型的协议或数据源创建数据流。 要创建流程，开发人员将组件从菜单栏拖动到画布，然后通过单击鼠标并将鼠标从一个组件拖动到另一个组件来连接它们。

一般来说，NiFi 在流程的开头有一个监听器组件，如 getfile，它从源系统获取数据。在另一端有一个发送器组件，如 putfile，中间还有一些组件，处理数据数据。

例如，让我们创建一个流程，该流程从一个目录获取一个空文件，并在该文件中添加一些文本，然后将其放入另一个目录中。

• 首先，将Processor(处理器)图标拖到 NiFi 画布上，然后从列表中选择 GetFile Processor(处理器)。

• 创建一个输入目录，例如 c:\inputdir。

• 右键单击Processor(处理器)并选择"配置"，然后在"属性"选项卡中添加输入目录 (c:\inputdir)，然后单击"应用"并返回画布。

• 将Processor(处理器)图标拖到画布上，然后从列表中选择 ReplaceText Processor(处理器)。

• 右键单击Processor(处理器)并选择配置。 在属性选项卡中，在替换值文本框中添加一些文本，例如"Hellotutorialspoint.com"，然后单击"应用"。

• 转到"设置"选项卡，选中右侧的失败复选框，然后返回画布。

• 在成功关系上将 GetFIle Processor(处理器)连接到 ReplaceText。

• 将Processor(处理器)图标拖到画布上，然后从列表中选择 PutFile Processor(处理器)。

• 创建一个输出目录，例如c:\outputdir。

• 右键单击Processor(处理器)并选择配置。 在属性选项卡中，添加目录 (c:\outputdir) 并单击应用并返回画布。

• 转到"设置"选项卡并选中右侧的失败和成功复选框，然后返回画布。

• 在成功关系上将 ReplaceText Processor(处理器)连接到 PutFile。

• 现在启动流程并在输入目录中添加一个空文件，您将看到它将移动到输出目录并且文本将添加到文件中。

通过执行上述步骤，开发人员可以选择任何Processor(处理器)和其他 NiFi 组件来为其组织或客户创建合适的流程。