Come determinare il tipo di dati in S3.getObject()

Question

L'API node.js per S3 fornisce la seguente descrizione per i dati restituiti nella richiamata di getObject. Da http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/S3.html#getObject-property:

Corpo: (Buffer, Array tipizzato, Blob, String, ReadableStream) Dati oggetto.

È vero? Non c'è modo di controllare quale di queste cose sia?

Answer 1

Non so se è possibile controllare in anticipo il tipo di dati. Campo di dati fornito nel callback getObject(). Se tutto quello che vuoi fare è determinare se hai ricevuto un buffer, puoi provare il metodo di classe Node's Buffer.isBuffer (data.body).

In alternativa, si potrebbe desiderare di evitare il problema del tutto e utilizzare questo approccio da S3 documentation di Amazon:

var s3 = new AWS.S3(); 
var params = {Bucket: 'myBucket', Key: 'myImageFile.jpg'}; 
var file = require('fs').createWriteStream('/path/to/file.jpg'); 
s3.getObject(params).createReadStream().pipe(file); 

Presumendo che verrà usato questo codice in un ambiente tipico node.js asincrona richiamata, potrebbe avere più senso per vedere il codice in questo modo:

var fs = require('fs'); 

function downloadFile(key, localPath, callback) { 
    var s3 = new AWS.S3(); 
    var params = {Bucket: 'myBucket', Key: key}; 
    var file = fs.createWriteStream(localPath); 

    file.on('close') { 
    callback(); 
    } 

    file.on('error', function(err) { 
    callback(err); 
    }); 

    s3.getObject(params).createReadStream().pipe(file); 
} 

Answer 2

non riuscivo a trovare un modo per cambiare il tipo di corpo o, comunque dopo aver notato il corpo è stato un buffer, ho trasformato il buffer in un ReadableStream con questo pratico & bella semplice function: AWS.util.buffer.toStream (o forse potresti voler usare un'altra lib come streamifier).

Stavo cercando qualcosa su cui poter convalidare gli errori prima di fare qualsiasi altra cosa, nell'esempio di Amazon si traduce in "creare il flusso di scrittura solo se non ci fossero errori".

s3.getObject(params, function(err, data) { 
    if (err) { 
     console.log(err); 
     return; 
    } 

    var file = require('fs').createWriteStream(name); 
    var read = AWS.util.buffer.toStream(data.Body); 

    read.pipe(file); 
    read.on('data', function(chunk) { 
     console.log('got %d bytes of data', chunk.length); 
    }); 
});