node.js:将一个异步函数列表应用于列表列表中的每一项

node.js: apply a list of async functions to each item of a list of lists

本文关键字：列表 应用于 一项 一个 js 异步 node 函数      更新时间：2023-09-26

我有一个人员列表，每个人都包含一个图像URL列表
我需要下载每个url，然后为该图像计算一个"签名"，验证它是否唯一，然后将其保存到文件系统中
我目前的方法是：两个嵌套的async.each调用，一个async.waterfall用于检查和保存图像（为了简单起见，省略了错误处理）：var async=require（'async'）；var request=require（'request'）；

var syncPersonsImages = function(persons, images, callback) {
  async.each(
    persons,
    function(person, callbackPerson) {
      async.each(
        person.imageUrls,
        function(imageUrl, callbackImage) {
          download(imageUrl, function(err, image) {
            downloadPost(callbackImage);
          });
        },
        function(err) {
          callbackPerson();
        }
      );
    },
    function(err) {
      callback(null, persons);
    }
  );
  function download() {
    request(
      { uri: image.url },
      function(err) {
        callback(err, image);
      },
      function(contents, res) {
        image.contents = res.contents;
        callback(null, image);
      }
    );
  }
  function downloadPost(image, callback) {
    async.waterfall(
      [
        getSignatureFromImage,
        findSimilarSignatureImage,
        saveImage,
      ],
      function (err, image) {
        callback(image);
      }
    );
  }
  function getSignatureFromImage(image, callback) {
    image.signature = crypto.createHash('md5').update(image.url).digest('hex');
    callback(null, image);
  }
  function findSimilarSignatureImage(image, callback) {
    if (existsAlready(image.signature)) { // this function is not shown but it's behaviour is clear...
      image.isNew = true;
    }
    callback(null);
  }
  function save(image, callback) {
    if (image.isNew) {
      img.save(function(err) {
        console.log('image', image.url, 'saved');
        callback(null, image);
      }
    } else {
      callback(null, null);
    }   
  }
};

问题是syncPersonsImages方法永远不会终止
有什么建议吗
我的方法至少在理论上是正确的吗？

总的来说，我认为这种方法是合理的。有几点。我认为你不必要地结束了一些回电话。例如：

  function(person, callbackPerson) {
    async.each(
      person.imageUrls,
      function(imageUrl, callbackImage) {
        download(imageUrl, function(err, image) {
          downloadPost(callbackImage);
        });
      },
      function(err) {
        callbackPerson();
      }
    );
  },
  function(err) {
    callback(null, persons);
  }
);

可以更改为：

function(person, callbackPerson) {
  async.each(
    person.imageUrls,
    function(imageUrl, callbackImage) {
      download(imageUrl, function(err, image) {
        downloadPost(callbackImage);
      });
    }, callbackPerson);
}, callback);

这取决于您是否希望async.each调用在第一次出现错误时保释。

此外，您定义了不带参数的下载方法。

相关文章：