ロギング機能として使用して、MongoDB キャップ付きコレクションをリッスンしたいと思います。
ノード、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
ます...
どんな手掛かり?