我正在尝试使用 pandas 和 sqlalchemy 将数据加载到 redshift

Question

当我第一次尝试加载能够创建表并加载到该表中的 pandas 时，第二次它会抛出类似 Relation "mytablename" already exists

之类的错误

df = pd.read_csv("data.csv",sep = "|")
conn = create_engine('redshift+psycopg2://uname:pass@xxxxxxxxx.us-east-
1.redshift.amazonaws.com:5439/db')
df.to_sql("my table name",con = conn,if_exists = "append",index = False)

sqlalchemy.版本 = '1.1.9' pandas.版本 = '0.20.3'

Answer 1

您必须传递 sqlalchemy 引擎而不是连接对象。试试这个，

df = pd.read_csv('data.csv',sep = '|')
conn = create_engine('redshift+psycopg2://uname:pass@xxxxxxxxx.us-east-
1.redshift.amazonaws.com:5439/db')
df.to_sql('my table name', conn, if_exists = 'append',index = False)

如果我做了一个错误的假设，请发表评论，我会重新调整我的答案。