in lambda/lambda-pg-generator/postgresql.py [0:0]
def lambda_handler(event, context):
begining = datetime.datetime.now()
newtime = begining
con = psycopg2.connect(host=RDS_ENDPOINT, database='sourcemf', user='sourcemf', password=get_secret())
cur = con.cursor()
#sql = 'drop table if exists cidade'
#cur.execute(sql)
cur.execute('''CREATE TABLE IF NOT EXISTS transactions
( trans_id serial primary key,
account_id INT,
date TIMESTAMP,
type varchar(10),
operation varchar(3),
amount INT,
balance INT );''')
#cur.execute(sql)
#sql = "insert into transactions values (default,1,'2016-06-22 19:10:25-07','credit','CAB',10,10)"
##cur.execute(sql)
con.commit()
while (newtime - begining).total_seconds()<5:
#result=db.customers.insert(getReferrer())
sql=getSQL()
newtime = datetime.datetime.now()
cur.execute(sql)
con.commit()
cur.execute('select * from transactions limit 10')
#cur.execute('select max(trans_id) from transactions')
recset = cur.fetchall()
print('select * from transactions limit 10')
for rec in recset:
print('tuple')
print (rec)
print('rec[2]')
print (rec[2])
con.close()