Mule Anypoint 时间戳 flowVar 不按 LastModifiedDate 过滤负载

Mule Anypoint timestamp flowVar does not filter payload by LastModifiedDate

我正在尝试使用 Mule Soft 创建数据同步,以便根据 LastModified Date 检查 Db1 是否有任何更新,如果是这样,更新将应用于 Db2。 我已经让脚本工作到一定程度,当脚本首次启动时,数据从 Db1 复制到 Db2。之后脚本不断更新 Db2 中的记录。 (下面是我的流程图)

我尝试在消息增强器(在 Batch_Step 中)中设置 recordVars 以查看记录是否存在并在 Choice(在 Batch_Step1 中)中相应地路由它们。 我还在 Poll 中为时间戳启用了水印,但没有任何方法可以避免不断更新插入的记录。

下面是我的配置截图:

水印设置:

Db1 查询:

BatchStep 接受表达式:

消息丰富器:

选择设置:

在 Db1 的 Select 语句中添加 LastModifiedDate,以便水印能够访问字段 payload.LastModifiedDate。

此外,您在 Db2 batch_step 中的查询是什么?检查它,因为它可能总是得到可能导致总是 payload.size > 0.

的结果