NodeJS如何从aws s3存储桶下载文件到磁盘？

Question

我的目标：

显示一个对话框，提示用户保存从aws下载的文件。

我的问题：我目前使用的awssum - 亚马逊S3来创建一个下载流

。不过，我只设法将文件保存到我的服务器或流到命令行...正如你可以从我的代码看到我的最后一次尝试是尝试和手动设置失败的内容处置标题。我不能使用res.download（）作为标题已被设置？

我该如何实现目标？

我的节点代码：

app.post('/dls/:dlKey', function(req, res, next){ 
     // download the file via aws s3 here 
     var dlKey = req.param('dlKey'); 

     Dl.findOne({key:dlKey}, function(err, dl){ 
      if (err) return next(err); 
      var files = dl.dlFile; 

      var options = { 
       BucketName : 'xxxx', 
       ObjectName : files, 
      }; 

      s3.GetObject(options, { stream : true }, function(err, data) { 
       // stream this file to stdout 
       fmt.sep(); 
       data.Headers['Content-Disposition'] = 'attachment'; 
       console.log(data.Headers); 
       data.Stream.pipe(fs.createWriteStream('test.pdf')); 
       data.Stream.on('end', function() { 
        console.log('File Downloaded!'); 
       }); 
      }); 
     }); 

     res.end('Successful Download Post!'); 
    }); 

我对角码：

$scope.dlComplete = function (dl) { 
     $scope.procDownload = true; 
     $http({ 
      method: 'POST', 
      url: '/dls/' + dl.dlKey 
     }).success(function(data/*, status, headers, config*/) { 
      console.log(data); 
      $location.path('/#!/success'); 
     }).error(function(/*data, status, headers, config*/) { 
      console.log('File download failed!'); 
     }); 
    }; 

这段代码它的目的是让用户使用一个生成的密钥下载一个文件一次。

Answer 1

这是使用流媒体的最新版本，整个代码AWS-SDK

var express = require('express'); 
var app = express(); 
var fs = require('fs'); 

app.get('/', function(req, res, next){ 
    res.send('You did not say the magic word'); 
}); 


app.get('/s3Proxy', function(req, res, next){ 
    // download the file via aws s3 here 
    var fileKey = req.query['fileKey']; 

    console.log('Trying to download file', fileKey); 
    var AWS = require('aws-sdk'); 
    AWS.config.update(
     { 
     accessKeyId: "....", 
     secretAccessKey: "...", 
     region: 'ap-southeast-1' 
     } 
    ); 
    var s3 = new AWS.S3(); 
    var options = { 
     Bucket : '/bucket-url', 
     Key : fileKey, 
    }; 

    res.attachment(fileKey); 
    var fileStream = s3.getObject(options).createReadStream(); 
    fileStream.pipe(res); 
}); 

var server = app.listen(3000, function() { 
    var host = server.address().address; 
    var port = server.address().port; 
    console.log('S3 Proxy app listening at http://%s:%s', host, port); 
}); 

Answer 2

你已经想出了解决你的问题的最重要的部分：你可以将来自S3的文件流传输到任何可写的流，无论是文件流还是将被发送到客户端的响应流！

s3.GetObject(options, { stream : true }, function(err, data) { 
    res.attachment('test.pdf'); 
    data.Stream.pipe(res); 
}); 

注意使用res.attachment，将设置正确的头。您还可以查看有关流和S3的this answer。

Answer 3

此代码为我工作与最近的图书馆：

var s3 = new AWS.S3(); 
var s3Params = { 
    Bucket: 'your bucket', 
    Key: 'path/to/the/file.ext' 
}; 
s3.getObject(s3Params, function(err, res) { 
    if (err === null) { 
     res.attachment('file.ext'); // or whatever your logic needs 
     res.send(data.Body); 
    } else { 
     res.status(500).send(err); 
    } 
});