如何实现CouchDB条件性复制？仅当版本匹配时触发复制

CouchDB内置的_replicator文档本身不支持直接编写条件判断逻辑来动态控制复制任务的启停，所以需要通过外部脚本校验版本+触发复制的方式来实现你的需求，以下是具体步骤：

1. 版本信息的读取方式 #

假设自定义版本号存在各自数据库的version_doc文档中，可通过HTTP请求直接读取：

• 读取CouchDB_A中database_A的version_A：

  curl -X GET http://couchdb_a_host:5984/database_A/version_doc | jq .version_A
  

• 读取CouchDB_B中database_B的version_B：

  curl -X GET http://couchdb_b_host:5984/database_B/version_doc | jq .version_B
  

2. 编写脚本实现版本校验与复制触发 #

用Shell脚本就能轻松实现你想要的逻辑，脚本会自动完成版本比对，只有当版本相等时才创建_replicator文档启动复制：

Shell脚本示例 #

#!/bin/bash

# 配置CouchDB连接参数（替换为你的实际地址和账号）
COUCHDB_A="http://admin:your_password@couchdb_a:5984"
COUCHDB_B="http://admin:your_password@couchdb_b:5984"
VERSION_DOC="version_doc" # 存储版本号的文档ID

# 获取本地版本号
local_version=$(curl -s "$COUCHDB_A/database_A/$VERSION_DOC" | jq -r '.version_A')
# 获取远程版本号
remote_version=$(curl -s "$COUCHDB_B/database_B/$VERSION_DOC" | jq -r '.version_B')

# 版本匹配判断
if [ "$local_version" = "$remote_version" ]; then
  echo "版本匹配（$local_version = $remote_version），启动复制任务..."
  # 构造复制任务文档
  replicator_doc='{
    "_id": "a_to_b_replication",
    "source": "'"$COUCHDB_A/database_A"'",
    "target": "'"$COUCHDB_B/database_B"'",
    "continuous": false, # 设为true可开启持续复制，按需选择
    "create_target": false
  }'
  # 将复制任务写入CouchDB_A的_replicator数据库
  curl -X PUT "$COUCHDB_A/_replicator/a_to_b_replication" \
       -H "Content-Type: application/json" \
       -d "$replicator_doc"
else
  echo "版本不匹配（$local_version != $remote_version），跳过复制"
  # 可选：如果之前存在复制任务，可删除它
  curl -X DELETE "$COUCHDB_A/_replicator/a_to_b_replication" 2>/dev/null
fi

使用说明 #

• 脚本执行后，CouchDB会自动检测_replicator数据库中的新文档并启动复制；
• 如果需要持续监控版本变化，可将脚本加入定时任务（比如Linux的crontab），定期执行版本校验逻辑。

3. 进阶：用筛选器实现文档级版本过滤（仅适用于持续复制） #

如果是持续复制场景，还可以配合CouchDB的筛选器函数，确保只有版本匹配时才复制文档，但这种方式无法控制复制任务的启停，只能过滤要复制的文档：

1. 在database_A中创建设计文档，定义筛选器：

{
  "_id": "_design/version_check",
  "filters": {
    "match_version": "function(doc, req) {
      // 从请求参数传入远程版本，或读取本地全局版本文档
      var remote_v = req.query.remote_version;
      var local_v = doc.version_A; // 假设每个文档带version_A，或读取全局版本
      return local_v === remote_v;
    }"
  }
}

2. 在复制文档中指定筛选器和版本参数：

{
  "_id": "a_to_b_replication",
  "source": "database_A",
  "target": "http://couchdb_b:5984/database_B",
  "continuous": true,
  "filter": "version_check/match_version",
  "query_params": {"remote_version": "2.0"}
}

不过这种方式需要手动维护版本参数，灵活性不如外部脚本，更适合固定版本的持续复制场景。

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