更改流 mongodb 重复项答案

【问题标题】：Change streams mongodb duplications更改流 mongodb 重复项
【发布时间】：2020-11-27 01:42:14
【问题描述】：

我正在尝试动态创建更改流。我想知道是否有办法避免创建观察同一个目标的更改流？

db.collection('Test' + ).watch().
        on('change', data => console.log(new Date(), data));

db.collection('Test' + ).watch().
        on('change', data => console.log(new Date(), data));

如果测试集合现在有一些变化，我将收到两次通知。因为我在 SQS 旁边发送通知，所以我会有重复的消息。

有没有办法检查目标“xy”的更改流是否已经存在，以避免拥有相同的观察者？

谢谢

【问题讨论】：

标签： mongodb changestream

【解决方案1】：

变更流是一种广播机制（一个发布者（数据库），多个订阅者）。

如果您需要队列，则需要使用排队系统并将工作项排入队列，而不是将它们存储到集合中并通过更改流观察集合。

【讨论】：