javascript - 从Scheduler填充Azure移动服务

我创建了这样的代码，以便从另一个网站的xml导出中获取新闻，而我试图用它填充我的数据库。

function UpdateLunchTime() {
    var httpRequest = require('request');
    var xml2js = require('xml2js');
    var parser = new xml2js.Parser();
    var url = 'http://www...com/export/xml/actualities';
    httpRequest.get({
            url: url
    }, function(err, response, body) {
        if (err) {
            console.warn(statusCodes.INTERNAL_SERVER_ERROR,
                'Some problem.');
        } else if (response.statusCode !== 200) {
            console.warn(statusCodes.BAD_REQUEST,
                'Another problem');
        } else {
            //console.log(body);
            parser.parseString(body, function (err2, result) {
                //console.log(result.Root.event);
                var count = 0;
                for (var i=0;i<result.Root.event.length;i++)
                {
                    //console.log(result.Root.event[i]);
                    InsertActionToDatabase(result.Root.event[i]);
                }
                /*
                result.Root.event.forEach(function(entry) {
                    InsertActionToDatabase(entry);
                });
                */
            });
        }
    });
}

function InsertActionToDatabase(action)
{
    var queryString = "INSERT INTO Action (title, description, ...) VALUES (?, ?, ...)";
    mssql.query(queryString, [action.akce[0], action.description[0],...], {
    success: function(insertResults) {
    },
      error: function(err) {
      console.log("Problem: " + err);
      }
    });
}

对于个别情况，它工作正常，但是当我在整个xml上运行时，出现此错误：

Error: [Microsoft][SQL Server Native Client 10.0][SQL Server]Resource ID : 1. The request limit for the database is 180 and has been reached. See 'http://go.microsoft.com/fwlink/?LinkId=267637' for assistance.

对于最后几个对象，我得到此错误：

Error: [Microsoft][SQL Server Native Client 10.0]TCP Provider: Only one usage of each socket address (protocol/network address/port) is normally permitted.

感谢帮助

最佳答案

问题是您试图在数据库中执行太多并发（插入）操作。请记住，在node.js中（几乎）一切都是异步的，因此当您为其中一项调用InsertActionToDatabase时，此操作将立即开始，而不必等到它完成返回。因此，您基本上是在尝试一次插入所有事件，并且如错误消息所言，对SQL Server进行的并发连接数受到限制。

您需要做的是更改循环以异步运行，方法是等待其中一个操作完成，然后再开始下一个操作（您也可以“分批”一次发送少量操作，在每次批处理完成后继续操作），但代码稍微复杂一些），如下所示。

var count = result.Root.event.length;
var insertAction = function(index) {
    if (index >= count) return;
    InsertActionToDatabase(result.Root.event[i], function() {
        insertAction(index + 1);
    });
}
insertAction(0);

完成后，InsertActionToDatabase函数将使用一个回调参数。

function InsertActionToDatabase(item, done) {
    var table = tables.getTable('event');
    table.insert(item, {
        success: function() {
            console.log('Inserted event: ', item);
            done();
        }
    });
}

关于javascript - 从Scheduler填充Azure移动服务，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/23021307/