如何将Python DataFrame追加存储至Digital Ocean数据库？

1. 网络与防火墙检查 #

• 先确认Digital Ocean Droplet的防火墙规则，把你运行脚本的机器IP加入允许访问列表，Droplet默认会限制数据库端口的外部访问。
• 用ping <你的host地址>或者telnet <你的host地址> <端口号>测试网络连通性，确保端口是开放状态。

2. 连接参数修正 #

• port参数必须是整数类型，别用字符串（比如把"5432"改成5432），psycopg2不接受字符串格式的端口值。
• 核对数据库页面给出的host、database、user、password是否完全匹配，别漏了域名后缀或者多打了空格。

3. 适配pandas的连接方式 #

pandas的to_sql和psycopg2直接连接兼容性不好，改用SQLAlchemy引擎包装连接，修改代码如下：

from sqlalchemy import create_engine

conn_params = {
        "host": "你的主机地址",
        "database": "你的数据库名",
        "user": "你的用户名",
        "password": "你的密码",
        "port": 5432  # 改为整数
}

# 构建SQLAlchemy引擎
engine = create_engine(f"postgresql+psycopg2://{conn_params['user']}:{conn_params['password']}@{conn_params['host']}:{conn_params['port']}/{conn_params['database']}")

# 用引擎执行插入
with engine.connect() as conn:
    df.to_sql("mydata", conn, if_exists="append", index=False)

4. 权限与表结构验证 #

• 确认你的数据库用户拥有mydata表的INSERT权限，以及该数据库的连接权限。
• 检查mydata表是否存在，且表的列名、数据类型和你的DataFrame完全匹配，类型不匹配会直接导致插入失败。

5. 捕获具体错误信息 #

在代码里加异常捕获，拿到准确错误内容才能更快定位问题：

try:
    # 这里放你的连接和插入代码
except Exception as e:
    print(f"错误详情: {str(e)}")

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