使用multer将多个文件发送到Google存储桶 - 为什么我的文件为空？

Question

我之前设置了一个文件上传并正常工作。现在我需要让它处理多个文件。

这是我现在的代码：

const multer = require('multer')
const { Storage } = require('@google-cloud/storage')

const storage = new Storage()

const m = multer({ storage: multer.memoryStorage()  })

module.exports = app => {
  app.use('/', router)
  router.post(
    '/reader-:shortId/file-upload',
    passport.authenticate('jwt', { session: false }),
    m.array('files'),
    async function (req, res) {
      const bucketName = req.params.shortId.toLowerCase()
      await storage.createBucket(bucketName)
      bucket = storage.bucket(bucketName)
      let promises = []

      req.files.forEach((file) => {
        const blob = bucket.file(file.originalname)
        const newPromise =  new Promise((resolve, reject) => {
          blob.createWriteStream({
            metadata: { contentType: file.mimetype }
          }).on('finish', async response => {
            await blob.makePublic()
            resolve(response)
          }).on('error', err => {
            reject('upload error: ', err)
          }).end()
        })
       promises.push(newPromise)
     })

     Promise.all(promises).then((response) => {
       // the response I get here is [undefined, undefined]
       res.status(200).send(response)
     }).catch((err) => {
       res.status(400).send(err.message)
     });
    })
  }

req.files确实给了我一个文件数组，有一个缓冲区和一个有意义的大小。承诺都解决了。但是，一旦我检查谷歌存储桶中的文件，他们就有正确的名称，但没有任何内容（大小为0）

正如我之前所说，当我使用一个文件（使用m.single（'file'）时，它正在工作

我不想将桶用作multer设置的目的地，因为我还必须在上传到Google存储桶之前更改文件名。

编辑：这是谷歌云文档为单个文件上传（https://cloud.google.com/nodejs/getting-started/using-cloud-storage）提供的代码示例：

function sendUploadToGCS (req, res, next) {
  if (!req.file) {
    return next();
  }

  const gcsname = Date.now() + req.file.originalname;
  const file = bucket.file(gcsname);

  const stream = file.createWriteStream({
    metadata: {
      contentType: req.file.mimetype
    },
    resumable: false
  });

  stream.on('error', (err) => {
    req.file.cloudStorageError = err;
    next(err);
  });

  stream.on('finish', () => {
    req.file.cloudStorageObject = gcsname;
    file.makePublic().then(() => {
      req.file.cloudStoragePublicUrl = getPublicUrl(gcsname);
      next();
    });
  });

  stream.end(req.file.buffer);
}

我最初有类似的工作，但我只是不明白从哪里获取文件缓冲区数据。这可能是多个文件的不同之处。

Answer 1

好吧，结果我不得不将.end()改为.end(file.buffer)