import psycopg2

conn = psycopg2.connect(
    host='etl.cscmn6ex0bdf.us-west-2.redshift.amazonaws.com', # this is the Levelset Redshift cluster
    user='{INSER_USER_HERE}',
    port=5439,
    password='{INSERT_PASS_HERE}',
    dbname='zlien')

sql = """
CREATE TABLE source_admin.teja_test (
  log_id int NOT NULL,
  losing_company_uuid varchar(255) DEFAULT NULL,
  losing_company_name varchar(255) DEFAULT NULL,
  gaining_company_uuid varchar(255) NOT NULL,
  gaining_company_name varchar(255) NOT NULL,
  source varchar(255) NOT NULL,
  timestamp datetime NOT NULL,
  losing_core_company_names varchar(max) DEFAULT NULL,
  PRIMARY KEY(log_id)
  )
;"""

cur = conn.cursor()

cur.execute(sql)
conn.commit()