如何在Parse Cloud Code中保存批量数据？

Question

在我的云代码中,我想用新数据更新我的所有记录,大约是50k.但我注意到即使我遵循1000条记录限制,我的工作仍然失败.我得到成功/错误没有被称为错误的这项工作.任何想法如何解决这个问题？

Parse.Cloud.job("hello", function(request, response) {
Parse.Cloud.useMasterKey();  
var results = [];
var limit = 1000;

var saveUpdatedQueries = function(queries) {
    console.log("updating records " + queries.length);

    Parse.Object.saveAll(queries,{
        success:function(lists){
        console.log("lists ok "+lists.length);

        if (!results.length) {
            response.success("finished");
            return;
        }

        updatingRecords(lists.length);

        },error: function(reason){
            console.log("error");
        }
    });
}

var updatingRecords = function(skip) {
    var tempRecords = [];

    if (skip) {
        results = results.slice(skip);
    }

    console.log("skip: " + skip + " Results length: "+ results.length);

    for (var i = 0; i < results.length; i++) {
        var today = new Date();
        var newObject = results[i];
        newObject.set('newCulumn', today);
        tempRecords.push(newObject);

        if (i === results.length - 1 || tempRecords.length === limit) {
            break;
        };
    };

    saveUpdatedQueries(tempRecords);
}

var processCallback = function(res) {
    results = results.concat(res);
    if (res.length === limit) {
        process(res[res.length - 1].id);
        return;
    }

    updatingRecords(0);
}

var process = function(skip) {
    var query = new Parse.Query(Parse.Installation);

    if (skip) {
        query.greaterThan("objectId", skip);
    }

    query.limit(limit);
    query.ascending("objectId");
    query.find().then(function querySuccess(res) {
    processCallback(res);

    }, function queryFailed(reason) {
        if (reason.code == 155 || reason.code == 141) { // exceeded parse timout
            console.log("time out error");
            process(skip);
        } else {
            response.error("query unsuccessful, length of result " + results.length + ", error:" + reason.code + " " + reason.message);
        }
    });
}

process(false);

});

Answer 1

解决方法：您可以分批安排 cron 作业，记录数量可以接受，但受您拥有的托管服务限制。例如，如果您每分钟只能处理 10 个请求，那么您将首先请求所有需要更新的 ID，然后将它们拆分成服务器在时限内接受并处理的块。这只是一个解决方法。

长期：更好的解决方案是将您的应用程序设计为从服务器请求尽可能少的数据，而不是强迫服务器完成所有繁重的工作。这还允许您的业务逻辑通过方便的公共 API 公开，而不是作为服务器上的隐藏进程。