Блог

Я новичок в Node и MongoDB, и у меня есть, казалось бы, простой запрос. Мне удалось подключиться к моей базе данных и использовать запрос для получения желаемых результатов. Теперь я хочу, чтобы этот запрос продолжался бесконечно, поскольку конечной целью моего проекта является отображение данных в реальном времени.

Я бы подумал, что простого цикла ‘while (true)’ будет достаточно, но, похоже, это не так.

 const MongoClient = require('mongodb').MongoClient;

// Connection URL
const url = 'mongodb://<username>:<password>@ds157614.mlab.com:57614/flight_data';


// Use connect method to connect to the Server
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {

  if (err) throw err;

  var dbo = db.db("flight_data").collection("data");

while(true)
{

    dbo.find().sort({_id: 1}).limit(1).toArray(function(err, result) {

    if (err) throw err;

    console.log("Temperature: "   result[0].data.temperature);

  });

}

db.close();

});
 

Я обнаружил, что цикл while действительно запущен, но по какой-то причине запрос просто не выполняется внутри цикла while. Если вы удалите цикл while, код будет работать нормально. Я просто хочу, чтобы он постоянно печатал результаты повторяющегося запроса.

Непрерывный запрос к БД неэффективен и приводит к потере ресурсов, вместо этого используйте потоки изменений. Он отслеживает коллекцию на предмет любых изменений и только тогда вызовет db. Работает только для Mongo 3.6 .

 const MongoClient = require("mongodb").MongoClient;

// Connection URL
const url =
  "mongodb://<username>:<password>@ds157614.mlab.com:57614/flight_data";

// Use connect method to connect to the Server
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
  if (err) throw err;

  const collection = db.collection("data");
  const changeStream = collection.watch();
  changeStream.on("change", next => {
    // process next document
    collection
      .find()
      .sort({ _id: 1 })
      .limit(1)
      .toArray(function(err, result) {
        if (err) throw err;

        console.log("Temperature: "   result[0].data.temperature);
      });
  });
  db.close();
});