import redis

# 本地 Redis
src = redis.Redis(host='localhost', port=6379, password='Zzh08165511', db=0, decode_responses=False)

# 远程 Redis
dst = redis.Redis(host='175.24.177.96', port=6379, password='Zzh08165511', db=0, decode_responses=False)

src_count = src.dbsize()
dst_count = dst.dbsize()
print(f"本地: {src_count} keys")
print(f"远程: {dst_count} keys")
print(f"需同步: {src_count - dst_count} keys")
print("")

# 获取所有本地 key
keys = src.keys()
total = len(keys)
synced = 0
updated = 0

for key in keys:
    try:
        data = src.dump(key)
        if data:
            ttl = src.ttl(key)
            if ttl < 0:
                ttl = 0
            # 检查远程是否已有此 key
            exists = dst.exists(key)
            dst.restore(key, ttl * 1000, data, replace=True)
            if exists:
                updated += 1
            else:
                synced += 1
            if (synced + updated) % 100 == 0:
                print(f"进度: {synced + updated}/{total}")
    except Exception as e:
        print(f"同步失败 {key}: {e}")

print(f"\n同步完成！")
print(f"新增: {synced} keys")
print(f"更新: {updated} keys")
print(f"远程现有: {dst.dbsize()} keys")