我想收听一个 MongoDB 上限集合,将其用作日志记录工具。
我使用 node、express.js、mongo(和 mongoose)。
这是我到现在为止的(简化)代码:
var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/mydb');
var logSchema = new mongoose.Schema({
date: Date,
message: String
}, {
capped: {
size: 1024
}
});
var Log = mongoose.model('Log', logSchema);
var filter = { "date": { "$gte": Date.now() } };
var stream = Log.find(filter).tailable().stream();
stream.on('data', function(doc) {
console.log('log stream data - new doc:', doc.message);
}).on('error', function (error) {
console.log('status stream data - error:', error.message);
}).on('close', function () {
console.log('status stream data - closed');
});
// ...
var log = new Log();
logger = function(message) {
log.date = new Date();
log.message = message;
log.save(function(err) {
if (err) {
return console.error('error saving log');
}
console.log('log message "' + message + '" added');
});
};
// ...
myRoutingMethod = function(req, res) {
logger('my routing method started');
// ...
res.json('done');
});
我的问题是,在调用 myRoutingMethod() 之前,我得到:
database connection opened
log message "my new message" added
status stream data - error: No more documents in tailed cursor
status stream data - closed
所以,我从来没有得到
log stream data - new doc: my new message
我可能遗漏了一些关于将stream()
上限Log
集合与express.js
...集成的内容
有什么线索吗?