@@ -43,8 +43,7 @@ df = wr.s3.read_parquet("s3://bucket/dataset/", dataset=True)
4343# Retrieving the data from Amazon Athena
4444df = wr.athena.read_sql_query(" SELECT * FROM my_table" , database = " my_db" )
4545
46- # Getting Redshift connection (SQLAlchemy) from Glue Catalog Connections
47- # Retrieving the data from Amazon Redshift Spectrum
46+ # Get Redshift connection (SQLAlchemy) from Glue Catalog and retrieving data from Redshift Spectrum
4847engine = wr.catalog.get_engine(" my-redshift-connection" )
4948df = wr.db.read_sql_query(" SELECT * FROM external_schema.my_table" , con = engine)
5049
@@ -58,16 +57,13 @@ wr.quicksight.create_athena_dataset(
5857 allowed_to_manage = [" username" ]
5958)
6059
61- # Getting MySQL connection (SQLAlchemy) from Glue Catalog Connections
62- # Load the data into MySQL
60+ # Get MySQL connection (SQLAlchemy) from Glue Catalog and LOAD the data into MySQL
6361engine = wr.catalog.get_engine(" my-mysql-connection" )
64- wr.db.to_sql(df, engine, schema = " test" , name = " my_table" )
62+ wr.db.to_sql(df, engine, schema = " test" , name = " my_table" )
6563
66- # Getting PostgreSQL connection (SQLAlchemy) from Glue Catalog Connections
67- # Load the data into PostgreSQL
64+ # Get PostgreSQL connection (SQLAlchemy) from Glue Catalog and LOAD the data into PostgreSQL
6865engine = wr.catalog.get_engine(" my-postgresql-connection" )
69- wr.db.to_sql(df, engine, schema = " test" , name = " my_table" )
70-
66+ wr.db.to_sql(df, engine, schema = " test" , name = " my_table" )
7167```
7268
7369## [ Read The Docs] ( https://aws-data-wrangler.readthedocs.io/ )
0 commit comments