Knoten js, Rohrleitung pdfkit zu einem Speicherstream

Question

Ich benutze pdfkit (https://github.com/devongovett/pdfkit) auf meinem Knoten-Server, in der Regel erstellen PDF-Dateien, und dann auf s3 hochladen. Das Problem ist, dass pdfkit Beispiele Pipe doc in einen Knoten schreiben Stream, der die Datei auf die Festplatte schreibt, folgte ich dem Beispiel und funktionierte korrekt, aber meine Anforderung ist jetzt, die PDF-Dokument zu einem Speicher-Stream statt speichern es auf der Festplatte (ich lade sowieso auf s3 hoch). Ich habe einige Node-Speicher-Streams-Prozeduren gefolgt, aber keiner von ihnen scheint mit PDF-Pipe mit mir zu arbeiten, ich könnte nur Strings in Speicher-Streams schreiben. Also meine Frage ist: Wie die PDF-Kit-Ausgabe zu einem Speicher-Stream (oder etwas Ähnliches) pipes und dann lesen Sie es als ein Objekt auf s3 hochladen?

var fsStream = fs.createWriteStream(outputPath + fileName); 
 
doc.pipe(fsStream);

Vielen Dank im Voraus.

Answer 1

Es gibt keine Notwendigkeit, einen Zwischenspeicher Strom – gerade Rohr des PDFKit Ausgangsstrom in einen HTTP-Sendedatenstrom direkt zu verwenden.

Meiner Erfahrung nach ist das AWS SDK Müll, wenn es um die Arbeit mit Streams geht, also verwende ich normalerweise request.

var upload = request({ 
    method: 'PUT', 
    url: 'https://bucket.s3.amazonaws.com/doc.pdf', 
    aws: { bucket: 'bucket', key: ..., secret: ... } 
}); 

doc.pipe(upload); 

^{1 - in der Tat ist es in der Regel unerwünscht, einen Speicherstrom zu verwenden, weil das bedeutet, dass die ganze Sache in RAM Pufferung, das ist genau das, was Strom vermeiden soll!}

Answer 2

Sie könnten so etwas versuchen und laden Sie es auf S3 innerhalb der end Veranstaltung.

var doc = new pdfkit(); 

var MemoryStream = require('memorystream'); 
var memStream = new MemoryStream(null, { 
    readable : false 
}); 

doc.pipe(memStream); 

doc.on('end', function() { 
    var buffer = Buffer.concat(memStream.queue); 
    awsservice.putS3Object(buffer, fileName, fileType, folder).then(function() { }, reject); 
})