当前位置：文江博客话题详情

Node.js 监听 MongoDB 变化

发布于 2024-12-06 21:44:49 字数 54 浏览 1 评论 0原文

Node.js 有没有办法监听 MongoDB 集合中特定数据的更改，并在发生更改时触发事件？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

诗酒趁年少 2024-12-13 21:44:49

嗯，这是一个老问题，但我也在为同样的事情而苦苦挣扎。我发现了一些帮助我整合解决方案的花絮，并将其作为库发布：

https ://github.com/TorchlightSoftware/mongo-watch

该库是用coffeescript编写的。这是一个 javascript 示例，供喜欢的人参考。

var MongoWatch = require('mongo-watch'),
    watcher = new MongoWatch({parser: 'pretty'});

watcher.watch('test.users', function(event) {
  return console.log('something changed:', event);
});

Well, this is an old question, but I was struggling with the same thing. I found a number of tidbits that helped me put together a solution, and I've published it as a library:

https://github.com/TorchlightSoftware/mongo-watch

The library is written in coffeescript. Here's an example in javascript, for those that prefer.

var MongoWatch = require('mongo-watch'),
    watcher = new MongoWatch({parser: 'pretty'});

watcher.watch('test.users', function(event) {
  return console.log('something changed:', event);
});

回复收藏 0 原文

神仙妹妹 2024-12-13 21:44:49

MongoDB 显然现在支持触发器和监视，这个答案已经过时了。

[原始]我相信您正在寻找数据库触发器。

不幸的是，MongoDB 还不支持它们，所以我认为你不能直接从数据库监听更改。您需要设置某种通知系统（例如发布/订阅），以便在集合发生更改时向感兴趣的各方发出警报。

回复收藏 0 原文

你的笑 2024-12-13 21:44:49

MongoDB 3.6引入了变更流，旨在解决这个问题。

这是一个示例： https://github.com/thakkaryash94/mongodb-change-流-nodejs-示例

const pipeline = [
  {
    $project: { documentKey: false }
  }
];

const db = client.db("superheroesdb");
const collection = db.collection("superheroes");

const changeStream = collection.watch(pipeline);
// start listen to changes
changeStream.on("change", function (change) {
  console.log(change);
});

MongoDB 3.6 introduced change streams, which are designed to solve precisely this problem.

Here's an example: https://github.com/thakkaryash94/mongodb-change-streams-nodejs-example

const pipeline = [
  {
    $project: { documentKey: false }
  }
];

const db = client.db("superheroesdb");
const collection = db.collection("superheroes");

const changeStream = collection.watch(pipeline);
// start listen to changes
changeStream.on("change", function (change) {
  console.log(change);
});

回复收藏 0 原文