2

ロギング機能として使用して、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ます...

どんな手掛かり?

4

1 に答える 1