Как получить ответ от S3 getObject в Node.js?

Ответ 1

При выполнении getObject() из S3 API, за docs содержимое вашего файла находится в Body свойство, которое вы можете увидеть из своего образца. У вас должен быть код, который выглядит примерно так:

const aws = require('aws-sdk');
const s3 = new aws.S3(); // Pass in opts to S3 if necessary

var getParams = {
    Bucket: 'abc', // your bucket name,
    Key: 'abc.txt' // path to the object you're looking for
}

s3.getObject(getParams, function(err, data) {
    // Handle any error and exit
    if (err)
        return err;

  // No error happened
  // Convert Body from a Buffer to a String

  let objectData = data.Body.toString('utf-8'); // Use the encoding necessary
});

Вам может не понадобиться создавать новый буфер из объекта data.Body, но если вам нужно, вы можете использовать вышеприведенный образец для достижения этого.

Ответ 2

Основываясь на ответе @peteb, но используя Promises и Async/Await:

const AWS = require('aws-sdk');

const s3 = new AWS.S3();

async function getObject (bucket, objectKey) {
  try {
    const params = {
      Bucket: bucket,
      Key: objectKey 
    }

    const data = await s3.getObject(params).promise();

    return data.Body.toString('utf-8');
  } catch (e) {
    throw new Error('Could not retrieve file from S3: ${e.message}')
  }
}

// To retrieve you need to use 'await getObject()' or 'getObject().then()'
getObject('my-bucket', 'path/to/the/object.txt').then(...);

Ответ 3

В качестве альтернативы вы можете использовать клиентскую библиотеку minio-js get-object.js

var Minio = require('minio')

var s3Client = new Minio({
  endPoint: 's3.amazonaws.com',
  accessKey: 'YOUR-ACCESSKEYID',
  secretKey: 'YOUR-SECRETACCESSKEY'
})

var size = 0
// Get a full object.
s3Client.getObject('my-bucketname', 'my-objectname', function(e, dataStream) {
  if (e) {
    return console.log(e)
  }
  dataStream.on('data', function(chunk) {
    size += chunk.length
  })
  dataStream.on('end', function() {
    console.log("End. Total size = " + size)
  })
  dataStream.on('error', function(e) {
    console.log(e)
  })
})

Отказ от ответственности: я работаю для Minio С открытым исходным кодом, S3-совместимым хранилищем объектов, написанным на golang с клиентскими библиотеками, доступными на Java, Python, Js, golang.

Ответ 4

На первый взгляд это выглядит не так, как будто вы делаете что-то не так, но вы не показываете весь свой код. Следующее работало для меня, когда я впервые проверил S3 и Node:

var AWS = require('aws-sdk');

if (typeof process.env.API_KEY == 'undefined') {
    var config = require('./config.json');
    for (var key in config) {
        if (config.hasOwnProperty(key)) process.env[key] = config[key];
    }
}

var s3 = new AWS.S3({accessKeyId: process.env.AWS_ID, secretAccessKey:process.env.AWS_KEY});
var objectPath = process.env.AWS_S3_FOLDER +'/test.xml';
s3.putObject({
    Bucket: process.env.AWS_S3_BUCKET, 
    Key: objectPath,
    Body: "<rss><data>hello Fred</data></rss>",
    ACL:'public-read'
}, function(err, data){
    if (err) console.log(err, err.stack); // an error occurred
    else {
        console.log(data);           // successful response
        s3.getObject({
            Bucket: process.env.AWS_S3_BUCKET, 
            Key: objectPath
        }, function(err, data){
            console.log(data.Body.toString());
        });
    }
});

Ответ 5

Возможно, этот пример может помочь кому-то, кому нужно вернуть файл, если он существует, или ответ JSON в случае, если нам нужно доставить JSON, когда имя сегмента или файл:

  // Assuming you already connected to AWS SDK and S3 

  var bucketParams = {
      Bucket: MyBucketName, //if variable or dynamically created otherwise string
      Key: myKey //if variable or dynamically created otherwise string
  };

  s3.getObject(bucketParams, function(err, data) {
        if (err) {
        //this will check connection and file / bucket existance
          console.log(err);
          return res.json({
            success: false,
            error: err
          });
        } else {
          res.attachment(key);
          s3.getObject(bucketParams)
            .createReadStream()
            .pipe(res);
        }
      });

Ответ 6

Для тех, кто ищет NEST JS TYPESCRIPT версию выше:

    /**
     * to fetch a signed URL of a file
     * @param key key of the file to be fetched
     * @param bucket name of the bucket containing the file
     */
    public getFileUrl(key: string, bucket?: string): Promise<string> {
        var scopeBucket: string = bucket ? bucket : this.defaultBucket;
        var params: any = {
            Bucket: scopeBucket,
            Key: key,
            Expires: signatureTimeout  // const value: 30
        };
        return this.account.getSignedUrlPromise(getSignedUrlObject, params);
    }

    /**
     * to get the downloadable file buffer of the file
     * @param key key of the file to be fetched
     * @param bucket name of the bucket containing the file
     */
    public async getFileBuffer(key: string, bucket?: string): Promise<Buffer> {
        var scopeBucket: string = bucket ? bucket : this.defaultBucket;
        var params: GetObjectRequest = {
            Bucket: scopeBucket,
            Key: key
        };
        var fileObject: GetObjectOutput = await this.account.getObject(params).promise();
        return Buffer.from(fileObject.Body.toString());
    }

    /**
     * to upload a file stream onto AWS S3
     * @param stream file buffer to be uploaded
     * @param key key of the file to be uploaded
     * @param bucket name of the bucket 
     */
    public async saveFile(file: Buffer, key: string, bucket?: string): Promise<any> {
        var scopeBucket: string = bucket ? bucket : this.defaultBucket;
        var params: any = {
            Body: file,
            Bucket: scopeBucket,
            Key: key,
            ACL: 'private'
        };
        var uploaded: any = await this.account.upload(params).promise();
        if (uploaded && uploaded.Location && uploaded.Bucket === scopeBucket && uploaded.Key === key)
            return uploaded;
        else {
            throw new HttpException("Error occurred while uploading a file stream", HttpStatus.BAD_REQUEST);
        }
    }