如何通过Firebase触发的Cloud Functions将远程PDF归档到GCS指定路径？

我来帮你搞定这个路径修改的问题！核心就是在上传文件到Google Cloud Storage（GCS）时，指定自定义的目标路径，而不是默认的存储桶根目录。结合你的代码场景，具体步骤如下：

1. 确认参数获取 #

你的触发器路径里已经包含了{ukey}参数，首先确保你已经正确从event.params中拿到这个值：

const params = event.params;
const ukey = params.ukey; // 这就是你要用到的组织唯一标识

2. 构造目标存储路径 #

接下来，你需要把PDF文件的目标路径构造成Orgs/${ukey}/[PDF文件名]。这里的文件名可以从远程PDF的URL中提取，或者自定义命名，比如：

// 假设你从数据库快照里拿到了远程PDF的链接
const remotePdfUrl = snapshot.val();
// 从URL中提取原始文件名（比如从"https://example.com/file.pdf"得到"file.pdf"）
const pdfFilename = remotePdfUrl.split('/').pop();
// 构造完整的GCS目标路径
const destinationPath = `Orgs/${ukey}/${pdfFilename}`;

3. 修改GCS上传逻辑 #

把原来上传到根目录的代码，替换成指定destination参数的版本。以下是两种常见场景的修改示例：

场景1：直接下载远程文件并上传到GCS #

如果你的代码是用bucket.upload()处理本地临时文件的方式：

const admin = require('firebase-admin');
const fs = require('fs');
const request = require('request-promise');

exports.copyFiles = functions.database.ref('Orgs/{orgkey}/resources/{restypekey}/{ukey}/linkDesc/en').onWrite(async (event) => {
  const snapshot = event.data;
  const params = event.params;
  const ukey = params.ukey;
  const remotePdfUrl = snapshot.val();
  
  // 1. 下载远程PDF到本地临时文件
  const tempFilePath = `/tmp/${Date.now()}.pdf`;
  await new Promise((resolve, reject) => {
    request(remotePdfUrl)
      .pipe(fs.createWriteStream(tempFilePath))
      .on('finish', resolve)
      .on('error', reject);
  });
  
  // 2. 构造目标路径
  const pdfFilename = remotePdfUrl.split('/').pop();
  const destinationPath = `Orgs/${ukey}/${pdfFilename}`;
  
  // 3. 上传到指定路径的GCS存储桶
  const bucket = admin.storage().bucket();
  await bucket.upload(tempFilePath, {
    destination: destinationPath,
    contentType: 'application/pdf' // 确保正确设置文件类型
  });
  
  // 4. 清理临时文件
  return fs.promises.unlink(tempFilePath);
});

场景2：通过Buffer直接上传（无需本地文件） #

如果你的代码是先获取文件Buffer再上传：

const admin = require('firebase-admin');
const request = require('request-promise');

exports.copyFiles = functions.database.ref('Orgs/{orgkey}/resources/{restypekey}/{ukey}/linkDesc/en').onWrite(async (event) => {
  const snapshot = event.data;
  const params = event.params;
  const ukey = params.ukey;
  const remotePdfUrl = snapshot.val();
  
  // 1. 获取远程PDF的Buffer
  const pdfBuffer = await request.get({ uri: remotePdfUrl, encoding: null });
  
  // 2. 构造目标路径
  const pdfFilename = remotePdfUrl.split('/').pop();
  const destinationPath = `Orgs/${ukey}/${pdfFilename}`;
  
  // 3. 上传到指定路径
  const bucket = admin.storage().bucket();
  const file = bucket.file(destinationPath);
  await file.save(pdfBuffer, {
    contentType: 'application/pdf',
    resumable: false // 小文件可以关闭断点续传提升效率
  });
  
  return null;
});

4. 注意事项 #

• 权限检查：确保你的Cloud Functions服务账号（通常是[项目ID]@appspot.gserviceaccount.com）拥有GCS存储桶的storage.objects.create权限，否则会上传失败。
• 文件名冲突：如果担心重复文件名，可以在文件名前加上时间戳或者随机字符串，比如${Date.now()}_${pdfFilename}。
• 路径分隔符：GCS的路径用正斜杠/分隔，和你要求的格式完全匹配，不需要额外处理。

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