Hi, I have a requirement to load data from Salesforce to Redshift. It is supposed to be a DELTA load every 2 hours (meaning capture only the changes that have occurred in source data after last execu...
Here is a sample pipeline to do just that. The key concept is to extract SFDC data from where you left off by 1st finding the max LastModifiedDate and use it in your SOQL as a condition to pull the net change.
Note: all timestamp store in Redshift is default to UTC
