Sync Salesforce to Snowflake

Salesforce is where the pipeline lives. Snowflake is where the company measures it against everything else: product usage, billing, support, marketing spend. Getting Salesforce into the warehouse usually means a managed connector you cannot see into, a nightly job that is hours stale, or a bulk export someone schedules and forgets.

• Accounts, opportunities, and custom objects land in Snowflake on the next poll using Salesforce Change Data Capture, not on a nightly cycle
• Every load is an ordered run log, so a number that looks off in a board can be traced to the exact sync and row that wrote it
• Deleted and merged Salesforce records become soft deletes, so a historical report does not silently change
• Model output, a fit score or a health segment, is written back to Salesforce on a schedule so reps see the same number as the analyst

The load flow most teams turn on first.

Salesforce Opportunity changes into ANALYTICS.CRM.OPPORTUNITY, streamed

Change-driven through CDC, with a scheduled full reconcile so nothing drifts.

1. 1Trigger: Salesforce New or updated record on Opportunity via Change Data Capture, batched every 10 seconds.
2. 2Shape: map the CDC payload to the target column names and types using the table below, keeping the full change event in a _RAW column.
3. 3Stage: for a batch above 5,000 rows, write to a stage and COPY INTO a scratch table. Below that, pass rows straight to the merge.
4. 4Merge: MERGE INTO ANALYTICS.CRM.OPPORTUNITY t USING :batch s ON t.ID = s.ID, update on match, insert when not matched.
5. 5Deletes: a Deleted record event sets IS_DELETED = TRUE and DELETED_AT = CURRENT_TIMESTAMP() rather than removing the row.
6. 6Watermark: write the max SystemModstamp seen to a control table, so a replay knows where to resume.
7. 7Nightly reconcile: a scheduled flow runs a bounded SOQL query and merges the result, catching anything a gap in the CDC stream dropped.

The starting map for the Opportunity to ANALYTICS.CRM.OPPORTUNITY step.

• Core and custom objects. Account, Contact, Opportunity, Lead, Case, and any custom object land as typed tables plus a raw VARIANT column. (Salesforce to Snowflake)
• Field history and activity. Field history, tasks, events, and email activity stream into event tables for stage-velocity and activity modeling. (Salesforce to Snowflake)
• Scores and segments. A model table of account fit, health, or propensity is written back to Salesforce custom fields on a schedule. (Snowflake to Salesforce)
• Enrichment and hygiene. Firmographic fields, deduped account hierarchies, and do-not-contact flags computed in the warehouse update the matching Salesforce records. (Snowflake to Salesforce)

The same controls apply to this sync as to every other Neblex workload.

• Ordered run log. Every load is an event log with the batch, the merge statement, and row counts. Replay a run without re-reading from Salesforce.
• Approval on write-back. Reverse-ETL flows that change Salesforce data can pause for review before the first run of a changed mapping.
• Scoped access. Salesforce uses a connected app and a permission set limited to the synced objects. Snowflake uses a role with grants on the target schema only.
• Environments. Build against a Salesforce sandbox and a Snowflake scratch schema, then promote the same flow to production.