如何将CouchDB多库统计数据同步至可复制文档用于检索？

针对你遇到的问题——需要将每个数据库的文档统计数据（按类型）存入可复制的文档，这里有几个直接可行的方案：

1. 定时调用更新函数写入统计文档 #

这是最容易实现的方案，核心思路是把视图计算的统计结果写入普通文档，让CouchDB的复制机制可以同步它：

• 首先在每个数据库的设计文档里添加一个更新函数，负责接收统计数据并写入专用统计文档：

  // 放在 _design/stats 的 updates 字段下，命名为 write_counts
  function(doc, req) {
    // 如果统计文档不存在，初始化一个
    if (!doc) {
      doc = {
        _id: "doc_type_counts",
        type: "statistics",
        counts: {}
      };
    }
    // 从请求体获取视图返回的统计数据并更新
    const newCounts = JSON.parse(req.body);
    doc.counts = newCounts;
    doc.last_updated = new Date().toISOString();
    // 返回更新后的文档和提示信息
    return [doc, "统计数据已更新"];
  }
  

• 然后用外部定时任务（比如Linux cron、Windows任务计划）定期执行两步操作：
  1. 调用map/reduce视图获取最新统计：curl http://couchdb-host:5984/your-db/_design/your-view/_view/type-counts?reduce=true&group=true
  2. 把结果传给更新函数写入文档：curl -X POST http://couchdb-host:5984/your-db/_design/stats/_update/write_counts -d @view-result.json -H "Content-Type: application/json"

2. 监听变更流实时更新统计 #

如果需要统计数据实时同步，可以写一个轻量服务监听数据库的_changes feed，一旦有文档变更就更新统计：

• 用Node.js/Python等写一个脚本，持续监听http://couchdb-host:5984/your-db/_changes?feed=continuous
• 每次收到变更事件（文档创建/修改/删除），立即调用视图获取最新统计，然后用PUT请求更新统计文档：

  // 简化的Node.js示例逻辑
  const fetch = require('node-fetch');
  
  async function updateStats(dbName) {
    // 获取视图统计
    const viewRes = await fetch(`http://couchdb:5984/${dbName}/_design/type-stats/_view/counts?reduce=true&group=true`);
    const { rows } = await viewRes.json();
    const counts = rows.reduce((acc, row) => {
      acc[row.key] = row.value;
      return acc;
    }, {});
  
    // 更新统计文档
    try {
      // 先获取现有文档的_rev
      const docRes = await fetch(`http://couchdb:5984/${dbName}/doc_type_counts`);
      const doc = await docRes.json();
      doc.counts = counts;
      doc.last_updated = new Date().toISOString();
      await fetch(`http://couchdb:5984/${dbName}/doc_type_counts`, {
        method: 'PUT',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify(doc)
      });
    } catch (e) {
      // 如果文档不存在，创建新的
      await fetch(`http://couchdb:5984/${dbName}/doc_type_counts`, {
        method: 'PUT',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({
          _id: "doc_type_counts",
          type: "statistics",
          counts,
          last_updated: new Date().toISOString()
        })
      });
    }
  }
  
  // 启动变更监听
  async function listenChanges(dbName) {
    const res = await fetch(`http://couchdb:5984/${dbName}/_changes?feed=continuous&heartbeat=30000`);
    const reader = res.body.getReader();
    while (true) {
      const { done } = await reader.read();
      if (done) break;
      // 每次变更触发统计更新
      await updateStats(dbName);
    }
  }
  
  listenChanges('your-db');
  

• 这个方案能保证统计数据和文档变更几乎同步，适合对实时性要求高的场景。

3. 服务器端预提交钩子维护统计 #

如果追求极致性能，不想依赖视图查询，可以用CouchDB的预提交钩子，在文档写入时直接更新统计计数：

• 修改CouchDB的local.ini配置，启用预提交钩子：

  [hooks]
  pre_commit = /usr/local/bin/update-stats.py
  

• 写一个Python脚本，在文档提交时解析文档类型，更新统计文档的对应计数：

  # update-stats.py 示例
  import sys
  import json
  import requests
  import os
  from datetime import datetime
  
  def main():
    # 从标准输入获取待提交的文档
    doc = json.load(sys.stdin)
    db_url = os.environ.get('COUCHDB_DB_URL')
    doc_type = doc.get('type', 'unknown')
  
    # 获取现有统计文档
    try:
      stats_res = requests.get(f"{db_url}/doc_type_counts")
      stats_doc = stats_res.json()
    except:
      stats_doc = {
        "_id": "doc_type_counts",
        "type": "statistics",
        "counts": {}
      }
  
    # 更新计数（这里简化处理新增逻辑，删除逻辑需额外判断变更类型）
    if doc_type not in stats_doc['counts']:
      stats_doc['counts'][doc_type] = 0
    stats_doc['counts'][doc_type] += 1
    stats_doc['last_updated'] = datetime.now().isoformat()
  
    # 写回统计文档
    requests.put(f"{db_url}/doc_type_counts", json=stats_doc)
  
  if __name__ == "__main__":
    main()
  

• 注意：这个方案需要服务器端权限，且要处理文档删除、冲突等边缘情况，适合大规模数据库的高性能场景。

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