DAQ Logo
ADAPTIVE AI &
DATA ENGINEERING.
Data Engineering / National Grocery Chain

Metadata-Driven ETL & Power BI

How we replaced 200+ hand-built pipelines with one configuration-driven framework, and put near-expiry stock in front of store managers while it could still be priced.

Supplier onboarding2wk → 4h
Legacy pipelines retired200+
Maintenance cost−60%
01 / The Challenge

What was breaking

Before

The client relied on 200+ hardcoded SSIS packages to ingest data from suppliers and POS systems. Onboarding a new supplier took 2 weeks of developer time. Data latency was high (T+48 hours), meaning store managers received 'Spoilage Reports' after items had already expired. They needed a scalable, automated solution to democratize data access and reduce operational overhead.

02 / Architecture

The platform we built

03 / Approach

How the framework works

After

We implemented a 'Metadata-Driven Ingestion Framework'. Instead of creating a pipeline for each source, we built a reusable 'Master Pipeline' in ADF that reads configuration (Source System, Schedule, Schema) from a SQL Control Table. This dynamic approach allows the client to onboard new data sources by simply inserting a row into a table—zero code required. We modeled a Star Schema in Synapse and built a Power BI 'Store Manager Dashboard' for real-time inventory tracking.

04 / Configuration

Driven by config, not code

The entire pipeline is driven by deterministic JSON configurations. Onboarding a new global supplier data source requires exactly zero code compilation.

  • Schema drift handled in config
  • Quality rules enforced per source
pipeline_config.json
1{
2 "source_system": "SUPPLIER_SFTP_NA",
3 "ingestion_mode": "INCREMENTAL_WATERMARK",
4 "schedule": "0 */4 * * *",
5 "target_schema": "gold_inventory",
6 "data_quality_rules": [
7 "null_check_sku",
8 "expiry_date_not_null"
9 ],
10 "owner": "data_ops_team"
11}
12deploy_pipeline --env=prod
05 / Interface

What the store manager sees

Real-time spoilage tracking telemetry enabling immediate interventions at the extreme perimeter of the retail floor. Powered by Power BI streaming primitives.

06 / Outcome

What it produced

  • 01

    Reduced supplier onboarding time from 2 weeks to 4 hours.

  • 02

    Enabled dynamic pricing on near-expiry stock, turning spoilage into recoverable margin.

  • 03

    Decommissioned 200+ legacy SSIS packages, reducing maintenance costs by 60%.

  • 04

    Empowered non-technical users to access clean data via Power BI Datasets.

Return to Archive

Explore
Portfolio.