NiFi之Processor配置

Posted 2022-06-11 zxbdboke

Processor(处理器)之配置

选择一个Processor，比如ExecuteSQL，从它的名字可以看出该处理器的功能就是去执行一个sql(当然是执行的该sql必须要有返回值的)，下面就以ExecuteSQL做示例说明，在画布上添加ExecuteSQL处理器，选中右键查看设置如图

1. configure 配置（主要说configure，其它的大家自行点点试试）

选择中处理器右键选择configure或者直接双击处理器进入配置，如图所示一共有4栏配置项

1.1 Settings

• Automatically Terminate Relationships

　　什么时候需要勾选需要终止的关系呢？对该处理器的关系，比如成功或者失败等等任意一个或者多个关系不做进一步的处理时就需要勾选掉。

1.2 Scheduling

• Scheduling Strategy

调度策略有三中选择

1. Timer driven：时间驱动(间隔多少时间执行)
2. Event driven：事件驱动
3. CRON driven：cron驱动

注意：处于头处理器的调度时间（Run Schedule）一定要设置，不要用默认的0 sec；不然的话就是死循环一直执行，比如说ExecuteSQL处理器没有设置调度时间的话就会造成频繁访问数据库，导致数据库挂断。

• Execution：

执行的节点有两种选择

1. All nodes：所有节点
2. Primary node：主节点

注意：对应单节点的NiFi来说上面两种选择都是没有区别的，对于集群来说的话，头处理器一般都是选择Primary node，处理器选择All nodes，因为在处理器是整个任务的起点，选择所有节点的话，每个节点都会去执行相同的任务，这肯定不是我们所想要的，我们只需要一个节点执行就可以了。

1.3 Properties

 属性的配置对于不同的处理器是不同的，鼠标指着属性名后面的问号就会有对应的说明

搞清楚每个属性的作用，然后进行相应的配置。

提示：要更好的查看属性的说明，请选中ExecuteSQL右键选择View usage，然后就会有ExecuteSQL详细的说明了.

1.4 Comments

这个注释说明没什么好说的