NIFI从MySql中增量同步数据_通过Mysql的binlog功能_实时同步mysql数据_根据binlog实现update数据实时同步_实际操作05---大数据之Nifi工作笔记0044

具体的,之前已经写过,如何在NIFI中实现MySQL的增量数据同步,但是写的简单了,因为,比如在插入的时候,更新的时候,仅仅是写死的某个表,也就是针对某个表,指定好字段进行插入操作,或者更新操作,这样就有些局限了,比如我想同步一整个库,注意是增量同步,那么,难道我要一张一张表的去创建好了以后,然后我再去一个的同步嘛,比较麻烦,一点点解决.

   首先看这个日期同步的问题,这里:

首先先来看一下之前那个整体的,mysql到mysql增量同步的流程,可以看到这里我们主要修改insert的ReplaceText处理器就可以, 修改这里拼接sql语句的部分.

 

上面这个insert对应的ReplaceText处理器需要修改.

需要修改他的ReplacementValue这个属性 

INSERT INTO userinfo_nifi(id,name,mobile,email,son_json,cdate) VALUES(${id},"${name}","${mobile}","