AWS S3 STREAM

index.js

// IMPORT DEPENDENCIES

const stream = require("stream")
const AWS = require('aws-sdk');
const fs = require('fs');
const s3 = new AWS.S3();

// DOWNLOAD STREAM EXAMPLE

const s3download = (bucketName, keyName, localDest) => {

    if (typeof localDest == 'undefined') {
        localDest = keyName;
    }

    let params = {
        Bucket: bucketName,
        Key: keyName
    };

    let file = fs.createWriteStream(localDest);

    return new Promise((resolve, reject) => {
        s3.getObject(params).createReadStream()
        .on('end', () => {
            return resolve();
        })
        .on('error', (error) => {
            return reject(error);
        }).pipe(file);
    });
};


// UPLOAD STREAM EXAMPLE

const s3upload = (bucketName, keyName) => {
  var pass = new stream.PassThrough();
  var params = {Bucket: bucketName, Key: keyName, Body: pass};
  s3.upload(params, function(err, data) {
    console.log(err, data);
  });
  return pass;
}

inputStream.pipe(s3upload(s3));