创建到目录的读取流并将整个目录通过管道传输到 MongoDB Bucket

Question

我正在尝试将整个目录保存到 MongoDB 存储桶。

当我压缩文件时它可以工作，但我需要将文件解压缩到存储桶中。

当我尝试流式传输目录时，错误显示为 "Illegal operation on a directory"。

我一直在尝试寻找解决方案，但找不到用于目录的解决方案。

let conn = mongoose.connection;
let gfb;

conn.once('open', () => {
  //init the stream
  console.log('- Connection open -');
  gfb = new mongoose.mongo.GridFSBucket(conn.db, {
    chunkSizeBytes: 1024,
    bucketName: 'uploads'
  })
})

const uploaddb = (req, res, vile) => {
conn.once('open', () => {
    console.log('- Connection open -');
    gfb = new mongoose.mongo.GridFSBucket(conn.db, {
      chunkSizeBytes: 1024,
      bucketName: 'uploads'
    })
    try {
    uploadDir('/Users/nancycollins/virtuload-beta/backend/uploads/unzipped/')
    } catch (e) {
      console.error(e);
    }
  });
}

async function uploadDir (folder, subFolder = '') {
  const actualFolder = path.join(folder, subFolder)
  const contents = await fs.readdir(actualFolder, { withFileTypes: true })
  await Promise.all(contents.map((fileOrDirectory) =>
    fileOrDirectory.isDirectory()
      ? uploadDir(folder, path.join(subFolder, fileOrDirectory.name))
      : uploadFile(folder, path.join(actualFolder, fileOrDirectory.name))
  ))
}

async function uploadFile (baseFolder, filePath) {
  return new Promise((resolve, reject) => {
    fs.createReadStream(filePath)
      .pipe(gfb.openUploadStream(filePath, { metadata: path.relative(baseFolder, filePath) }))
      .on('error', function(error) {
        reject(error);
      })
      .on('finish', () => {
        resolve()
      })
  })
}

-我也尝试将 try-catch 更改为：

    try {
    const folder = '/Users/nancycollins/virtuload-beta/backend/uploads/unzipped/';
    uploadDir(folder)
    } catch (e) {
      console.error(e);
    }

编辑：

这是更新版本。

当前错误为：

TypeError [ERR_INVALID_ARG_TYPE]: The "path" argument must be of type string. Received type object
    at validateString (internal/validators.js:125:11)
    at Object.join (path.js:1147:7)

等等……

Answer 1

解决方法：

上传文件夹文件并将它们的相对文件夹结构保存在 GridFS 的metadata 中。在此示例中，uploadDir 是一个递归函数，它遍历给定文件夹及其子文件夹，并为找到的每个文件调用 uploadFile。

在此示例中，我假设您使用的是fs 的承诺版本。

async function uploadDir (folder, subFolder = '') {
  const actualFolder = path.join(folder, subFolder)
  const contents = await fs.readdir(actualFolder, { withFileTypes: true })
  await Promise.all(contents.map((fileOrDirectory) =>
    fileOrDirectory.isDirectory()
      ? uploadDir(folder, path.join(subFolder, fileOrDirectory.name))
      : uploadFile(folder, path.join(actualFolder, fileOrDirectory.name))
  ))
}

async function uploadFile (baseFolder, filePath) {
  return new Promise((resolve, reject) => {
    fs.createReadStream(filePath)
      .pipe(gfb.openUploadStream(filePath, { metadata: path.relative(baseFolder, filePath) }))
      .on('error', function(error) {
        reject(error);
      })
      .on('finish', () => {
        resolve()
      })
  })
}

编辑：

如果您不需要存储更多信息，您可以将 GridFS 文件的 name 设置为相对路径。