import psycopg2
import os

host = "XXX.redshift.amazonaws.com"
database = "XXX"
user = "XXX"
password = "XXXX"
port = "5439"

copy_cmd_str = "COPY widgets \
FROM 's3://XXX/dir_%s/%s' \
CREDENTIALS 'aws_access_key_id=%s;aws_secret_access_key=%s' \
EMPTYASNULL \
BLANKSASNULL \
CSV \
GZIP;" % (1, 2, os.environ['DUPA'], 4)

print copy_cmd_str

if False:
    conn = psycopg2.connect(dbname=database, host=host, user=user, password=password, port=port)
    conn

    cur = conn.cursor()

    cur.execute(copy_cmd_str)
    print cur.fetchone()

    conn.commit()

    cur.close()
    conn.close()