All projects
Solution2024LTK (RewardStyle)

Billing medallion architecture & orchestration migration

Bronze/silver/gold billing pipelines on S3, change-data-capture services migrated to Airflow, and a reliable refunds path into Redshift.

Problem

A legacy orchestrator was being retired while billing and refunds data needed a medallion architecture. Change-data-capture tables behaved differently across environments, and new payment and refund tables needed merges, data-quality checks, and warehouse loads.

Approach

Migrate billing CDC pipelines to Airflow with custom SQL and primary-key tests. Deploy bronze-to-silver dedup for change-data-capture operations, then ship the refunds orchestration path to production.

Architecture

Medallion billing path

CDC microservices through bronze, silver dedup, and gold into Redshift.

Drag nodes to explore the flow

Solution highlights

Airflow cutover

Legacy orchestrator retired; billing CDC pipelines moved to Airflow with prod-safe table references.

Medallion on S3

Bronze, silver, and gold buckets with Athena merges and Glue jobs.

Refunds path to prod

Refunds orchestration deployed and the Redshift load path validated.

Data-quality gates

Custom SQL and primary-key tests for the new Airflow patterns.

Environment parity

CDC behavior reconciled so dev and prod pipelines matched.

AirflowMWAAAthenaGlueRedshiftMedallion