本地数据库上传云服务器

import psycopg2
import subprocess

# 本地数据库连接配置
local_conn = psycopg2.connect(
    host="localhost",
    database="mydatabase",
    user="myuser",
    password="mypassword"
)

# 云端数据库连接配置
cloud_conn = psycopg2.connect(
    host="your-cloud-host",
    database="mydatabase",
    user="myuser",
    password="mypassword"
)

# 创建备份文件
backup_file = "backup.sql"
subprocess.run(["pg_dump", "-U", "myuser", "-h", "localhost", "-F", "c", "-b", "-v", "-f", backup_file, "mydatabase"])

# 将备份文件传输到云端服务器
subprocess.run(["scp", backup_file, "your-cloud-user@your-cloud-host:/path/to/backup.sql"])

# 在云端恢复数据库
with cloud_conn.cursor() as cursor:
    cursor.execute("DROP DATABASE IF EXISTS mydatabase")
    cursor.execute("CREATE DATABASE mydatabase")
    cursor.execute(f"pg_restore -U myuser -h your-cloud-host -d mydatabase /path/to/backup.sql")

# 关闭连接
local_conn.close()
cloud_conn.close()