async parallelLimit只运行一次限制次数

Question

我正在尝试使用async.paralleLimit来更新数据库中的记录。我需要分10批这样做，每次的总记录将是1000条。我正在努力理解如何在我的代码中使用这个asy.parallelLimit。我看了一些示例解释并尝试了一下，但它只运行了10次，在返回10个回复后，它不会再给我下一个回复。我试图通过执行过滤器来查询数据库，然后将记录发送到async.paralleLimit并获取所有这些记录的响应。现在我只是想了解平行极限及其工作原理。这是我的代码

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条记录，我想知道我做错了什么

Answer 1

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

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上运行代码来查看它的运行情况。这是我做的。