Apache NiFi - 创建流程

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

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

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

创造流程

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

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

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

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

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

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

  • 根据成功关系将 GetFILE 处理器连接到 ReplaceText。

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

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

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

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

  • 根据成功关系将 ReplaceText 处理器连接到 PutFile。

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

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