Firebase函数调用admin.auth().getUser报无对应用户记录错误

问题背景 #

实现目标：编写Firebase函数监听Firestore中profile集合的数据变更，将变更数据同步推送至CRM系统的已有联系人记录。
原始实现代码：

// LISTENER
exports.listenData = functions.https.onRequest(async(request, response) => {

  // Keep track of profile collection
  db.collection('profile').onSnapshot(async(querySnapshot) => {
    console.log('change in profile');

    let changedDocs = querySnapshot.docChanges();
    for (let i = 0; i < changedDocs.length; i++) {
      let change = changedDocs[i];

      if (!change.doc.exists) {
        continue;
      }
      console.log('change in profile in loop');

      let profileDocData = change.doc.data();
      let body = {
        "customField": {
          "subscription_expiration_date": ""
        }
      };

      let user = await admin.auth().getUser(change.doc.id);

      // profile
      try {
        body.customField.subscription_expiration_date = profileDocData.expiration_date;
      } catch (error) {
        body.customField.subscription_expiration_date = '';
      }

      console.log("Profile changed by " + user.email ? ? "Unknown");

      try {
        let res = await axios.get('EndPoint URL ?email=' + user.email, {
          headers: {
            "Authorization": "Bearer Token"
          }
        });

        let userId = res.data.contacts[0].id;
        axios.put('EndPoint URL /contacts/' + userId, body, {
          headers: {
            "Authorization": "Bearer Token"
          }
        });

      } catch (error) {
        console.log('Error on profile');
      }
    }
  });


  response.send("Listening...");
});

运行报错信息：
Exception from a finished function: Error: There is no user record corresponding to the provided identifier（已结束函数抛出异常：所提供的标识符不存在对应的用户记录）

报错根因 #

1. 直接触发用户不存在错误的逻辑缺陷
   代码中let user = await admin.auth().getUser(change.doc.id)默认profile集合下所有文档的ID，都和Firebase Auth中的用户UID完全一一对应。实际场景中只要存在以下任意一种情况，就会触发该错误：
   • 已删除Firebase Auth账号，但对应的profile文档没有被级联删除，残留脏数据
   • 手动在Firestore中创建过ID不符合Auth UID规则的测试profile文档
   • 业务逻辑存在profile文档创建先于Auth账号注册的时序问题
     且这段getUser调用没有加任何异常捕获，错误抛出时会直接中断整个流程。
2. 架构选型错误（触发「已结束函数抛出异常」提示的核心原因）
   你把Firestore实时快照监听器onSnapshot写在了HTTP类型的云函数里。HTTP云函数的生命周期在调用response.send("Listening...")之后就已经结束，Cloud Functions会回收该函数实例的运行资源，你注册的监听器会在被回收的实例中后台残留运行，不仅会抛异常，还会造成监听器重复注册、同步逻辑重复执行、不必要的资源计费问题。Firestore数据变更监听必须使用官方提供的Firestore触发器实现，不能在HTTP函数里手动挂载onSnapshot。
3. 其他潜在代码问题
   • 空值合并运算符语法错误：user.email ? ? "Unknown"中间多了空格，正确写法为user.email ?? "Unknown"
   • CRM更新请求axios.put没有加await，函数退出时请求可能还未发送完成就被中断
   • CRM联系人查询结果没有做判空，若邮箱匹配不到联系人，取res.data.contacts[0].id会直接抛出下标不存在的错误

修复方案 #

废弃原有HTTP触发的函数，改用Firestore原生触发器实现监听，同时补全所有异常捕获和边界判断，修复后代码如下：

const functions = require('firebase-functions');
const admin = require('firebase-admin');
const axios = require('axios');
admin.initializeApp();
const db = admin.firestore();

// 使用Firestore文档写入触发器，替代原HTTP函数内的onSnapshot监听
exports.syncProfileToCRM = functions.firestore
  .document('profile/{docId}')
  .onWrite(async (change, context) => {
    // 跳过文档删除的场景
    if (!change.after.exists) {
      console.log('Profile document deleted, skip sync');
      return null;
    }

    const docId = context.params.docId;
    const profileData = change.after.data();
    const syncPayload = {
      customField: {
        subscription_expiration_date: profileData.expiration_date || ''
      }
    };

    // 捕获Auth用户不存在的异常，避免流程中断
    let userEmail = 'Unknown';
    try {
      const user = await admin.auth().getUser(docId);
      userEmail = user.email ?? 'Unknown';
    } catch (authErr) {
      console.error(`No matching Auth user for profile doc ID: ${docId}, sync terminated. Error: ${authErr.message}`);
      return null;
    }
    console.log(`Profile modified by operator: ${userEmail}`);

    // 全链路捕获CRM接口调用异常，补全await和判空逻辑
    try {
      const crmQueryRes = await axios.get(`你的CRM接口地址?email=${userEmail}`, {
        headers: {
          "Authorization": "Bearer 你的CRM鉴权Token"
        }
      });
      // 判空处理CRM无匹配联系人的场景
      if (!crmQueryRes.data.contacts || crmQueryRes.data.contacts.length === 0) {
        console.error(`No matching CRM contact for email: ${userEmail}`);
        return null;
      }
      const contactId = crmQueryRes.data.contacts[0].id;
      // 加await等待更新请求完成
      await axios.put(`你的CRM接口地址/contacts/${contactId}`, syncPayload, {
        headers: {
          "Authorization": "Bearer 你的CRM鉴权Token"
        }
      });
      console.log(`Profile for ${userEmail} synced to CRM successfully`);
      return null;
    } catch (crmErr) {
      console.error(`Sync to CRM failed: ${crmErr.message}`);
      return null;
    }
  });

部署验证注意事项 #

• 部署新的触发器函数后，删除原有旧的HTTP触发函数，避免残留的监听器重复执行同步逻辑
• 提前排查profile集合内的存量数据，清理掉ID和Firebase Auth UID不匹配的无效文档
• 测试时可在Firebase控制台手动修改一条合法的profile文档，通过函数日志确认同步流程正常执行无报错

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