Apache NiFi - 创建数据流

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

通常，NiFi 在数据流的起始位置有一个监听器组件，例如 getfile，它从源系统获取数据。在另一端，有一个发送器组件，例如 putfile，并且中间有一些组件来处理数据。

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

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

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

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

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

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

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

• 将 GetFIle 处理器连接到 ReplaceText 的成功关系。

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

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

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

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

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

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

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