Firebase Cloud Function调用bucket.upload()时出现连接错误求助

嘿，我来帮你搞定这个问题！你猜的没错——这个连接错误大概率是因为没有正确等待异步操作完成，导致Cloud Functions提前终止了执行，还没等上传完成就结束了函数进程，所以才会出现这个报错。

作为Node.js和Cloud Functions新手，异步操作的顺序确实容易踩坑，我给你拆解一下问题和解决办法：

为什么会出现这个错误？ #

Cloud Functions的执行逻辑是：一旦函数代码执行到最后一行（或者没有等待异步操作就返回了），它就会立刻终止进程，不管你的上传任务有没有完成。你日志里的“Function execution took 3721 ms, finished with status: 'connection error'”就是典型的函数提前结束，打断了正在进行的上传连接。

核心解决思路：用Promise/async-await管理异步顺序 #

你的代码里用到了html-pdf生成PDF和@google-cloud/storage上传文件，这两个都是异步操作，必须确保先等PDF生成完成，再执行上传，并且让函数等待上传完成后再结束。

我给你改一个可运行的示例代码，你可以参考调整：

首先，把html-pdf的回调式API转换成Promise（因为它默认不支持Promise，没法直接用await）：

const functions = require('firebase-functions');
const admin = require('firebase-admin');
const pdf = require('html-pdf');

// 把html-pdf的create方法包装成Promise
const generatePdfBuffer = (htmlContent, pdfOptions) => {
  return new Promise((resolve, reject) => {
    pdf.create(htmlContent, pdfOptions).toBuffer((err, buffer) => {
      if (err) {
        reject(err);
      } else {
        resolve(buffer);
      }
    });
  });
};

然后，在你的Cloud Function里用async/await来严格控制执行顺序：

// 初始化Firebase Admin（确保只初始化一次）
if (!admin.apps.length) {
  admin.initializeApp();
}

exports.uploadPdfToStorage = functions.https.onRequest(async (req, res) => {
  try {
    // 步骤1：生成你的HTML内容（这里替换成你实际的HTML生成逻辑）
    const html = '<h1>我的测试PDF</h1><p>这是生成的PDF内容</p>';
    const pdfOptions = { format: 'A4' };

    // 步骤2：等待PDF生成完成
    console.log('正在生成PDF...');
    const pdfBuffer = await generatePdfBuffer(html, pdfOptions);

    // 步骤3：初始化Storage桶（替换成你的桶名）
    const bucket = admin.storage().bucket('your-bucket-name');
    const targetFile = bucket.file('generated-pdf.pdf');

    // 步骤4：等待文件上传完成
    console.log('Init upload of file...');
    await targetFile.save(pdfBuffer, {
      contentType: 'application/pdf',
      metadata: {
        cacheControl: 'public, max-age=31536000' // 可选：设置缓存策略
      }
    });

    // 可选：获取文件的公开访问URL
    const [fileUrl] = await targetFile.getSignedUrl({
      action: 'read',
      expires: '2050-01-01'
    });

    console.log('文件上传成功！');
    res.status(200).send({ success: true, url: fileUrl });
  } catch (error) {
    console.error('处理过程出错：', error);
    res.status(500).send({ error: error.message });
  }
});

关键注意点： #

1. 用async标记函数，await等待每个异步步骤：这样函数会严格按照“生成PDF → 上传文件”的顺序执行，不会提前结束。
2. 错误处理用try/catch：捕获生成PDF或上传过程中的所有错误，避免函数崩溃，也方便排查问题。
3. 不要重复初始化Admin：用!admin.apps.length判断，确保只初始化一次，避免报错。
4. 检查Storage权限：确认Cloud Functions的服务账号有你的Storage桶的读写权限（默认情况下是有的，如果你手动修改过权限需要重新确认）。

按照这个思路调整代码，应该就能解决那个连接错误了！

内容的提问来源于stack exchange，提问作者Matheus Leite