Python 使用 psycopg2 将 DateFrame 写入 AWS redshift

Question

我想每天更新 AWS 中的表，我计划做的是首先使用 Python psycopg2 在 AWS 中删除公共表中的数据/行，然后将 python 数据帧数据插入该表中。

import psycopg2

import pandas as pd

con=psycopg2.connect(dbname= My_Credential.....)

cur = con.cursor()

sql = """

DELETE FROM tableA

"""

cur.execute(sql)

con.commit()

上面的代码可以做删除，但是我不知道如何编写python代码将My_Dataframe插入到tableA中。TableA 大小大约是 100 万行到 500 万行，请指教。

Answer 1

关于如何在下面的 conde 中传递连接字符串代替连接详细信息的任何建议：-conn = psycopg2.connect(dbname ='' ,host='' ...) i am looking to pass like this ..conn = psycopg2.connect('Connection_String')