mule - Mule Anypoint 时间戳 flowVar 不按 LastModifiedDate 过滤有效负载

Question

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

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

下面是我的配置截图：

水印设置：

Db1 查询：

BatchStep 接受表达式：

消息丰富器：

选择设置：

Answer 1

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

另外，您在 Db2 batch_step 中的查询是什么？检查它，因为它可能总是得到可能导致payload.size> 0的结果。