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, который установит правильные заголовки. Вы также можете посмотреть this answer относительно потоков и S3.

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); 
    } 
});