如何在Mongoose查询上设置超时?

我正在使用一个非常大的Mongo数据库Mongoose,我想要像MySet.find({})昂贵的查询10秒后超时。

我已经尝试在我的连接上设置套接字超时,但如果超时超时服务器崩溃:

 var options = {server: {socketOptions: {socketTimeoutMS: 10000}}}; var conn = mongoose.connect('mongodb://localhost/my_db', options); 

我已经尝试将maxTimeMS选项传递给find函数,但是根本没有任何效果:

 MySet.find({}, {}, {timeout: true, maxTimeMS: 10000}, function(err, doc) {}); 

有任何想法吗?

       

网上收集的解决方案 "如何在Mongoose查询上设置超时?"

你可以使用Query#maxTime方法来做到这一点,这个方法在Mongoose本身没有logging,但它是Mongoose为其stream畅的查询接口使用的mquery库的一部分。

所以在你的情况下,你可以这样称呼它:

 MySet.find({}).maxTime(10000).exec(function(err, doc) { ... }); 

您可以通过maxTimeMS mongoose.set('debug', true);启用Mongoosedebugging来确认是否正确设置了maxTimeMS选项mongoose.set('debug', true); 然后你会看到这个查询的控制台输出,如下所示:

 Mongoose: myset.find({}) { maxTimeMS: 10000, safe: true, fields: {} } 

我认为这应该工作。

db.mycoll.find()。maxTimeMS(50)

TL; DR:

 MySet.find({ $query: { /*Query here*/ }, $maxTimeMS: 10000 }); 

你可以用这个查询来testing:

 MySet.find({ $query: {"$where": "sleep(100) || true"}, $maxTimeMS: 10000 }); 

为什么它的作品:

您可以使用查询修饰符

特别是这个: $ maxTimeMS

注意 :这个操作符在v3.2以后在mongo Shell中被弃用了

这是我开始使用很多的模式。

 // Default time out timeout in ms const DEFAULT_TIME_OUT = 500; // Default timeout message const DEFAULT_MESSAGE = 'Timeout fetching data(${DEFAULT_TIME_OUT}ms)'; // Removed angled single quotes // Function that triggers a Promise's reject after a set amount of time function timeoutReject(reject, message, timeout) { setTimeout(function(){ // Reject the Promise if the time is reached reject(message || DEFAULT_MESSAGE); }, timeout || DEFAULT_TIME_OUT); }; function youAreNotAuthentic() { // Logic to validate user and request return boolean }; // Throw error if the user cannot access this data function youCantTouchThis() { throw new Error('You cannot access this data.'); }; // Function to request data function getDataById(_id) { // First check if this is authentic if (youAreNotAuthentic()) youCantTouchThis(); // Return a Promise return new Promise((resolve, reject) => { // Set a timeout to reject if we do not get a response in x time timeoutReject(reject, 'Custom Message', 300); // Could look like this to just use the defaults // timeoutReject(reject); // Query for the data Collection.findOne({ _id }).then(data => { // Resolve the Promise with the retrieved data resolve(data); }); }); }; 

这样,我有一个默认的超时适用于大多数请求,但如果我需要调整每个呼叫的基础上,那么我可以。 或者我可以意识到需要更好索引的领域。

我终于搞定了。 首先,当套接字(即查询)超时时,防止服务器崩溃:

 //don't crash the server if a query times out mongoose.connection.on('error', function() {}); 

然后,每次我要查询数据库,我断开连接并重新连接到数据库,将socketTimeoutMS设置为10000:

 mongoose.disconnect(); mongoose.connect('mongodb://localhost/my_db', { server: {socketOptions: {socketTimeoutMS: 10000}} }); MySet.find({}, function(err, doc) {}); 

这恰好在执行10秒后切断查询。