每次将特定类型的数据插入到集合中时,我想使用 MongoDB 流来触发事件。
我已经找到了与我正在寻找的大致相似的东西,但这仅适用于更改流而不适用于插入。
知道我如何完成这项工作吗?
我正在使用带有Nodejs 的Mongodb驱动程序来完成这项工作,因此我的代码将是这样的:
const MongoClient = require('mongodb').MongoClient;
const uri = 'mongodb://localhost:27017/?replicaSet=rs0';
MongoClient.connect(uri, function(err, client) {
const db = client.db('mydb');
// Connect using MongoClient
var filter = [{
$match: {
$or: [
{ $or: [{"receipt.receiver": "newdexpocket"}, {"act.account": "newdexpocket"}] }]
}
}];
var options = { fullDocument: 'updateLookup' };
db.collection('somecollection').watch(filter, options).on('create', data =>
{
console.log(data);
});
});
Run Code Online (Sandbox Code Playgroud)
operationType在过滤器中指定一个吗?updateLookup不是正确的工具,我应该使用什么?on活动中使用哪些选项?我用过,create但我什至不确定它是否存在,是吗?对所有这些问题感到抱歉,但我正在努力在官方文档中找到一些答案。
解决方案:
当心不要忘记fullDocument您的请求;-) …