如何在Firebase云函数中通过REST API认证读取实时数据库浅层数据

你遇到的核心问题是尝试用REST API访问非公开的RTDB位置时认证失败，原因在于：

• createCustomToken生成的是自定义登录令牌，仅用于客户端Firebase Auth登录，不能直接作为REST API的Bearer凭证使用。
• applicationDefault().getAccessToken()返回的是包含令牌的对象，你需要提取其中的access_token字段才能正确使用。

不过更高效的方案是直接使用Firebase Admin SDK实现浅层读取，无需依赖REST API，同时自动绕过数据库规则。

方案一：使用Admin SDK直接实现浅层读取 #

Admin SDK的实时数据库API支持shallow参数，设置后仅读取当前节点的键，不会加载子节点数据，完美匹配你的需求：

const admin = require("firebase-admin");
const functions = require("firebase-functions");
const serviceAccount = require("./serviceAccount.json");

admin.initializeApp({
  credential: admin.credential.cert(serviceAccount),
  databaseURL: "https://DATABSEID.firebaseio.com",
});

async function doShallowRead() {
  // 定位到目标数据库路径
  const targetRef = admin.database().ref("PATH/IN/DATABASE");
  
  // 执行浅层读取：仅获取当前节点的键，不加载子节点
  const snapshot = await targetRef.once("value", null, { shallow: true });
  
  // 提取键列表（如果节点为空则返回空数组）
  const keys = snapshot.exists() ? Object.keys(snapshot.val()) : [];
  
  console.log("浅层读取到的键列表：", keys);
  return keys;
}

exports.callMyFunction = functions.https.onCall(async () => {
  const result = await doShallowRead();
  return { keys: result };
});

优势 #

• 无需额外依赖（如node-fetch），减少代码复杂度
• Admin SDK自动处理认证，完全绕过数据库规则，无需手动管理令牌
• 性能更优，避免额外的HTTP请求开销

方案二：如果坚持使用REST API #

若必须通过REST API实现，需正确使用服务账号的OAuth2访问令牌：

const fetch = require("node-fetch");
const admin = require("firebase-admin");
const functions = require("firebase-functions");
const serviceAccount = require("./serviceAccount.json");

admin.initializeApp({
  credential: admin.credential.cert(serviceAccount),
  databaseURL: "https://DATABSEID.firebaseio.com",
});

async function doShallowReadWithREST() {
  // 获取服务账号的OAuth2访问令牌
  const tokenObj = await admin.credential.applicationDefault().getAccessToken();
  const accessToken = tokenObj.access_token;

  const response = await fetch(
    "https://DATABSEID.firebaseio.com/PATH/IN/DATABASE.json?shallow=true",
    {
      headers: {
        Authorization: `Bearer ${accessToken}`,
      },
    }
  );

  if (!response.ok) {
    throw new Error(`请求失败：${response.status} ${response.statusText}`);
  }

  const shallowData = await response.json();
  console.log("REST API浅层读取结果：", shallowData);
  return shallowData;
}

exports.callMyFunction = functions.https.onCall(async () => {
  const result = await doShallowReadWithREST();
  return result;
});

注意事项 #

• 确保云函数使用的服务账号拥有Firebase Database Admin角色（默认云函数服务账号已具备此权限）
• 访问令牌有过期时间，Admin SDK会自动处理刷新，无需手动管理

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