Mongoose 回调无法使用 Forever

Question

我正在尝试使用 Forever 运行一个后台进程，该进程每小时将来自外部服务的数据添加到我的 mongodb 数据库中（我是 node 新手，不知道如何执行此操作）。我正在使用带有 Express 的 Node 并使用

运行永远的任务

forever -o out.log -e err.log start background/collector.js

所以我从这个过程中得到了一些反馈。代码如下：

var request = require('request');
var mongoose = require('mongoose');
var Model = require('../models/Model.js');

// Starting the collector process
addNewData();

function addNewData() {
    request('external_service_url', function (error, response, body) {
        if (!error && response.statusCode == 200) {
            var models = JSON.parse(body);

            console.log('Adding the new models...')
            for(var i = 0; i < models.length; i++)
            {
                console.log(i);

                Model.create(models[i], function (error, post, result) {
                    console.log('Test');
                    if (error) console.log('Something went wrong adding the document!');
                    if ( ! result.updatedExisting)
                    {
                        console.log('A new document has been added!');
                    }
                });
            }

            console.log('Models added: ' + models.length);

            // Every hour we will collect new data

            console.log('Waiting for an hour...');
            setTimeout(addNewData, 36000000);
        }
    })
}   

我不知道为什么，但似乎 .create() 回调不起作用，放置在 create 回调中的 console.logs 没有在日志中显示任何内容。 Forever 不适用于猫鼬？你有什么想法吗？

Answer 1

好吧，事情就是这样。您从未将猫鼬适配器“连接”到数据库。只需添加：

mongoose.connect('mongodb://myhost/mydatabase');

在您尝试做任何其他事情之前，请先到达顶部附近。它不一定按这个顺序“连接”，但猫鼬方法会解决这个问题。 “异步编程”，请继续阅读。

此外，您不应该像这样循环，因为您没有等待“回调”（它不是闭包，而是回调）来完成或以其他方式“限制”连接，这可能会导致问题。

改用"async" 之类的东西来处理这个问题。在此示例中，.eachLimit() 是为了将并行操作的数量限制在合理的水平：

async.eachLimit(models,10,function(el,callback) {
    Model.create(models[i], function (error, result) {
        // do something maybe but call
        callback(err);   // to signal it is done
    });
},function(err) {
    // comes here on completion or error
});

请记住，“异步”代码需要在“回调”或“承诺”上执行，以便在事情完成时发出信号。在“同步”编程中取消行，其中下一行仅在前几行代码完成时执行。

否则，您的“for”循环只会“将所有内容发送”到服务器，并且在继续执行之前不会等待完成。

但这里的主要问题是连接。但是你仍然应该修复其余部分，如图所示。