CouchDB1.7.1升级3.0时修复reduce null无效视图的方案咨询

实现思路 #

通过遍历全库设计文档，匹配reduce: null的无效字段并删除，保留正常视图配置，全程保留文档版本号避免更新冲突，不需要关闭升级校验即可完成前置修复。

前置依赖 #

安装Python请求库：

pip install requests

可直接使用的Python脚本 #

import requests

# -------------------------- 配置项 --------------------------
COUCHDB_URL = "http://127.0.0.1:5984"  # 你的CouchDB地址
USERNAME = "admin"                     # 管理员账号
PASSWORD = "your_password"             # 管理员密码
DRY_RUN = True  # 测试模式设为True，只会打印要修改的内容，不会实际提交；确认没问题再改成False
# 要处理的数据库列表，留空则自动遍历所有数据库
TARGET_DBS = []
# -----------------------------------------------------------

session = requests.Session()
session.auth = (USERNAME, PASSWORD)

def get_all_dbs():
    resp = session.get(f"{COUCHDB_URL}/_all_dbs")
    resp.raise_for_status()
    # 过滤掉系统库
    return [db for db in resp.json() if not db.startswith("_")]

def fix_design_docs(db_name):
    print(f"处理数据库: {db_name}")
    # 拉取所有设计文档，包含文档内容
    url = f"{COUCHDB_URL}/{db_name}/_all_docs?startkey=\"_design/\"&endkey=\"_design0\"&include_docs=true"
    resp = session.get(url)
    resp.raise_for_status()
    rows = resp.json()["rows"]
    
    updated_docs = []
    for row in rows:
        doc = row["doc"]
        if "views" not in doc:
            continue
        modified = False
        # 遍历所有视图
        for view_name, view_conf in doc["views"].items():
            # 匹配reduce为null的情况
            if "reduce" in view_conf and view_conf["reduce"] is None:
                del view_conf["reduce"]
                modified = True
                print(f"  清理视图: _design/{doc['_id'].split('/')[-1]}/_view/{view_name} 的无效reduce字段")
        if modified:
            updated_docs.append(doc)
    
    if not updated_docs:
        print(f"  数据库{db_name}无需要修复的设计文档")
        return
    
    if DRY_RUN:
        print(f"  测试模式：{db_name}有{len(updated_docs)}个设计文档待更新，未实际提交")
        return
    
    # 批量更新设计文档
    bulk_url = f"{COUCHDB_URL}/{db_name}/_bulk_docs"
    resp = session.post(bulk_url, json={"docs": updated_docs})
    resp.raise_for_status()
    print(f"  成功更新{len(updated_docs)}个设计文档")

if __name__ == "__main__":
    target_dbs = TARGET_DBS if TARGET_DBS else get_all_dbs()
    for db in target_dbs:
        try:
            fix_design_docs(db)
        except Exception as e:
            print(f"处理数据库{db}失败: {str(e)}")

使用说明 #

1. 先修改配置项中的CouchDB地址、账号密码，保持DRY_RUN = True运行一次脚本，确认要清理的视图符合预期
2. 清理前务必对所有数据库做全量备份，避免误操作
3. 确认待清理内容无误后，将DRY_RUN改为False运行即可完成批量修复
4. 修复完成后重新运行couchup升级流程，即可正常通过视图校验

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