Comment puis-je définir un délai d'attente sur une Mangouste requête?

Je suis à l'aide de la Mangouste avec une très grande base de données Mongo, et je veux coûteux requêtes comme MySet.find({}) de temps après 10 secondes.

J'ai essayé de fixer un délai d'attente du socket sur ma connexion, mais le serveur se bloque si le délai d'attente est dépassé:

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

J'ai essayé de passer le maxTimeMS option pour le trouver fonction, mais qui n'ont pas le moindre effet:

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

Des idées?

Êtes-vous à l'aide de MongoDB 2.6 ou supérieur?
mongo --version dit MongoDB shell version: 2.6.8.
Ressemble à de la Mangouste de soutien pour la maxTimeMS option a été ajouté en 3.8.13. Quel est votre Mangouste version?
La mangouste est à 3.8.24
MySet.find({}, {}, {maxTime: 10}, function(err, doc) {}) genre de travaux, mais seulement pour de petites valeurs de maxTime. Au début, je pensais que maxTime prend que quelques secondes ou peut-être dixièmes de seconde, mais la valeur 10 est-il temps de sortir pratiquement instantanément, et la valeur 100 en fait jamais.

OriginalL'auteur Alex Henrie | 2015-03-12

  1. 9

    Vous pouvez faire cela avec le Query#maxTime méthode qui n'est pas documenté dans la Mangouste lui-même, mais fait partie de la mquery bibliothèque Mangouste utilise pour ses fluent interface de requête.

    Donc dans votre cas, vous diriez que:

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

    Vous pouvez vérifier qu'elle est correctement réglage de la maxTimeMS option par l'activation de la Mangouste de débogage via mongoose.set('debug', true);, et ensuite vous pourrez voir la sortie de la console pour cette requête qui ressemble à:

    Mongoose: myset.find({}) { maxTimeMS: 10000, safe: true, fields: {} }
    savez-vous si cela peut être fait sur populate() ainsi? Comme ici: stackoverflow.com/questions/42398696/...
    Est-il une option pour ajouter cette maxTime globalement à toutes les requêtes sur?

    OriginalL'auteur JohnnyHK

  2. 0

    TL;DR:

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

    Vous pouvez tester avec cette requête :

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

    Pourquoi ça marche:

    Vous pouvez utiliser Requête modificateurs

    Et surtout celui-ci : $maxTimeMS

    Être prudent : cet opérateur est obsolète dans mongo Shell depuis la v3.2

    OriginalL'auteur Yoluk

  3. -2

    Je pense que cela devrait fonctionner.

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

    Le natif de MongoDB pilote, mais il ne fonctionne pas pour la Mangouste.

    OriginalL'auteur Kaushal

  4. -2

    C'est le modèle que j'ai commencé à utiliser beaucoup.

    //Default time out timeout in ms
const DEFAULT_TIME_OUT = 500;

//Default timeout message
const DEFAULT_MESSAGE = `Timeout fetching data(${DEFAULT_TIME_OUT}ms)`;

//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);
    });
  });
};

    De cette façon, j'ai un délai d'attente par défaut appliquée à la plupart des demandes, mais si j'ai besoin d'ajuster sur un appel alors que je peux. Ou j'ai peut être mis au courant de zones qui ont besoin d'une meilleure indexation.

    Certains ont proposé et approuvé le "seul angle de la citation" normal devis. Cela ne fonctionnera pas. Il est destiné à être basé sur un modèle de chaîne de caractères. ` est correcte pour ne pas '.

    OriginalL'auteur bcbrian

  5. -8

    J'ai enfin réussi à le faire fonctionner. J'ai d'abord empêcher le serveur à partir de la plante lors de la prise de courant (c'est à dire une requête) fois:

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

    Ensuite, chaque fois que je veux interroger la base de données, j'ai déconnecter et se reconnecter à la base de données, réglage socketTimeoutMS à 10000:

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

    Cette coupe de la requête après exactement 10 secondes d'exécution.

    Se déconnecter/reconnecter sur chaque requête serait coûteux droit?
    Les frais généraux que vous payez en se reconnectant sur chaque requête rend cette approche inutilisable pour tout, mais le plus simple des applications.

    OriginalL'auteur Alex Henrie