如何将Realtime Database的新增或更新数据推送至Cloud Firestore

核心逻辑 #

通过Firebase原生的Cloud Functions触发器监听Realtime Database的写入（新增/更新）事件，触发后自动把数据写入Cloud Firestore，全程不需要修改现有Zapier推送流程，两个数据库可独立正常运行。

操作步骤 #

• 环境初始化
  本地安装Firebase CLI后执行firebase login登录你的Firebase账号，在项目目录下执行firebase init functions，选择对应项目，运行环境选择Node.js即可。
• 编写同步逻辑
  打开functions目录下的index.js文件，写入如下触发器代码：

const functions = require("firebase-functions");
const admin = require("firebase-admin");
admin.initializeApp();
const firestoreDB = admin.firestore();

// 替换为你Zapier写入Realtime Database的实际路径，{entryId}为动态匹配的条目ID
exports.syncRtdbToFirestore = functions.database.ref('/rtdb_data_store_path/{entryId}')
  .onWrite(async (change, context) => {
    // 获取变更后的最新数据
    const latestData = change.after.val();
    // 数据被删除时不同步，需要同步删除可删除该判断
    if (!latestData) return null;
    try {
      // 替换为业务使用的Firestore集合名，merge为true表示更新时仅覆盖变更字段
      await firestoreDB.collection('business_firestore_collection').doc(context.params.entryId).set(latestData, { merge: true });
      return { status: 'sync_success' };
    } catch (error) {
      console.error('数据同步失败：', error);
      return null;
    }
  });

• 部署上线
  本地执行firebase deploy --only functions，部署完成后触发器自动生效，所有对应路径下的新增、更新操作都会自动同步到Cloud Firestore。

自定义调整说明 #

• 需要同步删除操作的话，移除代码中的空数据判断，补充Firestore对应文档的删除逻辑即可。
• 若需要对同步数据做字段转换、格式校验，可在写入Firestore之前添加对应处理逻辑。
• Firestore的文档ID可自定义配置，无需强制复用Realtime Database的条目ID。

注意事项 #

• 默认初始化的admin SDK已拥有同项目下两个数据库的读写权限，无需额外配置IAM规则，若你之前修改过服务账号权限，需确保云函数服务账号拥有datastore.user和firebasedatabase.admin角色。
• 出现同步异常时可直接查看Cloud Functions运行日志排查问题。

内容的提问来源于stack exchange，提问作者A.M.