#Open a connection and create a cursor object to perform database operations
conn = z.getDatasource("zepl_docs_redshift")
# Create table called zepl_doc if not exists
cur.execute(""" create table IF NOT exists zepl_doc(
salesid integer not null,
listid varchar not null distkey) """)
# Insert data (100, "xyz") into the table zepl_doc
cur.execute("INSERT INTO zepl_doc (salesid, listid) VALUES (%s, %s)", (100, "xyz"))
# Persist changes to the database
# Close communication with the database