MongoDB Atlas触发器离线同步仅触发最新事务的解决方法问询

我通过MongoDB Realm实现了React Native应用与MongoDB Atlas的同步，同时配置了监听change stream的触发器，用于将数据推送至外部API。在线模式下，应用每笔事务同步到Atlas后都会正常触发触发器，但离线状态下用户执行多笔事务，上线同步后只有最新的那笔事务会触发触发器（已通过日志确认此问题）。

架构与流程 #

• React Native应用通过Realm订阅MongoDB Atlas中的目标集合，集合文档包含数字、字符串、日期及数组类型字段
• 用户提交表单后，数据同步至Atlas的业务集合
• 数据提交到Atlas时，触发Node.js编写的触发器，将同步的数据推送至外部API
• 预期应用每次表单提交都会触发对应的触发器

需求 #

如何实现所有离线事务在同步完成后，均能触发对应的触发器，而非仅最新的那笔事务？

解决方案 #

MongoDB Atlas触发器的设计定位是响应特定事件或定时任务，并不适合批量处理历史变更记录。可以通过新增专用的事务跟踪集合来解决这个问题，具体步骤如下：

1. 创建triggerQueue集合，用于存储所有需要触发器处理的事务记录。每次应用更新业务数据时，除了写入业务集合，同时向triggerQueue写入一条对应的事务记录，记录中包含isSynced字段（初始值设为false，标记该事务尚未完成外部推送）
2. 修改原有触发器，让它监听triggerQueue集合的change stream。触发器逻辑调整为：筛选出isSynced为false的文档，将数据推送至外部服务（如Azure Functions或AMP）后，将该文档的isSynced字段更新为true

通过这种方式，无论用户在离线状态下产生多少笔事务，只要同步到Atlas后，都会在triggerQueue中生成独立的记录，触发器会逐一处理每一条未完成的记录，确保所有离线事务都能被正确触发推送。

内容的提问来源于stack exchange，提问作者kashaziz