- A: The blog outlines:
Create a source (OLTP) table
Use Python (and libraries like snowflake-connector-python, sqlalchemy, pandas) to load data into Snowflake
Create a Snowflake Stream object on that table to capture changes (captures metadata such as METADATA$ACTION, METADATA$ROWID, etc.)
Use a SQL MERGE into a final target table to apply inserts/updates/deletes based on captured changes.
