Async.waterfall 函数在保存解析对象后退出

我相信你只需要在updateVenue中调用next并保存Scence。 async.waterfall 将回调传递给系列中的每个函数，您当前正在使用 next 。 如果需要将数据传递给下一个 fn，请将其作为第二个参数传递给回调。

以下是如何在updateVenue中应用的示例：

   function updateVenue(next) {
       return venueObj.save(null, {
           success: function(response){
               console.log('Updated Venue thumbnail succesfully: ',    response);
               return next(null, response);
           },
           error: function(response, error){
               console.log('Failed to update Venue thumbnail, with error code: ' + error.description);
               return next(error);
           }
       }); // end of venueObj.save
   },...

希望对您有所帮助！

我找到了解决这个问题的方法。不幸的是，我无法将函数分开，但是，我能够将第二个函数嵌入到第一个函数的完成块中：

// Download the image from S3, transform, and upload to a different S3 bucket.
        async.waterfall([
            function download(next) {
                // Download the image from S3 into a buffer.
                s3.getObject({
                        Bucket: srcBucket,
                        Key: srcKey
                    },
                    next);
                },
            function transform(response, next) {
                gm(response.Body).size(function(err, size) {
                    // Infer the scaling factor to avoid stretching the image unnaturally.
                    WIDTH = size.width;
                    HEIGHT = size.height;

                    if (WIDTH > HEIGHT) {
                        var side = HEIGHT;
                    }
                    else{
                        var side = WIDTH;
                    }
                    var scalingFactor = Math.min(
                                    MAX_WIDTH / side,
                                    MAX_HEIGHT / side
                                );
                                var width  = scalingFactor * side;
                                var height = scalingFactor * side;
                    // Transform the image buffer in memory.
                    this.gravity("Center").crop(side, side).resize(width, height)
                        .toBuffer(imageType, function(err, buffer) {
                            if (err) {
                                next(err); 
                                console.log(err);
                            } else {
                                next(null, response.ContentType, buffer);
                            }
                        });

                });
            },
            function upload(contentType, data, next) {
                // Stream the transformed image to a different S3 bucket.
                s3.putObject({
                        Bucket: dstBucket,
                        Key: dstKey,
                        Body: data,
                        ContentType: contentType
                    },
                    next);
            },
            function updateVenue(next) {
                venueObj.save(null, {
                  success: function(response){
                    console.log('Updated Venue thumbnail succesfully: ', response);
                    sceneObj.save(null, {
                      success: function(response){
                        console.log('Saved sceneObj succesfully: ', response);
                        context.succeed();
                        next
                      },
                      error: function(response, error){
                          console.log('Failed to create new sceneObj, with error code: ' + error.description);
                          context.fail();
                          next 
                      }
                    }); // end of sceneObj.save
                  },
                  error: function(response, error){
                      console.log('Failed to update Venue thumbnail, with error code: ' + error.description);
                      context.fail();
                      next
                  }
                }); // end of venueObj.save
            }
            ], function (err) {
                if (err) {
                    console.error(
                        'Unable to resize ' + srcBucket + '/' + srcKey +
                        ' and upload to ' + dstBucket + '/' + dstKey +
                        ' due to an error: ' + err
                    );
                } else {
                    console.log(
                        'Successfully resized ' + srcBucket + '/' + srcKey +
                        ' and uploaded to ' + dstBucket + '/' + dstKey
                    );
                }
                callback(null, "message");
            }

        );