首先来看一下整体的流程:
可以看到了用到了上面的这些处理器,然后我们主要看看,这里之前
同步的时候,总是出现重复的数据,奇怪.
比如源表中只有166条数据,但是同步过去以后变成了11万条数据了.
${db.table.name:equals('table1'):or(${db.table.name:equals('table2')})}
可以看到这里的,我们让同步这两个表,上面是路由出需要同步的表,这个RouteOnAttribute处理器的配置
RouteOnAttribute 这个处理器的配置可以看到
然后这个RouteOnAttribute处理器,连接到其他处理器的时候,选择路由策略,选择刚刚我们配置的路由策略就可以了.
其他的处理器的配置按照之前的配置就可以,之前的NIFI的博文都已经,说了如何使用了,这里不做说明.
这