如何统计Firestore中用户的读写操作次数以实现计费？

以下是几种适配不同业务场景的实现方式，你可以根据规模和准确性需求选择：

1. 客户端手动计数（小规模场景） #

在用户每次执行Firestore读写操作时，本地维护计数器，定期将累计值同步到users集合的对应文档中（新增readCount和writeCount字段）。

• 为避免并发冲突，必须用Firestore事务更新计数，示例代码（Web端）：

async function incrementReadCount(userId) {
  const userRef = db.collection('users').doc(userId);
  await db.runTransaction(async (tx) => {
    const userDoc = await tx.get(userRef);
    const newCount = (userDoc.data()?.readCount || 0) + 1;
    tx.update(userRef, { readCount: newCount });
  });
}

• 缺点：客户端计数存在被篡改风险，仅适合对准确性要求不高的小型应用。

2. Cloud Functions服务器端计数（中等规模，更可靠） #

利用Firestore触发器处理写操作计数，读操作通过客户端上报+云端验证的方式统计：

• 写操作计数：监听所有业务集合的onWrite触发器，在云端提取关联的用户ID并更新计数：

exports.countWrites = functions.firestore
  .document('{collection}/{docId}')
  .onWrite(async (change, context) => {
    // 假设业务文档都包含userId字段，关联操作所属用户
    const userId = change.after.exists ? change.after.data().userId : change.before.data().userId;
    if (!userId) return;

    const userRef = admin.firestore().collection('users').doc(userId);
    await admin.firestore().runTransaction(async (tx) => {
      const userDoc = await tx.get(userRef);
      const writeCount = (userDoc.data()?.writeCount || 0) + 1;
      tx.update(userRef, { writeCount });
    });
  });

• 读操作计数：要求客户端每次读操作后调用专用的Cloud Function上报，函数内通过Firebase Auth验证用户身份，确保请求合法后更新计数。

3. Billing导出+BigQuery分析（大规模，精准统计） #

基于官方计费数据实现最准确的统计：

1. 开启Firebase Billing导出功能，将Firestore使用数据同步到BigQuery。
2. 在BigQuery中编写SQL，结合业务数据里的用户-文档关联关系，按用户聚合读写次数：

SELECT
  JSON_EXTRACT_SCALAR(labels.value, '$.userId') AS userId,
  SUM(CASE WHEN operation_type = 'READ' THEN usage.amount ELSE 0 END) AS read_count,
  SUM(CASE WHEN operation_type = 'WRITE' THEN usage.amount ELSE 0 END) AS write_count
FROM
  `your-project-id.billing.gcp_billing_export_v1_XXXXXX`
WHERE
  service.description = 'Cloud Firestore'
  AND labels.key = 'firebase_user_id' -- 需提前给操作打用户标签
GROUP BY
  userId

• 优点：基于官方数据源，计数绝对准确；缺点：配置流程稍复杂，数据存在几小时延迟，需提前给Firestore操作添加用户标签。

4. 代理层统一处理（完全可控场景） #

搭建中间代理服务，所有Firestore请求必须通过代理转发：

• 在代理层中解析每个请求的用户身份和操作类型，实时更新用户计数到数据库（可复用users集合）。
• 额外优势：可同时实现权限校验、请求限流等功能；缺点：需要额外开发和维护代理服务，增加架构复杂度。

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