将本地系统上的csv文件加载到redshift数据库

import psycopg2

# 连接到Redshift数据库
conn = psycopg2.connect(
    host='your-redshift-host',
    port='your-redshift-port',
    dbname='your-redshift-dbname',
    user='your-redshift-username',
    password='your-redshift-password'
)

# 创建一个游标对象
cur = conn.cursor()

# 创建一个表来存储CSV文件的数据
cur.execute('CREATE TABLE IF NOT EXISTS my_table (column1 datatype1, column2 datatype2, ...)')

# 使用COPY命令将CSV文件加载到表中
cur.execute("COPY my_table FROM 's3://your-bucket/your-file.csv' CREDENTIALS 'aws_access_key_id=your-access-key;aws_secret_access_key=your-secret-key' CSV")

# 提交事务并关闭连接
conn.commit()
cur.close()
conn.close()