您可以to_sql
用来将数据推送到Redshift数据库。通过使用sqlAlchemy引擎与数据库的连接,我已经能够做到这一点。只要确保index = False
在to_sql
通话中进行设置即可。如果该表不存在,则将创建该表,并且您可以指定是否要调用以替换该表,追加到该表,或者如果该表已存在则失败。
from sqlalchemy import create_engine
import pandas as pd
conn = create_engine('postgresql://username:password@yoururl.com:5439/yourdatabase')
df = pd.DataFrame([{'A': 'foo', 'B': 'green', 'C': 11},{'A':'bar', 'B':'blue', 'C': 20}])
df.to_sql('your_table', conn, index=False, if_exists='replace')
请注意,您可能需要pip install psycopg2
通过sqlAlchemy连接到Redshift。