Apache Nifi 简明教程

Apache NiFi - Creating Flows

Apache NiFi 提供大量组件，帮助开发人员为任何类型的协议或数据源创建数据流。若要创建流，开发人员可将组件从菜单栏拖动至画布，然后单击并拖动鼠标，将组件彼此连接。

通常，NiFi 在流的开始部分有类似 getfile 的侦听器组件，用于从源系统获取数据。在另一端有类似 putfile 的发送器组件，以及处理数据的中间组件。

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

creating flow

  1. 首先，将处理器图标拖动到 NiFi 画布中，然后从列表中选择 GetFile 处理器。

  2. 创建一个输入目录，如 c:\inputdir.

  3. 右键单击处理器并选择“配置”，然后在“属性”选项卡中添加 Input Directory (c:\inputdir) ，单击“应用”，然后返回画布。

  4. 将处理器图标拖到画布上，然后从列表中选择 ReplaceText 处理器。

  5. 右键单击处理器，然后选择配置。在 properties 选项卡中，在 “替换值” 文本框中添加一些文本，例如 “Hello tutorialspoint.com” ，然后单击 “应用”。

  6. 转到 “设置” 选项卡，勾选右侧的 “错误” 复选框，然后返回到画布。

  7. 将 GetFIle 处理器连接到 ReplaceText，以建立成功关系。

  8. 将处理器图标拖到画布上，然后从列表中选择 PutFile 处理器。

  9. 创建输出目录，例如 c:\outputdir 。

  10. 右键单击处理器，然后选择 “配置”。在 “属性” 选项卡中，添加 Directory (c:\outputdir) ，然后单击 “应用” 并返回到画布。

  11. 转到 “设置” 选项卡，勾选右侧的 “错误” 和 “成功” 复选框，然后返回到画布。

  12. 将 ReplaceText 处理器连接到 PutFile，以建立成功关系。

  13. 现在开始流程，并在输入目录中添加一个空文件，您将看到它将移动到输出目录，并且该文本将被添加到文件中。

通过遵循以上步骤，开发人员可以选择任何处理器和其他 NiFi 组件，为他们的组织或客户创建合适的流程。