如何基于Firebase函数将multipart/formData的文件保存到Firestore？

我编写了一段Firebase Cloud Function代码如下：

//Functions and firestore requirements are here
exports.saveData = functions.https.onRequest(async (req, res) => { 
console.log("Data received") 
const busboy = new Busboy({headers: req.headers}); 
const fields = {} 
const uploads = {} 
//Push fields that are not file in fields 
busboy.on('field', (fieldname, val) => { 
console.log(`Processed field ${fieldname}: ${val}.`); 
fields[fieldname] = val; 
}); 
//Push files in uploads 
busboy.on('file', (fieldname, file, filename) => { 
console.log('File :', file); 
const filepath = path.join(tmpdir, filename); 
uploads[fieldname] = filepath; 
}); 
busboy.on('finish', () => { 
console.log(uploads) 
console.log(fields) 
db.collection("a_collection").add({ 
a: fields.a, 
b: fields.b, 
file: "Help ! From the client, I send an image. Which value do I need to save ?" 
}) 
.then(function () { 
res.send("Data is saved") 
}) 
.catch(function (error) { 
res.status(400).send(error) 
console.error("Error :" + error) 
}) 
}); 
busboy.end(req.rawBody); 
})

我希望从multipart/formData请求中保存图片和数据到Google Cloud Firestore数据库，请问具体该如何实现？是否需要将图片转为base64格式保存，还是有其他方式可以在Firestore中存储文件？

核心结论：别直接在Firestore存图片，用「Cloud Storage + Firestore存路径/URL」才是最优解 #

Firestore单文档最大只能存1MB数据，而且base64编码会让图片体积凭空增加30%左右，稍大一点的图片就会触发大小限制。更合理的方案是：

• 把图片上传到Google Cloud Storage（Firebase项目默认关联了这个存储服务）
• 在Firestore文档里只存图片的「Cloud Storage路径」或者「公开下载URL」，同时保存表单字段数据

具体实现步骤及代码修改 #

1. 补充依赖

除了已有的Firebase相关包，还需要引入fs-extra（简化文件流操作），当然用原生fs也可以，只是代码会繁琐一点。

2. 完整修改后的Cloud Function代码

const functions = require('firebase-functions');
const admin = require('firebase-admin');
const Busboy = require('busboy');
const path = require('path');
const os = require('os');
const fs = require('fs-extra');

admin.initializeApp();
const db = admin.firestore();
const storage = admin.storage();

exports.saveData = functions.https.onRequest(async (req, res) => {
  try {
    console.log("Data received");
    const busboy = new Busboy({ headers: req.headers });
    const fields = {};
    const uploadPromises = []; // 用来收集所有文件上传的Promise，方便后续统一等待

    // 处理普通表单字段
    busboy.on('field', (fieldname, val) => {
      console.log(`Processed field ${fieldname}: ${val}.`);
      fields[fieldname] = val;
    });

    // 处理上传的图片文件
    busboy.on('file', (fieldname, file, filename) => {
      console.log(`Processing file ${filename}`);
      // 创建临时文件路径（Cloud Functions的临时目录是内存挂载的，用完要删）
      const tempFilePath = path.join(os.tmpdir(), filename);
      const writeStream = fs.createWriteStream(tempFilePath);
      file.pipe(writeStream);

      // 封装文件上传到Cloud Storage的逻辑为Promise
      const uploadPromise = new Promise((resolve, reject) => {
        writeStream.on('finish', async () => {
          try {
            // 指定Cloud Storage的存储路径，比如images/[文件名]
            const storageRef = storage.bucket().file(`images/${filename}`);
            // 把临时文件上传到Storage
            await storageRef.upload(tempFilePath, {
              resumable: false,
              metadata: {
                contentType: file.mimetype // 保留图片的MIME类型，方便前端识别
              }
            });
            // 获取图片的公开下载URL（如果需要公开访问）
            const [url] = await storageRef.getSignedUrl({
              action: 'read',
              expires: '03-01-2500' // 设置长期有效，也可以按需调整过期时间
            });
            // 把URL和存储路径存入fields，后续一起写到Firestore
            fields[`${fieldname}_url`] = url;
            fields[`${fieldname}_path`] = `images/${filename}`;
            resolve();
          } catch (err) {
            reject(err);
          } finally {
            // 上传完成后删除临时文件，释放资源
            await fs.unlink(tempFilePath);
          }
        });
        writeStream.on('error', reject);
      });

      uploadPromises.push(uploadPromise);
    });

    // 等待所有文件上传完成，再写入Firestore
    busboy.on('finish', async () => {
      try {
        await Promise.all(uploadPromises);
        console.log("所有文件上传完成");
        console.log("表单字段：", fields);

        // 将表单数据和图片信息存入Firestore
        await db.collection("a_collection").add({
          a: fields.a,
          b: fields.b,
          image_url: fields.image_url, // 假设前端上传的文件字段名是image
          image_storage_path: fields.image_path
        });

        res.status(200).send("数据和图片已成功保存");
      } catch (error) {
        console.error("保存数据时出错：", error);
        res.status(400).send(`保存失败：${error.message}`);
      }
    });

    busboy.end(req.rawBody);
  } catch (error) {
    console.error("请求处理出错：", error);
    res.status(500).send(`服务器错误：${error.message}`);
  }
});

3. 关键细节说明

• 临时文件清理：Cloud Functions的临时目录空间有限，上传完成后一定要删除临时文件，避免资源浪费
• Storage权限控制：如果需要让普通用户访问图片，要在Firebase控制台的Storage规则里配置权限，比如允许公开读取images/路径下的文件，或者通过Firebase Auth做身份验证
• Signed URL可选：如果不想公开图片，可以生成带签名的URL，设置过期时间，只有持有URL的人才能在有效期内访问
• base64仅适用于极小图片：除非是几KB的图标，否则绝对不要用base64存到Firestore，不仅体积大，还会拖慢文档读写速度

可选：真要存base64的话（仅适合极小图片） #

如果你的图片非常小（比如小于700KB，base64编码后刚好不超过1MB），可以转成base64字符串存到Firestore，代码片段如下：

// 在busboy的file事件中替换为这段逻辑
busboy.on('file', (fieldname, file, filename) => {
  const chunks = [];
  file.on('data', (chunk) => chunks.push(chunk));
  file.on('end', () => {
    const base64String = Buffer.concat(chunks).toString('base64');
    // 生成可以直接在img标签里用的dataURL
    fields[`${fieldname}_base64`] = `data:${file.mimetype};base64,${base64String}`;
  });
});

// 写入Firestore时保存这个base64字符串
await db.collection("a_collection").add({
  a: fields.a,
  b: fields.b,
  image_base64: fields.image_base64
});

内容的提问来源于stack exchange，提问作者Valentin Regnault