9

I am trying to send a file from my s3 bucket to the client with my NodeJS application. This is what I have so far:

import { S3 } from '@aws-sdk/client-s3';

const BUCKET_NAME = process.env.S3_BUCKET_NAME;

const s3 = new S3({
    region: 'ap-southeast-2',
    httpOptions: {
        connectTimeout: 2 * 1000,
        timeout: 60 * 1000,
    },
});

router.get('/download/:id', async (req, res) => {
    console.log('api: GET /download/:id');
    console.log('req.params.id: ', req.params.id);
    const result = await getRequiredInfo(req.params.id);
    if (typeof result !== 'number') {
        res.attachment(result.filename);
        await s3
            .getObject({
                Bucket: BUCKET_NAME,
                Key: result.location,
            })
            .createReadStream()
            .pipe(res);
    } else {
        res.sendStatus(result);
    }
});

And when I run this code, I receive this:

(node:11224) UnhandledPromiseRejectionWarning: TypeError: s3.getObject(...).createReadStream is not a function

I wondered around on SO and looks like others are working fine with the combination of getObject and createReadStream. Is there something I am missing at this point? How should I send a file as a stream in the response?

Terry Windwalker
  • 1,343
  • 2
  • 16
  • 36
  • https://github.com/aws/aws-sdk-js/issues/1436 – Rayon Aug 03 '21 at 05:00
  • @Rayon I don't think that one solves my Issue. For some reason the error comes up at the line with ".createReadStream()" while in that issue this function is still used. – Terry Windwalker Aug 03 '21 at 05:04
  • I guess, s3.getObject is returning an error, that may be the reason for the error createReadStream is not a function. Add an error handler and try again. – Jishnu Aug 03 '21 at 05:53
  • @Jishnu Thanks for noting that. Actually the getObject is working fine as it returns the file name, body, etc. The error only occurs after I added createReadStream(). Can you tell me how to add a handler on that one before the pipe(res)? – Terry Windwalker Aug 03 '21 at 10:32

2 Answers2

14

.createReadStream() is a method in aws-sdk v2. @aws-sdk/client-s3 is part of aws-sdk v3.

To get the stream from the v3 you'll need to do the following:

const response = await s3.getObject({
    Bucket: BUCKET_NAME,
    Key: key,
});

response.Body.pipe(res);

For more information about aws-sdk v3: https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-s3/

ZHENK
  • 156
  • 2
  • 5
  • https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-s3/classes/getobjectcommand.html – Muhad B K Dec 06 '21 at 15:44
  • 3
    this is does not work for me in client-s3 v^3.121. `response.Body` is of type `SdkStream | Blob | undefined> | undefined`. https://stackoverflow.com/questions/67366381/aws-s3-v3-javascript-sdk-stream-file-from-bucket-getobjectcommand/74699284#74699284 – Akshay Dec 06 '22 at 10:14
2

This is what worked for me

import { S3, GetObjectCommand } from "@aws-sdk/client-s3";
import { config } from 'dotenv';

// Load Environment Variable From a '.env' file
config();
const s3 = new S3( {
    region: process.env.S3_REGION,
    accessKeyId: process.env.AWS_ACCESS_KEY_ID,
    secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY,
});

const params = {
    Bucket: process.env.AWS_BUCKET_NAME,
    Key: key,
}
const command = new GetObjectCommand( params );
const response = await s3.send( command);

// More Logic Here

const stream = Readable.from( response.Body );