Connect to Salesforce from AWS Glue jobs using the CData JDBC Driver hosted in Amazon S3. AWS Glue is an ETL service from Amazon that allows you to easily prepare and load your data for storage and analytics. Using the PySpark module along with AWS Glue, you can create jobs that work with data over JDBC connectivity, loading the data directly into AWS data stores. In this article, we walk through uploading the CData JDBC Driver for Salesforce into an Amazon S3 bucket and creating and running an AWS Glue job to extract Salesforce data and store it in S3 as a CSV file. Upload the CData JDBC Driver for Salesforce to an Amazon S3 Bucket In order to work with the CData JDBC Driver for Salesforce in AWS Glue, you will need to store it (and any relevant license files) in an Amazon S3 bucket. Open the Amazon S3 Console. Select an existing bucket (or create a new one). Click UploadSelect the JAR file (cdata.jdbc.salesforce.jar) found in the lib directory in the installation location for the driver. Configure the Amazon Glue Job Navigate to ETL -> Jobs from the AWS Glue Console. Click Add Job to create a new Glue job. Fill in the Job properties:Name: Fill in a name for the job, for example: SalesforceGlueJob.IAM Role: Select (or create) an IAM role that has the AWSGlueServiceRole and AmazonS3FullAccess permissions policies. The latter policy is necessary to access both the JDBC Driver and the output destination in Amazon S3.Type: Select "Spark".Glue Version: Select "Spark 2.4, Python 3 (Glue Version 1.0)".This job runs: Select "A new script to be authored by you". Populate the script properties: A name for the script file, for example: GlueSalesforceJDBC Fill in or browse to an S3 bucket. Fill in or browse to an S3 bucket. Expand . For Dependent jars path, fill in or browse to the S3 bucket where you uploaded the JAR file. Be sure to include the name of the JAR file itself in the path, i.e.: s3://mybucket/cdata.jdbc.salesforce.jarClick Next. Here you will have the option to add connection to other AWS endpoints. So, if your Destination is Redshift, MySQL, etc, you can create and use connections to those data sources. Click "Save job and edit script" to create the job. In the editor that opens, write a python script for the job. You can use the sample script (see below) as an example. Script file name: S3 path where the script is stored: Temporary directory: Security configuration, script libraries and job parameters (optional) Sample Glue Script To connect to Salesforce using the CData JDBC driver, you will need to create a JDBC URL, populating the necessary connection properties. Additionally, you will need to set the property in the JDBC URL (unless you are using a Beta driver). You can view the licensing file included in the installation for information on how to set this property. RTK There are several authentication methods available for connecting to Salesforce: Login, OAuth, and SSO. The Login method requires you to have the username, password, and security token of the user. If you do not have access to the username and password or do not wish to require them, you can use OAuth authentication. SSO (single sign-on) can be used by setting the SSOProperties, SSOLoginUrl, and TokenUrl connection properties, which allow you to authenticate to an identity provider. See the "Getting Started" chapter in the help documentation for more information. Built-in Connection String Designer For assistance in constructing the JDBC URL, use the connection string designer built into the Salesforce JDBC Driver. Either double-click the JAR file or execute the JAR file from the command-line. view source java -jar cdata.jdbc.salesforce.jar Fill in the connection properties and copy the connection string to the clipboard. To host the JDBC driver in Amazon S3, you will need a license (full or trial) and a Runtime Key (RTK). For more information on obtaining this license (or a trial), . contact our sales team Below is a sample script that uses the CData JDBC driver with the PySpark and AWSGlue modules to extract Salesforce data and write it to an S3 bucket in CSV format. Make any necessary changes to the script to suit your needs and save the job. view source sys awsglue.transforms * awsglue.utils getResolvedOptions pyspark.context SparkContext awsglue.context GlueContext awsglue.dynamicframe DynamicFrame awsglue.job Job
 
args = getResolvedOptions(sys.argv, [ ])
 
sparkContext = SparkContext()
glueContext = GlueContext(sparkContext)
sparkSession = glueContext.spark_session
 
##Use the CData JDBC driver to read Salesforce data the Account table into a DataFrame
##Note the populated JDBC URL and driver = sparkSession.read.format( ).option( , ).option( , ).option( , ).load()
 
glueJob = Job(glueContext)
glueJob.init(args[ ], args)
 
##Convert DataFrames to AWS Glue import from import from import from import from import from import from import 'JOB_NAME' from class name source_df "jdbc" "url" "jdbc:salesforce:RTK=5246...;User=username;Password=password;SecurityToken=Your_Security_Token;" "dbtable" "Account" "driver" "cdata.jdbc.salesforce.SalesforceDriver" 'JOB_NAME' 's DynamicFrames Object
dynamic_dframe = DynamicFrame.fromDF(source_df, glueContext, "dynamic_df")
 
##Write the DynamicFrame as a file in CSV format to a folder in an S3 bucket.
##It is possible to write to any Amazon data store (SQL Server, Redshift, etc) by using any previously defined connections.
retDatasink4 = glueContext.write_dynamic_frame.from_options(frame = dynamic_dframe, connection_type = "s3", connection_options = {"path": "s3://mybucket/outfiles"}, format = "csv", transformation_ctx = "datasink4")
 
glueJob.commit() Run the Glue Job With the script written, we are ready to run the Glue job. Click Run Job and wait for the extract/load to complete. You can view the status of the job from the Jobs page in the AWS Glue Console. Once the Job has succeeded, you will have a CSV file in your S3 bucket with data from the Salesforce Account table. Using the CData JDBC Driver for Salesforce in AWS Glue, you can easily create ETL jobs for Salesforce data, whether writing the data to an S3 bucket or loading it into any other AWS data store.

Amazon

Glue

How to Connect to Salesforce Data in AWS Glue Jobs Using JDBC

About Author

Comments

TOPICS

THIS ARTICLE WAS FEATURED IN

Related Stories

A Guide to Authoring Power BI Reports on Real-Time Google Sheets Data

101 Stories To Learn About Cloud Infrastructure

10 Things in Engineering We Don't Spend Enough Time On

10 Things I Did To Increase CloudTrail Logs Security

10 reasons to give cloud computing a go

10 Lessons from 10 Years of AWS (part 1)

A Guide to Authoring Power BI Reports on Real-Time Google Sheets Data

101 Stories To Learn About Cloud Infrastructure

10 Things in Engineering We Don't Spend Enough Time On

10 Things I Did To Increase CloudTrail Logs Security

10 reasons to give cloud computing a go

10 Lessons from 10 Years of AWS (part 1)

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps