将文件管道传输到Sails中的多个源（船长）

Question

我目前正在将文件中的文件以skipper格式上传到skipper-s3，但是我想保存该文件的多个调整大小的副本。 有没有办法克隆文件流？ 我找到了此解决方案，但找不到生成文件流的方法。 也许有一种可行的方法。 无论如何，这是上传的代码：

  processUpload: function (req, res) {

    var type = req.param('type');
    if (type !== 'thumbnail' && type !== 'image' || typeof req.file('file')._files[0] == 'undefined') return res.badRequest();

    var dir = 'news/'+type+'/',
      filename = moment().unix() + '_' + req.file('file')._files[0].stream.filename,
      filetype = req.file('file')._files[0].stream.headers['content-type']
      filesize = req.file('file')._files[0].stream.byteCount;

    // Lowercase and convert spaces to hyphens
    filename = filename.toLowerCase()
             .replace(/ +/g,'-');

    if (filetype != 'image/jpeg' && filetype != 'image/png' && filetype != 'image/gif') return res.badRequest('File must be a JPG, GIF, or PNG');
    if (filesize > 2000000) return res.badRequest('File cannot exceed 2MB');

    var fs = require('fs')
      , gm = require('gm');

    var resizeStream = req.file('file')._files[0].stream;
    var bs = gm(resizeStream, 'img.jpg')
    .resize(100,100)
    .write('resize.jpg', function (err) { });


    req.file('file').upload({
      adapter: require('skipper-s3'),
      key: 'Axx',
      secret: 'xx',
      bucket: 'xx6',
      saveAs: dir+filename,
      headers: {
        'x-amz-acl': 'public-read'
      }
    }, function (err, filesUploaded) {
      if (err) return res.negotiate(err);

      return res.ok({
        trigger: 'article-'+type+'-uploaded',
        fileUploaded: filename,
        previewURL: 'https://s3.amazonaws.com/sdf/'+dir+filename,
      });
    });

  }

这在我调整大小并保存图像后不起作用，.upload功能不再可用。 如果您知道克隆流或解决此问题的好方法，请告诉我。 感谢您检查我的问题。

Answer 1

很奇怪，这就是我最终开始工作的原因，但是我在第一次上传时使用了skipper-s3模块，在随后的上传中使用了aws-sdk，因为它们肯定依赖于要复制的第一个。 这似乎不是一个理想的解决方案，但是对我来说，它可以将一个文件流式传输到多个缓冲流，通过gm调整它们的大小并将大小上传到s3。

var fs = require('fs')
, gm = require('gm');

req.file('file').upload({
  adapter: require('skipper-s3'),
  key: 'Asdf234',
  secret: 'hehe',
  bucket: 'xd',
  function (file, cb) {
            if (allowedTypes.indexOf(file.headers['content-type']) === -1) return false;

            var extension = file.filename.split('.').pop();
            var clean = file.filename.toLowerCase()
                                .replace(/ +/g,'-');
            filename = moment().unix() + '_' + clean + '.' + extension;

            cb(null, dir+filename);
        },
  headers: {
    'x-amz-acl': 'public-read'
  }
}, function (err, filesUploaded) {
  if (err) return res.negotiate(err);


        var request = require('request');
        var AWS = require('aws-sdk');
        AWS.config.region = 'us-east-1';

        var s3obj = new AWS.S3({params: {Bucket: 'xd'}});

        gm(request(filesUploaded[0]['extra']['Location']),"/tmp/orig.jpg")
        .resize('750', '375')
        .stream(function (err, stdout, stderr) {

            var buf = new Buffer('');

            stdout.on('data',function(data) {
                buf = Buffer.concat([buf,data]);
            });

            stdout.on('end',function(data) {
                var params = {
                ACL: 'public-read',
                  Key: 'news/1/'+filename,
                  Body: buf};

                    s3obj.upload(params, function(err, data) {
                if (err) {
                  sails.log.debug("Error uploading data: ", err);
                } else {
                  sails.log.debug("Successfully uploaded data to myBucket/myKey");
                }
              });
            });
        });