создать монитор работоспособности сайта в Node.js

Question

Я хочу создать монитор работоспособности, используя NodeJS и MongoDB. Я хочу запустить задание cron в NodeJS и сохранить данные в MongoDB. Если код статуса ответа сайта не равен 200, он будет сохранен в базе данных. Я хочу сделать запись в базе данных, как это,

url : http://www.google.com
status_code : 500
start_time :- start time
end_time :- end time

Я могу запустить задание cron, но не уверен, как сохранить время простоя в базе данных. Как, я не хочу хранить каждый ответ в базе данных. Только когда код состояния ответа отличен от 200, он начинает отслеживать (start_time) URL-адрес и сохраняет время возврата веб-сайта на 200 как end_time.

.

cron.js: -

var async=require('async');
const Entry = require('../models/health.model.js');

var https = require('https');
var request = require('request');

module.exports = function getHttpsRequests () {

    Entry.find({},function(err,entrys){
      console.log(err);
      if(!err && entrys){

         async.each(entrys,function(entry,callback){


           request(entry.url, function (error, response, body) {
            entry.statuscheck=response.statusCode;
            entry.save();
            callback();
            });


         },function (error) {

         });

      }
    });

}

health.model.js: -

const mongoose = require('mongoose');

const EntrySchema = mongoose.Schema({
    url: String,
    statuscheck: String
}, {
    timestamps: true
});

module.exports = mongoose.model('Entry', EntrySchema);

Answer 1

Я бы сделал что-то подобное для обновления базы данных. Я пошел дальше и добавил стандартные функции стрелок, потому что мне было проще. Я добавил несколько комментариев, которые должны прояснить большинство вопросов. Возможно, это не самое элегантное решение, потому что я написал его за 5 минут, но если вы будете следовать этому общему логическому потоку, вы должны быть намного ближе к своему решению (это совершенно непроверенное внимание.)

var async=require('async');
const Entry = require('../models/health.model.js');

var https = require('https');
var request = require('request');

module.exports = function getHttpsRequests () {
  Entry.find({}, (err,entrys) => {
    console.log(err);
    if (!err && entrys) {
      async.each(entrys, (entry,callback) => {
        request(entry.url, (error, response, body) => {
          //first check if the url has a document in the db.
          Entry.find({ url: entry.url }, (err, entry) => {
            if(!entry) {
              //since the document does not exist, check the statusCode.
              if(response.statusCode===200) { //if the statusCode is 200, continue the loop.
                callback();
              } else { //if the status code is not 200, lets save this to the db.
                console.log("Saving object: " + entry)
                entry.status_code = response.statusCode;
                entry.start_time = new Date();
                entry.save();
                callback();
              }
            } else if (entry) {
              //since the document exists, lets check the statusCode.
              if(response.statusCode===200) { //if the statusCode is 200, update the stop_time.
                entry.end_time = new Date();
                Entry.findOneAndUpdate({ url: entry.url }, entry, (err, object) => { //this returns the entry after update, so we can put that in the console for easy debug.
                  if (err) {
                    console.log(err);
                    callback();
                  } else {
                    console.log("Object saved: " + object);
                    callback();
                  }
                });
              }
            } else { //there was an error finding the document in the db, just go to the next one.
              callback();
          });
        });
      });
    }
  });
}