Laden Sie die Datei von der URL herunter und laden Sie sie ohne Speichern auf AWS S3 hoch - node.js

Question

Ich schreibe eine Anwendung, die Bilder von einer URL herunterlädt und sie dann mithilfe der aws-sdk in einen S3-Bucket hochlädt.

Ich habe gerade Bilder heruntergeladen und auf diese Weise gespeichert.

request.head(url, function(err, res, body){ 

    request(url).pipe(fs.createWriteStream(image_path)); 

}); 

Und dann die Bilder auf AWS S3 hochladen wie diese

fs.readFile(image_path, function(err, data){ 
    s3.client.putObject({ 
     Bucket: 'myBucket', 
     Key: image_path, 
     Body: data 
     ACL:'public-read' 
    }, function(err, resp) { 
     if(err){ 
      console.log("error in s3 put object cb"); 
     } else { 
      console.log(resp); 
      console.log("successfully added image to s3"); 
     } 
    }); 
}); 

Aber ich möchte das Teil überspringen, wo ich das Bild auf der Festplatte speichern. Gibt es eine Möglichkeit die pipe Antwort von request(url) auf eine Variable zu übertragen und diese dann hochzuladen?

Answer 1

Hier einige Javascript, dass dies gut funktioniert:

var options = { 
     uri: uri, 
     encoding: null 
    }; 
    request(options, function(error, response, body) { 
     if (error || response.statusCode !== 200) { 
      console.log("failed to get image"); 
      console.log(error); 
     } else { 
      s3.putObject({ 
       Body: body, 
       Key: path, 
       Bucket: 'bucket_name' 
      }, function(error, data) { 
       if (error) { 
        console.log("error downloading image to s3"); 
       } else { 
        console.log("success uploading to s3"); 
       } 
      }); 
     } 
    }); 

Answer 2

Das ist, was ich tat und funktioniert gut:

const request = require('request-promise') 
 
const AWS = require('aws-sdk') 
 
const s3 = new AWS.S3() 
 

 
const options = { 
 
    uri: uri, 
 
    encoding: null 
 
}; 
 

 
async load() { 
 

 
    const body = await request(options) 
 
    
 
    const uploadResult = await s3.upload({ 
 
    Bucket: 'bucket_name', 
 
    Key : path, 
 
    Body : body, 
 
    }).promise() 
 
    
 
}