import psycopg2 import boto3
conn = psycopg2.connect(host=HOST, dbname=DBNAME, user=USER, password=PASSWORD) cursor = conn.cursor()
query = "SELECT * FROM mytable WHERE column1 = 'value'" cursor.execute(query)
s3 = boto3.resource('s3') bucket = s3.Bucket('mybucket')
with open('output.csv', 'w') as f: cursor.copy_expert("COPY ({0}) TO STDOUT WITH CSV HEADER".format(query), f) bucket.upload_file('output.csv', 'path/to/output.csv')