YjvCLrjC

1from redshift_utils import Messages
2from redshift_utils import ScriptReader
3from redshift_utils import RedshiftDataManager
4from settings import SCRIPT_PATH 
5from settings import DB_CONNECTION
6
7def lambda_handler(event, context):  
8    ## script = ScriptReader.get_script(SCRIPT_PATH)
9    ## return RedshiftDataManager.run_update(script, DB_CONNECTION)
10    user = 'lseactuary'
11    table = ['public.en_dtln_p01', 'public.en_cgnv_p02']
12    script = "create user {0}_user".format(user)"password disable; grant select on {public.en_dtln_p01} to {0}_user;" 
13    ## script = "create table is not exists public.test_{0} (customer_id varchar, datefield date);".format(user)
14    ## script = "create table if not exists public.sample_table1 (customer_id varchar, datefield date); create table if not exists public.sample_table2 (customer_id varchar, datefield date);"
15    return RedshiftDataManager.run_update(script, DB_CONNECTION)