1.概述
我现在数据库发生变化后,希望实时同步到 另外的一个数据库库,当然能做数据库同步,也可以将数据同步到消息队列或其他的数据库进行备份。
2.实现过程
本次使用NIFI 组要使用了
- 数据源
- CaptureChangeMySQL
这个可以监控mysql 的数据库变更,并将变更的数据往后传递 - ExecuteGroovyScript
这个处理器组件的作用是,根据flowfile 的数据,构造SQL语句,给后续的节点使用 - PutSQL
这个的作用就是执行前面节点提交的SQL语句
2.1 配置数据源
配置数据源

这里正常配置即可,配置连接,驱动名称,用户名密码,另外 mysql 的驱动可以拷贝到 nifi 的lib 目录,也可以直接配置路径,最好就是不要配置,直接将驱动拷贝到lib目录。
这里我们配置两个数据源,一个来源一个目标数据源。
2.2 配置CaptureChangeMySQL

配置数据节点,用户名密码等,数据库,需要同步的表等
2.3.配置ExecuteGroovyScript
这个的代码的作用是,将上游的JSON生成SQL语句

2.4 配置PUTSQL
这个组件的作用就是将上游的数据,执行到数据库中。

这里比较简单,只需要配置目标连接即可。