2016-03-05 18 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