in functions/source/bootstrap_redshift/bootstrap_redshift.py [0:0]
def save_orders_data(csv_data, cursor, connection):
orders = []
count = 1
for row in csv_data:
if count > 1 and len(row) >= 8:
row2 = row[2]
row2d = dateutil.parser.parse(row2).date()
row3 = row[3]
row3d = ''
if row3.lower() == 'null':
row3d = None
else:
row3d = dateutil.parser.parse(row3).date()
row1 = row[1]
row1d = ''
if row1.lower() == 'null':
row1d = None
else:
row1d = dateutil.parser.parse(row1).date()
data = {'ordernumber': row[0], 'orderdate': row1d, 'requireddate': row2d, 'shippeddate': row3d,
'status': row[4], 'comments': row[5], 'customernumber': row[6], 'current_year': row[7]}
orders.append(data)
logger.info('Order Date ..+++++++++' + row[1])
else:
count = count + 1
query = """ insert into orders(ordernumber,orderdate,requireddate,shippeddate,status,comments,customernumber,current_year) values (%(ordernumber)s,%(orderdate)s,%(requireddate)s,%(shippeddate)s,%(status)s,%(comments)s,%(customernumber)s,%(current_year)s) """
cursor.executemany(query, orders)
connection.commit()