nodejs 将 pdf 上传到 S3 存储桶损坏的文件

Question

我目前正在使用 aws-sdk 将 pdf 文件上传到存储桶 S3，如下所示：

function uploadFile (filePath, remoteFilename, cb) {
    var fileBuffer = fs.createReadStream(filePath); // ex.: 'temp/longFileName.pdf'
    fileBuffer.on('error', function(err) {
        logger.warn('Failed reading local pdf file');
        cb(err);
    });
    s3.upload({
        Bucket: 'someBucketName',
        Key: remoteFilename,
        Body: fileBuffer
    }, function (error, response) {
        cb(error, { response, remoteFilename });
    });
}

问题是有时上传的文件大小为 0B，有时上传的文件大小正确，但当我下载它时，它已损坏，当然有时它会正确上传并正确打开。

我从系统文件本地读取pdf文件，那个pdf文件是正确的。

有人可以帮我解决这个问题吗？

更新

我正在使用 pdfkit 创建 pdf：

function createPdf (data, cb) {
    var fs = require('fs');
    var PDFDocument = require('pdfkit');
    var filePath = 'temp/longFileName.pdf';
    var pdf = new PDFDocument({
      size: 'LEGAL',
      info: {
        Title: 'Tile of File Here',
        Author: 'Some Author',
      }
    });

    // Write stuff into PDF
    pdf.text('Hello World');

    // Stream contents to a file
    pdf.pipe(
      fs.createWriteStream(filePath)
    )
      .on('finish', function () {
        console.log('PDF closed');
      });

    // Close PDF and write file.
    pdf.end();
    cb(null, {filePath})
}

调用此函数中的回调后，我调用 uploadFile 函数：

function doAll (someData, cb) {

    createPdf(someData, function(err, data) {
        if (err) console.log(err)

        uploadFile(data.filePath, function(err,data) {
            if (err) console.log(err)
            console.log('finished')
            cb(null, 'done');
            return;
        })
    })
}

Answer 1

问题在于您是立即调用回调，而不是等待文件完全写入。你的回调函数应该在 .on('finish')

里面

pdf.pipe(
  fs.createWriteStream('./path/to/file.pdf')
)
.on('finish', function () {
    console.log('PDF closed');
    cb(null, 'finished'); // The callback should e in here
});

// Close PDF and write file.
pdf.end();

nodejs 将 pdf 上传到 S3 存储桶损坏的文件

nodejs uploading pdf to S3 bucket corrupt file

pdf

amazon-s3

node.js

aws-sdk

aws-sdk-nodejs

更新