NiFi 模板 | 学习笔记

简介: 快速学习 NiFi 模板

开发者学堂课程【NiFi 知识精讲与项目实战(第一阶段)Nifi 模板 】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/705/detail/12520


Nifi 模板

内容介绍:

一、创建模板

二、使用模板


一、创建模板

1、当使用处理器在 NiFi 当中涉及复杂的数据流的时候,经常会发现相同的处理器序列串在一起执行任务的时候,这个流程很长。在这种情况下,NiFi 提供了模版概念,它可以用来做解耦合。模板可以被认为是能够重用的子流程。要想创建模板,可以通过一个简单的步骤实现。

2、首先要选择想要创建成模板的组件,然后右键单击第一个组件,按住 shift 键通过一个多选框把想要获取的组件全部圈起来,然后点击操作面板上创建模板的按钮,在之前讲解面板的时候有提到过这个按钮,然后就可以输入模板的名称进行创建。创建模板以后就可以使用它来作为一个包,就像 JAVA 里面的包一样。可以通过添加菜单栏里面的 template 模板组件,添加到工作区。然后我可以选择已经创建或者已经上传的模板,进行快捷的添加,这样的话提高了 NiFi 流程的复用性。最后,可以使用模板管理这个功能,来管理已经拥有的模板。可以从菜单栏当中选择模板信息,然后可以把已经有的模板进行删除操作,或者说是下载操作。下载以后可以把下载出来的 XML 文件,发送给其他的项目组,或者发送到公司的组件库当中,为以后的复用提供基础。

 

二、使用模板

1、如果想要导入 NiFi 模板,可以点击上传模板这个按钮,然后选择已经保存好的 XML 文件,进行上传。

使用模板的时候有一些注意事项,就是任何已经被标记为敏感的属性,在添加模板的时候都不会被保存。比如说MySQL 数据库的密码,账号会被保留,密码再添加以后,复用导入以后,还要进行重新的输入。如果不输入在使用的时候就会报错,因为这些是属于敏感的数据。如果 NiFi 包含组件引用了 Controller Service,那么被引用的 Controller Service 类似的主件也需要添加到模板当中,也就是说,每一次我们把模板导入到工作区的时候,它都会自动的创建一个新的 Controller Service。

2、NiFi 模板的使用。 打开 nifi web,在工作区的左侧,有一个按钮叫做创建模板,点击。点击以后可以在输入框当中输入模板的名称,例如叫做 file get put。

1111.png

然后填写一些描述信息,获取并剪切文件,点击 create。此时会收到提示,已经成功添加。可以在菜单栏的右侧,点击按钮,点击 template

22222.png

如图所示现在已经拥有的模板信息。可以在这里面进行操作,例如下载模板,也可以进行删除模板。

3333.png下载的模板主要是一个 XML 文件,我们可以看到这个里面保存的就是模板里面的所有组件。

4444.png 3.下载完以后,可以把这个文件存储到公共库当中,在以后进行使用的时候直接进行上传、复用流程。我们可以点击upload template 按钮,在弹出框中可以点击选择按钮,从这里面就可以选择 NiFi 模板。

5555.png然后点击 upload 上传就可以了。上传完以后,template 当中就会存在已经上传和自己创建的所有模板信息。

4.使用模板的具体操作。

可以通过菜单栏的模板按钮,拖动到工作区域当中,然后选择想要使用的模板,点击 add,这个时候就会把模版当中所包含的所有组件全部加载进来。如何来选择多个组件呢?我们可以通过按住 shift 按钮,同时通过鼠标选择区域,选择我们想要使用的组件,然后进行创建模板或者删除等等这样的操作。

5.当使用处理器在 NiFi 中设计复杂的数据流处理流程时,经常会发现将相同的处理器序列串在一起以执行某些任务。这种情况下,NiFi 提供了模板概念。模板可以被认为是可重用的子流。要创建模板,请按照下列步骤操作:  

(1)选择要包含在模板中的组件。我们可以通过单击第一个组件,然后按住 Shift 键同时选择其他组件(以包括这些组件之间的连接),或者在画布上拖动所需组件周围的框时按住 Shift 键选择多个组件。

(2)从操作面板中选择如下图标。

6666.png 

(3)提供模板的名称和描述。

