异步parallelLimit仅运行一次限制时间

如何解决异步parallelLimit仅运行一次限制时间

我试图利用async.parallelLimit更新数据库中的记录。我需要以10为批次进行此操作，每次总记录为1000。我试图了解如何在我的代码中使用此asyn.parallelLimit。我看了一些解释示例，并尝试了它，但是它仅运行10次，并且在给出10个响应之后却没有给出下一个响应。我试图通过执行过滤器来查询数据库，然后将记录发送到async.parallelLimit并获取所有这些记录的响应。现在，我只是想了解parallelLimit及其工作原理。这是我的代码

const async = require("async");

module.exports = async (server) => {
  async function data(server) {
    return await resolveData(server);
  }

  function resolveData(server) {
    return new Promise((resolve) => {
      let parcel = server.models["Parcel"].find({
        order: "createdAt ASC",include: [
          {
            relation: "parcelStatuses",},{
            relation: "customerData",scope: {
              fields: ["firstName","lastName","cityId","customerId"],],limit: 1000,skip: 200,});
      resolve(parcel);
    });
  }
  // console.log(await data(server));
  var parcelData = await data(server);

  for (var i = 1; i <= parcelData.length; i++) {
    parcelData[i - 1] = (function (i) {
      return function () {
        console.log(i);
      };
    })(parcelData[i]);
  }

  async.parallelLimit(parcelData,10,function (err,results) {
    if (results) {
      console.log("This is resilt",results);
    } else {
      console.log(err);
    }
  });
};

我需要我的parallelLimit函数只向我返回查询获取的记录。稍后我将运行更新命令。自从它返回我以来，只有10条记录，我想知道我在做什么错

解决方法

我不确定for loop应该做什么。我猜您正在尝试为parcelData的每个元素创建函数。一个简单的方法就是在map之上parcelData并返回一个异步函数：

let async = require("async");

// Your data is here but I used a dummy array with 100 elements
let parcelData = Array(100).fill(0).map((_,i) => i);

// Just a dummy function to wait
function delay(ms) {
    return new Promise(r => setTimeout(r,ms));
}

// map over array and return an `async` function;
let tasks = parcelData.map(p => {
  return async () => {
    await delay(1000);
    console.log(p);
  }
});

// Finally execute the tasks
async.parallelLimit(tasks,10,(err,result) => {
    if (err) console.error('error: ',err)
    else console.log('done');
});

您可以在repl.it上运行代码以查看其运行情况。这是我做的one。