def lambda_handler()

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()