如何正确解码Firestore触发的Google CloudEvent数据？

你遇到的乱码问题，根源在于Firestore通过CloudEvent传递的文档数据是Protocol Buffer（protobuf）二进制格式，不是纯UTF-8文本，直接用toString('utf8')解码肯定会出现乱码。下面是两种可靠的解决方法：

方法一：使用官方@google/events包解析（推荐） #

这个包内置了Firestore事件的类型定义和解析逻辑，能直接把二进制数据转成结构化对象：

1. 安装依赖：

npm install @google/events

2. 修改你的Cloud Function代码：

import { FirestoreDocumentEventData } from '@google/events/cloud/firestore/v1';
import { functions } from '@google-cloud/functions-framework';

functions.cloudEvent('onItemCreate', async (cloudEvent: functions.CloudEvent<FirestoreDocumentEventData>) => {
  // 获取文档的结构化数据
  const documentFields = cloudEvent.data.value.fields;
  console.log('解析后的文档数据:', documentFields);

  // 还可以获取文档的元信息
  console.log('文档完整路径:', cloudEvent.data.value.name);
  console.log('文档更新时间:', cloudEvent.data.value.updateTime);
});

方法二：手动用ProtobufJS解析 #

如果不想额外安装依赖，可以直接基于Firestore的Event proto定义手动解码：

1. 安装protobufjs：

npm install protobufjs

2. 编写解析逻辑（需要引入Firestore的proto定义）：

import { functions } from '@google-cloud/functions-framework';
import { loadSync } from 'protobufjs';

// 加载Firestore事件的proto定义（可从Google官方仓库获取对应proto文件）
const root = loadSync('firestore_event.proto');
const DocumentEventData = root.lookupType('google.events.cloud.firestore.v1.DocumentEventData');

functions.cloudEvent('onItemCreate', async (cloudEvent: functions.CloudEvent<any>) => {
  // 解码二进制数据
  const decodedData = DocumentEventData.decode(cloudEvent.data as Buffer);
  console.log('解析后的文档数据:', decodedData.value.fields);
});

注意：手动解析需要自行获取并维护Firestore的proto文件，不如官方包省心，所以优先推荐方法一。

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