asyncjs 回调未被执行

Question

我正在尝试合并来自两个 JSON 文件（客户列表）的数据，然后创建与客户一样多的任务，稍后通过 [=27= 执行]

为了让所有任务数组都满，我用一个承诺控制了 forEach 的结尾：

var parsePromise = new Promise(function (resolve, reject) {
mongoDB.MongoClient.connect(dbURL, (error, db) => {
        originalData.forEach(function (element, index) {
            var restoredCustomer = Object.assign(element, backupData[index]);

            tasksArray.push((function (db, element) {
                return function () {
                    db.collection('customers').insert(element, function (error) {
                        if (error) {
                            console.error("Error: ", error);
                        }
                    })
                }
            })(db, restoredCustomer));

            forEachCounter--;
            if (forEachCounter === 0) {
                resolve(tasksArray);
            }
        });
    });
});

然后，当 promise 结束时，我执行 async.js parallel 方法：

parsePromise.then(function (tasksArray) {
    async.parallel(tasksArray, (err, results) => {
        console.log("Operation completed successfully: ", results);
    })
})

奇怪的是代码运行良好，插入在 MongoDB 上完成，但是，放置在 parallel 回调中的 console.log("Operation completed successfully: ", results); 从未显示。

Answer 1

试试这个

var parsePromise = new Promise(function (resolve, reject) {
mongoDB.MongoClient.connect(dbURL, (error, db) => {
        originalData.forEach(function (element, index) {
            var restoredCustomer = Object.assign(element, backupData[index]);
             tasksArray.push(function(cb){
                  db.collection('customers').insert(restoredCustomer, function (error) {
                        if (error) return cb(err);
                        cb();
                    })
             });

            forEachCounter--;
            if (forEachCounter === 0) {
                resolve(tasksArray);
            }
        });
    });
});

根据异步 js 文档 https://caolan.github.io/async/global.html async.js 中的并行函数中的任务参数必须是 AsyncFunction。 AsyncFunction 需要有最后一个参数，它是一个回调。回调的结构遵循function(err, args)的标准。

您也可以尝试将代码简化为：

new Promise((resolve, reject) => {
  mongoDB.MongoClient.connect(dbURL, (error, db) => {
        if (error) return reject(error);
        resolve(db);
  });
}).then(db => {
  var tasksArray = [];
  for (let i = 0; i != originalData.length; ++i){
    var restoredCustomer = Object.assign(originalData[i], backupData[index]);
    tasksArray.push(function(cb){
      db.collection('customers').insert(restoredCustomer, function (error) {
        if (error) return cb(err);
        cb();
      })
    });
  }

  return new Promise((resolve, reject) => {
    async.parallel(tasksArray, (err, results) => {
        if (err) return reject(err);
        resolve(results)
    })
  })
})

asyncjs 回调未被执行

asyncjs callback not being executed

javascript

node.js

mongodb

closures

async.js