CDC: DynamoDB to Databricks | Real-Time Replication Guide
Real-time Change Data Capture from DynamoDB to Databricks with exactly-once delivery, order-token guards, and tombstone anti-resurrect protection.
Source: DynamoDB. Destination: Databricks.
CDC apply: Unity Catalog MERGE.
Sample config
yaml
skippr:
workspace: cdc_dynamodb_to_databricks
pipelines:
cdc_dynamodb_to_databricks:
data_source: data_sources.source
data_sink: data_sinks.warehouse
cdc:
default:
business_key_columns:
- id
data_sources:
source:
Dynamodb:
table_name: my_table
region: us-east-1
cdc_mode: snapshot_then_cdc
data_sinks:
warehouse:
Databricks:
workspace_url: "https://dbc-xxx.cloud.databricks.com"
token: "${DATABRICKS_TOKEN}"
catalog: main
schema: defaultEnvironment
bash
export DATABRICKS_TOKEN="dapi..."
export AWS_ACCESS_KEY_ID="your-key"
export AWS_SECRET_ACCESS_KEY="your-secret"Source connector: dynamodb. Destination connector: databricks.
See CDC overview.
