使用 express js 同步将大文件上传到 AWS s3

Question

目前我正在使用 putObject 通过 REST api 调用将大文件上传到 AWS s3。

 var params ={               
     Bucket:'lambdacushbu',    
     Key:req.files.image.name, 
     Body:req.files.image.data 
 }                             
  s3.putObject(params,function(err, data) {                      
      if (err) console.log(err, err.stack); // an error occurred      
      else     {                                                      
          console.timeEnd('Uploadtime');                              
          console.log("uploaded",data);                               
          res.json({                                                  
              'status':'Uploaded',                                    
              'url':data.Location                                     
          });                                                         
      }           // successful response                              
  });                                         

但它看起来像异步我希望上述同步模式也发生超时，但文件正在上传到 AWS s3。

那么我怎样才能增加超时值呢？尝试使用connect-timeout 包

app.use(timeout('600000'));

但是没有用

Answer 1

尝试使用upload 函数而不是putObject。这应该可以解决您的超时问题。

这是该函数的文档：http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/S3.html#upload-property

同步调用肯定会降低应用的性能。您能否提供有关您的问题的更多详细信息，以便我们找到异步解决方案？

编辑： 以下是您应该如何在控制器中返回响应：

router.post('/your-route',
  //additional middlewares
  function(req, res, next) {
     var params = {               
      Bucket:'lambdacushbu',    
      Key:req.files.image.name, 
      Body:req.files.image.data 
      }                             
      s3.upload(params,function(err, data) {                      
        if (err) { res.json(err); }      
        else {                                                        
           res.json({                                                  
          'status':'Uploaded',                                    
          'url':data.Location                                     
       }
      });                                             
  }
);

并确保您不要在此路线的其他任何地方致电 res.json() 或 res.send()