in functions/source/bootstrap_redshift/bootstrap_redshift.py [0:0]
def save_customers_data(csv_data, cursor, connection):
customers = []
count = 1
for row in csv_data:
if count > 1 and len(row) >= 13:
if row[11].lower() == 'null' or row[11] == '':
row[11] = None
data = {'customernumber': row[0], 'customername': row[1], \
'contactlastname': row[2], \
'contactfirstname': row[3], \
'phone': row[4], 'addressline1': row[5], 'addressline2': row[6], 'city': row[7], 'state': row[8],
'postalcode': row[9], 'country': row[10], 'salesrepemployeenumber': row[11], 'creditlimit': row[12]}
customers.append(data)
else:
count = count + 1
query = """ insert into customers(customernumber,customername,contactlastname,contactfirstname,phone,addressline1,addressline2,city,state,postalcode,country,salesrepemployeenumber,creditlimit)
values (%(customernumber)s,%(customername)s,%(contactlastname)s,%(contactfirstname)s,%(phone)s,%(addressline1)s,%(addressline2)s,%(city)s,%(state)s,%(postalcode)s,%(country)s,%(salesrepemployeenumber)s,%(creditlimit)s) """
cursor.executemany(query, customers)
connection.commit()