
- Apache NiFi 教程
- Apache NiFi - 首页
- Apache NiFi - 简介
- Apache NiFi - 基本概念
- Apache NiFi - 环境设置
- Apache NiFi - 用户界面
- Apache NiFi - 处理器
- Apache NiFi - 处理器分类
- Apache NiFi - 处理器关系
- Apache NiFi - FlowFile
- Apache NiFi - 队列
- Apache NiFi - 处理组
- Apache NiFi - 标签
- Apache NiFi - 配置
- Apache NiFi - 管理
- Apache NiFi - 创建数据流
- Apache NiFi - 模板
- Apache NiFi - API
- Apache NiFi - 数据溯源
- Apache NiFi - 监控
- Apache NiFi - 升级
- Apache NiFi - 远程处理组
- Apache NiFi - 控制器设置
- Apache NiFi - 报告任务
- Apache NiFi - 自定义处理器
- Apache NiFi - 自定义控制器服务
- Apache NiFi - 日志记录
- Apache NiFi 有用资源
- Apache NiFi - 快速指南
- Apache NiFi - 有用资源
- Apache NiFi - 讨论
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 组件来为其组织或客户创建合适的数据流。