NiFi_Demo_调度示例

1.背景

要求：每天凌晨1：00后开始每2min执行一次sql查询

2.作业编排

3.各模块配置

3.1 GenerateFlowFile

作用：用于产生flowfile，该flowfile内容为空。

主要配置如下其余默认配置：

3.2 UpdateAttribute

作用：给flowfile添加属性名及赋予属性值

主要配置如下：

3.3 RouteOnAttribute

作用：根据属性做路由，好比if判断

主要配置如下：

3.4 ExecuteSQL

作用：执行sql查询

配置：暂未配置