(4)单击 Create 按钮。 一旦创建了一个模板,就可以将它用作流程中的构建块,就像处理器一样。单击并将模板图标 从组件工具栏拖动到的画布上。然后,选择要添加到画布的模板,然后单击 Add 按钮。

7777.png 

5.最后,可以使用模板管理(Template Mangement)对话框来管理模板。要访问此对话框,请从全局菜单(GlobalMenu)中选择模板。在这里,我们可以看到存在哪些模板并设置过滤条件以找到感兴趣的模板。在表的右侧是一个图标,用于将模板导出或下载为 XML 文件。然后可以将其提供给其他人,以便他们可以复用模板。

要将模板导入 NiFi 实例,请上传模板从操作选项板中选择上载模板 ,单击搜索下图图标并选择本地计算机上的文件。然后单击 Upload 按钮。模板将显示在的表格中,可以将其拖动到画布上,与创建的任何其他模板一样。

8888.png 

6、使用模板时需要记住一些重要注意事项:

(1)任何标记为敏感属性的属性(例如在处理器中配置的密码)都不会添加到模板中。每次将模板添加到画布时都必须填充这些敏感属性。

(2)如果模板中包含的组件引用 Controller Service,则 Controller Service 也将添加到模板中。这意味着每次将模板添加到图表时,它都会创建 Controller Service 的副本。

相关文章
|
数据可视化 关系型数据库 MySQL
Apache NiFi之MySQL数据同步
一.简述 Apache NiFi是一个易用、强大、可靠的数据处理与分发系统,Apache NiFi的设计目标是自动化管理系统间的数据流Apache NiFi是美国国家安全局(NSA)开发和使用了8年的一个可视化、可定制的数据集产品。
6156 0
typro收费了,怎么看markdown文章?推荐谷歌markdown插件
typro收费了,怎么看markdown文章?推荐谷歌markdown插件
391 0
typro收费了,怎么看markdown文章?推荐谷歌markdown插件
|
前端开发 Java Unix
【NiFi】(二)三分钟搞定 NiFi 安装与简单使用!
【NiFi】(二)三分钟搞定 NiFi 安装与简单使用!
2997 0
【NiFi】(二)三分钟搞定 NiFi 安装与简单使用!
|
大数据 OLAP 数据库
阿里大数据——数据库总结——ADS分析型数据库
阿里大数据——数据库总结——ADS分析型数据库自制脑图
912 1
阿里大数据——数据库总结——ADS分析型数据库
|
数据采集 物联网 大数据
NiFi【部署 01】NiFi最新版本1.18.0下载安装配置启动及问题处理(一篇学会部署NiFi)
NiFi【部署 01】NiFi最新版本1.18.0下载安装配置启动及问题处理(一篇学会部署NiFi)
2534 0
|
缓存 应用服务中间件 PHP
502错误是nginx返回的吗(502错误和nginx有关系吗)
本文详细介绍了Nginx出现502 Bad Gateway错误的原因及解决方法,包括缓冲区错误、Header过大和PHP-CGI进程不足等问题,并提供了增大缓冲区、调整Header大小及增加PHP-CGI进程数量的具体步骤。此外,还解释了502错误的含义及其可能原因,如上游服务器故障、网络故障和配置错误,并给出了检查上游服务器、代理配置及联系网络管理员等多种解决方案。以上内容仅供参考,具体操作需根据实际情况调整。
4491 4
|
存储 缓存 JavaScript
NPM怎样清空缓存
NPM怎样清空缓存
|
SQL 存储 关系型数据库
SQL判断CHAR类型字段不为空的方法与技巧
在SQL查询中,判断一个CHAR类型字段是否不为空是一个常见的需求
|
消息中间件 Kubernetes 监控
实时计算 Flink版操作报错合集之在编译源码时遇到报错:无法访问,该如何处理
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
XML Java 应用服务中间件
SpringBoot同时可以处理多少请求?
Spring Boot 的并发处理能力取决于其内置的 Web 容器,如 Tomcat、Undertow 或 Jetty。默认是 Tomcat,最大连接数为 8192,最大等待数为 100,因此默认可同时处理 8292 个请求。可通过配置 `server.tomcat.max-connections` 和 `server.tomcat.accept-count` 修改这些值。另外,可以通过排除 Tomcat 并引入 Jetty 或 Undertow 的依赖来更换 Web 容器。
2315 0