Firestore写入触发器同步Meilisearch时数据获取异常求助

核心问题：事件格式不匹配 #

你当前的代码是基于Firebase Cloud Functions的onWrite触发器编写的，但函数部署在Cloud Run，由google.cloud.firestore.document.v1.written（Eventarc触发器）触发——两者的事件 payload 结构完全不同：

• Firebase Functions的onWrite会传入封装好的Change对象（包含before/after DocumentSnapshot）
• Cloud Run收到的是CloudEvents格式的Firestore事件，原始数据在data字段下，包含oldValue（对应before）和value（对应after）两个Firestore文档快照的JSON结构。

这就是change.before.exists始终为false的原因——你访问的不是正确的字段，甚至change对象的结构都不符合Cloud Run的输入。

步骤1：修正事件解析逻辑 #

Cloud Run收到的Firestore事件结构大致如下（简化版）：

{
  "id": "事件ID",
  "type": "google.cloud.firestore.document.v1.written",
  "data": {
    "oldValue": { /* 删除/更新前的文档数据，不存在则无此字段 */ },
    "value": { /* 创建/更新后的文档数据，不存在则无此字段 */ },
    "updateMask": { /* 更新字段掩码 */ }
  },
  "attributes": {
    "document": "projects/[项目ID]/databases/(default)/documents/[集合名]/[文档ID]"
  }
}

以下是修正后的Node.js代码示例（假设用Express处理Cloud Run请求）：

const express = require('express');
const app = express();
app.use(express.json());

app.post('/', async (req, res) => {
  const cloudEvent = req.body;
  const firestoreEvent = cloudEvent.data;
  const docPath = cloudEvent.attributes.document;
  const docId = docPath.split('/').pop();

  // 判断事件类型：创建/更新/删除
  let eventType;
  let documentData = null;
  if (!firestoreEvent.oldValue && firestoreEvent.value) {
    eventType = 'create';
    documentData = convertFirestoreFieldsToJson(firestoreEvent.value.fields);
  } else if (firestoreEvent.oldValue && firestoreEvent.value) {
    eventType = 'update';
    documentData = convertFirestoreFieldsToJson(firestoreEvent.value.fields);
  } else if (firestoreEvent.oldValue && !firestoreEvent.value) {
    eventType = 'delete';
  }

  console.log(`事件类型: ${eventType}, 文档ID: ${docId}`);
  console.log("文档数据:", documentData);

  // 同步到Meilisearch的逻辑
  if (documentData) {
    const meiliPayload = { id: docId, ...documentData };
    // 调用Meilisearch API完成同步...
  }

  res.status(200).send('处理完成');
});

// 工具函数：将Firestore结构化字段转换为普通JSON
function convertFirestoreFieldsToJson(fields) {
  const result = {};
  for (const [key, value] of Object.entries(fields)) {
    const type = Object.keys(value)[0];
    switch (type) {
      case 'stringValue':
        result[key] = value.stringValue;
        break;
      case 'integerValue':
        result[key] = parseInt(value.integerValue);
        break;
      case 'booleanValue':
        result[key] = value.booleanValue;
        break;
      case 'mapValue':
        result[key] = convertFirestoreFieldsToJson(value.mapValue.fields);
        break;
      case 'arrayValue':
        result[key] = value.arrayValue.values?.map(item => {
          const itemType = Object.keys(item)[0];
          return item[itemType];
        }) || [];
        break;
      // 根据你的数据类型扩展其他类型（比如timestampValue等）
      default:
        result[key] = value[type];
    }
  }
  return result;
}

const port = process.env.PORT || 8080;
app.listen(port, () => {
  console.log(`服务运行在端口 ${port}`);
});

步骤2：解决主动读取文档的"未找到"错误 #

如果需要主动读取Firestore文档，逐一排查以下点：

• 文档路径正确性：确保使用完整路径projects/[项目ID]/databases/(default)/documents/[集合名]/[文档ID]，或用Firestore SDK时正确指定集合和文档ID，避免拼写错误。
• 服务账号权限：
  1. 确认服务账号已被授予roles/datastore.user（或roles/datastore.reader）权限，权限变更可能需要几分钟同步，耐心等待后重试。
  2. 检查Cloud Run服务的运行账号是否为该服务账号（控制台→Cloud Run→目标服务→权限标签页）。
• 项目ID匹配：确保代码中使用的项目ID与Firestore所在项目完全一致，避免跨项目访问。

额外调试建议 #

• 在Cloud Run日志中打印完整的事件 payload，确认data.oldValue和data.value字段是否存在、结构是否符合预期。
• 本地测试Firestore读取逻辑：用服务账号密钥本地运行代码，直接读取目标文档，验证是否能正常获取数据，排除权限或路径问题。

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