Sync Salesforce leads and opportunities to PostgreSQL with backfill and incremental ETL
Fetch Opportunity Records
salesforce
Normalize Output Fields
Merge All Streams
Set Historical Date Range
Generate Weekly Periods
Loop Over Date Periods
noOp
Normalize Lead Phone (+62)
Normalize Opportunity Phone (+62)
Fetch Lead Records
salesforce
Upsert Rows into Postgres
postgres
Schedule Trigger (Incremental)
Manual Trigger (Historical Backfill)
Merge Lead with Opportunity
Set Incremental Dates
Remove Duplicate Opportunities
removeDuplicates
Phone empty? (Lead)
Phone empty? (Opportunity)
Press enter or space to select a node. You can then use the arrow keys to move the node around. Press delete to remove it and escape to cancel.
Press enter or space to select an edge. You can then press delete to remove it or escape to cancel.