Reputation: 11
scenario
I have glue catalog and I need to load this data from catalog to redshift.
dyf = glueContext.create_dynamic_frame.from_catalog(
database=catalog_db,
table_name=f"{table}",
push_down_predicate=f"day = {day}"
)
glueContext.write_dynamic_frame.from_jdbc_conf(
frame=DynamicFrame.fromDF(df, glueContext, "trx_df"),
catalog_connection="redshift_connection",
connection_options={
"database": database,
"dbtable": f"{schema}.{table}"
},
redshift_tmp_dir= "s3://"
using this i am writing, redshift_connection this my redshift connection which is my redshift established connection on aws connection.it loading data daily
Requirement:
Upvotes: 0
Views: 53