Google Cloud Functions v2迁移：EventArc如何获取调用用户ID？

不用完全重写前后端，以下几种方案可以解决你的问题：

1. 复用v1风格的Firebase原生触发器（最省心） #

Cloud Functions v2 SDK依然保留了Firebase原生触发器的接口（比如functions.database.ref().onUpdate），这类触发器并不完全依赖EventArc，依然会提供包含auth信息的context对象，和v1的用法几乎一致。

示例代码：

const functions = require("firebase-functions");

exports.onMyUpdate = functions
  .region('us-central1')
  .database
  .ref('/my/{myId}')
  .onUpdate(async (change, context) => {
    // 依然可以直接获取用户UID
    const user = context.auth?.uid || SYSTEM;
    const isUpdatedBySystem = user === SYSTEM;
    
    if (isUpdatedBySystem) {
      console.log("Update by system - Exit");
      return true;
    }
    // 后续逻辑...
  });

这种方案不需要改动原有业务代码，直接沿用v1的逻辑即可。

2. 通过安全规则自动写入调用者UID到数据元字段 #

在Firebase Realtime Database的安全规则中，强制要求写入操作必须附带调用者UID到指定的元字段（比如_updatedBy），这样在v2函数的EventArc事件数据中就能直接读取到该UID。

安全规则配置： #

{
  "rules": {
    "my": {
      "$myId": {
        ".write": "auth != null",
        // 强制验证_updatedBy字段必须等于当前用户UID
        "_updatedBy": {
          ".validate": "newData.val() === auth.uid"
        },
        // 允许其他字段正常写入
        "$other": {
          ".validate": true
        }
      }
    }
  }
}

前端/Admin SDK写入时的处理： #

前端写入数据时，自动添加_updatedBy字段：

// 前端示例（Web SDK）
const db = getDatabase();
const myRef = ref(db, '/my/1234');
update(myRef, {
  // 业务字段
  name: "new name",
  // 自动带上当前用户UID
  _updatedBy: auth.currentUser.uid
});

在v2函数中读取：

onValueUpdated(
  { region: "us-central1", ref: "/my/{myId}" },
  async (event) => {
    const updatedBy = event.data.after._updatedBy;
    const isUpdatedBySystem = updatedBy === SYSTEM;
    // 后续逻辑...
  }
);

这种方案只需要在数据结构中添加一个元字段，无需大规模重写前后端。

3. 通过Cloud Logging关联安全规则日志获取UID #

如果不想修改数据结构，可以利用Firebase安全规则的日志功能，将调用者UID和操作路径关联记录，然后在v2函数中通过Cloud Logging API查询匹配的日志条目，提取UID。

安全规则配置（添加日志）： #

{
  "rules": {
    "my": {
      "$myId": {
        ".write": "auth != null",
        // 写入日志，包含UID和操作路径
        ".validate": "log('db-write:uid=' + auth.uid + ',ref=' + $myId); true"
      }
    }
  }
}

v2函数中查询日志： #

通过Cloud Logging API查询最近的包含当前事件ref的日志条目，提取UID。注意要处理日志的延迟问题，可添加短时间重试逻辑：

const { Logging } = require('@google-cloud/logging');
const logging = new Logging();

onValueUpdated(
  { region: "us-central1", ref: "/my/{myId}" },
  async (event) => {
    const targetRef = event.ref;
    const logName = 'firebase.database';
    
    // 查询最近1分钟内包含目标ref的日志
    const [entries] = await logging.log(logName).getEntries({
      filter: `textPayload:"db-write:ref=${targetRef}"`,
      orderBy: 'timestamp desc',
      pageSize: 1
    });

    if (entries.length > 0) {
      const match = entries[0].textPayload.match(/uid=([a-zA-Z0-9_-]+)/);
      if (match) {
        const user = match[1];
        const isUpdatedBySystem = user === SYSTEM;
        // 后续逻辑...
      }
    }
  }
);

这种方案无需修改数据，但需要额外调用Cloud Logging API，且要注意日志权限和延迟问题。

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