示例：使用 SWAPDB 命令实行在线替换数据库

正如上一节所说，SWAPDB 命令可以以非阻塞方式互换给定的两个数据库。因为这个命令的执行速度是如此之快，并且完全不会阻塞服务器，所以用户实际上可以使用这个命令来实行在线的数据库替换操作。

举个例子，假设我们拥有一个 Redis 服务器，它的 0 号数据库储存了用户的邮件地址以及经过加密的用户密码，这些数据可以用于登录用户账号。不幸的是，因为一次漏洞事故，这个服务器遭到了黑客入侵，并且经过确认，这个服务器储存的所有用户密码均已泄露。为了保障用户的信息安全，我们决定立即重置所有用户密码，具体的做法是：遍历所有用户的个人档案，为每个用户生成一个新的随机密码，并使用这个新密码替换已经泄露的旧密码。

代码清单 11-4 展示了一个用于重置用户密码的脚本，它的 reset_user_password() 函数会迭代 origin 数据库中的所有用户数据，为他们生成新密码，并将更新后的用户信息储存到 new 数据库里面。在此之后，函数会使用 SWAPDB 命令互换新旧两个数据库，并以异步方式移除旧数据库。

代码清单 11-4 用于重置用户密码的脚本代码：/database/reset_user_password.py

import random
 
from redis import Redis
from hashlib import sha256
 
def generate_new_password():
    random_string = str(random.getrandbits(256)).encode('utf-8')
    return sha256(random_string).hexdigest()
 
def reset_user_password(origin, new):
    # 两个客户端，分别连接两个数据库
    origin_db = Redis(db=origin)
    new_db = Redis(db=new)
 
    for key in origin_db.scan_iter(match="user::*"):
        # 从源数据库获取现有用户信息
        user_data = origin_db.hgetall(key)
        # 重置用户密码
        user_data["password"] = generate_new_password()
        # 将新的用户信息储存到新数据库里面
        new_db.hmset(key, user_data)
 
    # 互换新旧数据库
    origin_db.swapdb(origin, new)
 
    # 以异步方式移除旧数据库
    # （new_db 变量现在已经指向旧数据库）
    new_db.flushdb(asynchronous=True)

作为例子，表 11-5 和表 11-6 分别展示了设置新密码之前和之后的用户数据。注意，为了凸显新旧密码之间的区别，重置之前的用户密码是未经加密的。

表 11-5 重置之前的用户数据

表 11-6 重置之后的用户数据