我有一个审计集合,在mongo中有一行像这样. { total: 100, successes: 95, failures: 5} 我想使用socket.io将其流式传输到UI.我可以使用像这样的mongo集合来实现. const Audit = require('../models/audit'); // Mon
{ total: 100, successes: 95, failures: 5}
我想使用socket.io将其流式传输到UI.我可以使用像这样的mongo集合来实现.
const Audit = require('../models/audit'); // Mongoose Model module.exports = function(app){ const http = require('http').Server(app); const io = require('socket.io')(http); Audit.find().tailable().cursor() .on('data', function(doc) { console.log(doc); io.emit('audit', doc); // push to subscribed clients }); };
然而,这似乎只支持插入.当我想监视单行的更改时,如何执行此操作?
您是否尝试使用awaitData和tailable标志设置游标?请参阅MongoDBs Node.JS驱动程序 API Reference.