2016-03-05 25 views
1

筛选有效载荷我试图创建一个使用骡子柔软,因此DB1检查基于上次更改日期的任何更新,如果这样的更新应用到DB2数据同步。 我已经将脚本运行到脚本首次启动时的位置,数据从Db1复制到Db2。之后脚本不断更新Db2中的记录。 (下面是我的流程图)骡子Anypoint时间戳flowVar不通过LastModifiedDate

enter image description here 我试图在(在Batch_Step)消息浓缩塔设置recordVars,看是否存在记录,并在路线选择它们进行相应(在Batch_Step1)。 我也启用了时间戳的轮询中的水印,但没有任何工作可以避免不断更新插入的记录。

下面是我的configs的截图:

水印设置: enter image description here

DB1查询: enter image description here

BatchStep接受的表达: enter image description here

消息富集: enter image description here

选择设置: enter image description here

回答

2

在Select语句从DB1添加LastModifiedDate所以水印将能够访问该场payload.LastModifiedDate。

此外,您在Db2 batch_step中的查询是什么?检查它,因为它可能总是得到可能导致总是有效载荷大小为0的结果。

+0

谢谢!将LastModifiedDate添加到Db1的Select语句解决了它。现在它不会返回有效负载,除非在Db1中找到更新的LastModifiedDate。 – codeBarer