📜  Apache NiFi-创建流程

📅  最后修改于: 2020-11-18 08:43:21             🧑  作者: Mango


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

通常,NiFi在流程开始时就有一个侦听器组件,例如getfile,它从源系统获取数据。在另一端,有一个发送器组件(如putfile),中间有处理数据的组件。

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

创建流程

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

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

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

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

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

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

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

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

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

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

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

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

  • 现在开始该流程,并在输入目录中添加一个空文件,您将看到它将移至输出目录,并将文本添加到该文件中。

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