how to use dlt module in streaming pipeline

[rt-slowth]

If anyone has example code for building a CDC live streaming pipeline generated by AWS DMS using import dlt, I'd love to see it.
I'm currently able to see the parquet file starting with Load on the first full load to S3 and the cdc parquet file after that, but it doesn't work with @dlt.create_table, so I'd like to see how to do it.

[Kaniz · Accepted solution]

Hi @rt-slowth , 

Certainly! Let’s explore how to create a Change Data Capture (CDC) live streaming pipeline using Delta Live Tables and AWS Database Migration Service (DMS).

1. Delta Live Tables and AWS DMS:

   • Delta Live Tables is an open-source storage layer that brings reliability to data lakes. It provides ACID transactions, scalable metadata handling, and unifies streaming and batch data processing.
   • AWS DMS is a service that helps migrate data from various sources to AWS services. In this case, we’ll capture changes from multiple RDBMS data sources.

2. GitHub Repository:

   • You can find a complete end-to-end example with Terraform, Delta Live Tables, AWS RDS, and AWS DMS in this GitHub repository.