importpsycopg2conn=psycopg2.connect(host='etl.cscmn6ex0bdf.us-west-2.redshift.amazonaws.com',# this is the Levelset Redshift clusteruser='{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()
Comments (0)
HTTPSSSH
You can clone a snippet to your computer for local editing.
Learn more.