如何将多个文件上传到mongodb

const { MongoClient } = require('mongodb');
const fs = require('fs');

async function uploadFilesToMongoDB(filePaths) {
  const uri = 'mongodb://localhost:27017'; // MongoDB连接字符串
  const dbName = 'mydatabase'; // 数据库名称
  const collectionName = 'files'; // 集合名称

  const client = new MongoClient(uri);
  await client.connect();

  const db = client.db(dbName);
  const bucket = new mongodb.GridFSBucket(db, { bucketName: collectionName });

  for (const filePath of filePaths) {
    const fileStream = fs.createReadStream(filePath);
    const uploadStream = bucket.openUploadStream(filePath);

    fileStream.pipe(uploadStream);

    await new Promise((resolve, reject) => {
      uploadStream.on('finish', resolve);
      uploadStream.on('error', reject);
    });
  }

  client.close();
}

// 使用示例
const filePaths = ['file1.txt', 'file2.txt', 'file3.txt'];
uploadFilesToMongoDB(filePaths)
  .then(() => {
    console.log('Files uploaded successfully.');
  })
  .catch((error) => {
    console.error('Error uploading files:', error);
  });