我想使用MongoDB流在每次将特定类型的数据插入到集合中时触发一个事件。
我已经找到了一些与我所寻找的内容大致相似的东西，但这只适用于变更流，而不适用于插入。
你知道我该怎么做吗
我使用Mongodb驱动程序和Nodejs来完成这一工作，因此我的代码如下所示：

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);
  });
});

• 是否需要在筛选器中指定operationType？
• 我还需要获取fullDocument，但显然updateLookup不是合适的工具，我应该使用什么？
• 我可以为on事件使用哪些选项？我使用了create，但我甚至不确定它是否存在，是吗？

很抱歉所有这些问题，但我正在努力找到一些答案，在官方文件。
解决方案：
注意不要忘记在您的请求中的fullDocument;- ）

function watch_insert(con, db, coll) {
  console.log(new Date() + ' watching: ' + coll);

  const insert_pipeline = [ { $match:
                    { 
                        operationType: 'insert',
                        $or: [
                            { "fullDocument.receipt.receiver": "newdexpocket" },
                            { "fullDocument.act.account": "newdexpocket" }
                        ]
                    }
                }];

  con.db(db).collection(coll).watch(insert_pipeline)
    .on('change', data => {
      console.log(data)
    });
}

async function run(uri) {
    try {
        con = await MongoClient.connect(uri, {"useNewUrlParser": true});
        watch_insert(con, 'EOS', 'action_traces');
    } catch (err) {
        console.log(err);
    }
}