Apache NiFi - 创建数据流



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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

广告