Skip to content

Conversation

@mlevin19
Copy link
Contributor

@mlevin19 mlevin19 commented Aug 18, 2021

Added Scala Notebook that migrates Snowflake schema to Synapse dedicated pool.
ADF , as well as Synapse pipeline requires multiple step to get data from Snowflake table to the table in SQL dedicated pool in Synapse. You need first copy data to BLOB storage and then you load the file from BLOB storage into Synapse table.
This notebook is using simple approach reading data from Snowflake table for given schema into Spark Data Frame and then write this Data Frame into Synapse SQL dedicated pool table. It uses schema name as parameter, providing ability to move all tables from given schema to SQL dedicated pool schema. The stored procedure that initiate database objects provided in the comments.

@ghost
Copy link

ghost commented Aug 18, 2021

CLA assistant check
All CLA requirements met.

@ruixinxu
Copy link
Contributor

ruixinxu commented Sep 1, 2021

hi @mlevin19 thanks for sending the PR, here are some suggestions to improve it.

  1. cell 1. Please add the link to download spark-snowflake_2.12-2.9.0-spark_3.1.jar and snowflake-jdbc-3.13.6.jar .
  2. cell 1. Please add the link to the instruction how to add customized jars to cluster/session packages
  3. cell 2, Please change the schema value to parameter that user need to specify .e.g. val sfschema = ""
  4. cell 3, Please add a link to instruction of configuring Azure Key Vault.
  5. cell 3, Please change the get secret input as parameters user need to specify. e.g. mssparkutils.credentials.getSecret("azure key vault name","secret name","linked service name")

added downloads links to cell1
added links for Azure Key Vault configuration
changed name of schema for testing
@mlevin19
Copy link
Contributor Author

mlevin19 commented Sep 1, 2021

Hi @ruixinxu , I added all your recommendations. Please review and let me know if anything need to be changed/corrected. Thanks!

@ruixinxu ruixinxu merged commit c335d6f into Azure-Samples:main Sep 2, 2021
@mlevin19 mlevin19 deleted the movefromsnowflake branch September 2, 2021 15:41
@mlevin19 mlevin19 restored the movefromsnowflake branch January 6, 2022 17:51
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants