如何将PostgreSQL中的Etherpad数据迁移至本地Redis 1号数据库？

嘿，我来帮你搞定这个迁移问题！既然Etherpad的数据是简单键值对，那迁移起来其实挺直接的，下面给你两种靠谱的方法，你可以根据自己的情况选：

方法一：用SQL导出+Redis命令行导入（适合快速操作） #

这种方法不需要写代码，直接用数据库和Redis自带的工具就能搞定：

1. 从PostgreSQL导出符合Redis格式的数据 #

假设你的Etherpad数据存在名为etherpad_store的表里，字段是key（存储键）和value（存储内容），先连接到PostgreSQL数据库，执行以下COPY命令生成Redis的SET命令文件：

COPY (
  SELECT 'SET ' || quote_literal(key) || ' ' || quote_literal(value)
  FROM etherpad_store
) TO '/tmp/etherpad_redis_migrate.txt';

这里用quote_literal是为了自动转义值里的特殊字符（比如引号、换行），避免导入时出错。导出的文件每行都是一条SET 键 值命令。

2. 导入到Redis 1号数据库 #

打开终端，用redis-cli的-n 1参数指定1号数据库，直接执行导出的命令文件：

# 小数据量用这个方式即可
redis-cli -n 1 < /tmp/etherpad_redis_migrate.txt

# 如果数据量很大，用--pipe模式更高效，支持批量处理
cat /tmp/etherpad_redis_migrate.txt | redis-cli -n 1 --pipe

方法二：用Python脚本迁移（适合复杂场景/大数据量） #

如果你的数据里有很多特殊字符，或者想更灵活地控制迁移过程，用Python脚本会更稳妥：

1. 安装依赖包 #

先装好PostgreSQL和Redis的Python驱动：

pip install psycopg2-binary redis

2. 编写迁移脚本 #

创建一个migrate_etherpad.py文件，内容如下：

import psycopg2
import redis

# 配置PostgreSQL连接信息
pg_config = {
    "dbname": "你的PostgreSQL数据库名",
    "user": "数据库用户名",
    "password": "数据库密码",
    "host": "localhost"
}

# 连接Redis的1号数据库
redis_client = redis.Redis(host="localhost", port=6379, db=1)

def migrate_data():
    # 连接PostgreSQL，用with自动管理连接关闭
    with psycopg2.connect(**pg_config) as pg_conn:
        with pg_conn.cursor() as pg_cursor:
            # 分批获取数据，避免一次性加载太多导致内存溢出
            pg_cursor.execute("SELECT key, value FROM etherpad_store")
            batch_size = 1000  # 每次取1000条，可根据你的服务器内存调整
            while True:
                rows = pg_cursor.fetchmany(batch_size)
                if not rows:
                    break
                # 批量插入Redis，比单条SET命令效率高很多
                redis_client.mset(dict(rows))
                print(f"已迁移 {len(rows)} 条数据")

if __name__ == "__main__":
    migrate_data()
    print("数据迁移完成！")

3. 执行脚本 #

运行脚本开始迁移：

python migrate_etherpad.py

迁移前的重要注意事项 #

• 先备份PostgreSQL的数据！可以用pg_dump做个全量备份，以防迁移过程中出问题。
• 迁移前建议先测试一小部分数据，比如在SQL里加LIMIT 10，验证导入到Redis后内容完全一致。
• 迁移完成后，对比Redis的键数量（执行redis-cli -n 1 DBSIZE）和PostgreSQL的行数（执行SELECT COUNT(*) FROM etherpad_store），确保数据没有丢失。

内容的提问来源于stack exchange，提问作者We are Borg