Home > Docs > Industries > Retail & CPG
🛒 Retail & CPG — Demand Forecasting & Customer 360¶
End-to-end retail analytics from point-of-sale to supply chain on Microsoft Fabric
Last Updated: 2026-05-05 | Version: 1.0.0
"Retailers that act on data in minutes instead of days convert 23% more shoppers and waste 18% less inventory."
📑 Table of Contents¶
- Scenario Overview
- Regulatory Landscape
- Data Flow Architecture
- Why Fabric for Retail and CPG
- Getting Started
- References
🎯 Scenario Overview¶
| Scenario | Fabric Pattern | Latency Target | Key Features |
|---|---|---|---|
| Point-of-sale streaming analytics | Eventstream → Eventhouse → Real-Time Dashboard | < 5 sec | RTI, Alerting |
| Demand forecasting | Lakehouse Gold + AutoML time-series model | Daily/Weekly | AutoML, Semantic Link |
| Customer 360 | Lakehouse medallion + Direct Lake semantic model | Near-real-time | Direct Lake, Data Sharing |
| Supply chain visibility | Lakehouse Silver + Warehouse star schema | Hourly | Warehouse Setup, Mirroring |
| Promotion effectiveness analysis | Gold aggregation + Direct Lake | Daily | Medallion Architecture, Power BI |
| Shrinkage and loss prevention | Eventstream from loss-prevention sensors → Eventhouse | < 10 sec | RTI, Data Activator |
📋 Regulatory Landscape¶
| Framework | Applicability | Fabric Controls |
|---|---|---|
| PCI-DSS | Card payment data from POS terminals | OneLake Security column-level masking, CMK, Network Security |
| GDPR | EU customer loyalty and purchase data | GDPR Right to Deletion, sensitivity labels via Data Governance |
| CCPA / CPRA | California consumer purchase and loyalty data | CCPA Privacy Rights, data subject access request workflows |
| FDA 21 CFR Part 117 (CPG) | Food safety traceability for CPG manufacturers | Delta Lake time-travel for lot/batch traceability, Audit Trail |
| FTC Act Section 5 | Consumer protection in marketing analytics | RBAC for marketing data access controls |
🏗️ Data Flow Architecture¶
flowchart LR
subgraph Sources["🛒 Data Sources"]
POS["POS Terminals<br/>(Event Hub)"]
ERP["ERP / Inventory<br/>System"]
LOYALTY["Loyalty &<br/>CRM Platform"]
SUPPLY["Supply Chain<br/>/ EDI Feeds"]
WEB["E-Commerce<br/>Clickstream"]
end
subgraph Bronze["🥉 Bronze Layer"]
B1["POS Transactions<br/>(Eventstream)"]
B2["Inventory Snapshots<br/>(daily extract)"]
B3["Loyalty Events<br/>(append-only)"]
B4["Purchase Orders &<br/>Shipments (EDI)"]
B5["Clickstream<br/>(Eventstream)"]
end
subgraph Silver["🥈 Silver Layer"]
S1["Sales Transactions<br/>(deduplicated, card masked)"]
S2["Inventory Positions<br/>(reconciled)"]
S3["Customer Master<br/>(PII pseudonymized)"]
S4["Supply Chain<br/>Events (validated)"]
end
subgraph Gold["🥇 Gold Layer"]
G1["Customer 360<br/>Star Schema"]
G2["Demand Forecast<br/>Feature Store"]
G3["Promotion<br/>Effectiveness"]
G4["Supply Chain<br/>KPIs"]
end
subgraph BI["📊 Consumption"]
DL["Direct Lake<br/>Semantic Model"]
PBI["Power BI<br/>Dashboards"]
RTD["Real-Time<br/>Dashboard"]
DA["Data Activator<br/>Stock Alerts"]
end
POS --> B1
ERP --> B2
LOYALTY --> B3
SUPPLY --> B4
WEB --> B5
B1 --> S1
B2 --> S2
B3 --> S3
B4 --> S4
B5 --> S3
S1 --> G1
S1 --> G2
S1 --> G3
S2 --> G4
S3 --> G1
S4 --> G4
G1 --> DL --> PBI
G2 --> DL
G3 --> DL
G4 --> DL
B1 --> RTD
S2 --> DA 💡 Why Fabric for Retail and CPG¶
POS streaming and batch analytics on one platform. Point-of-sale events flow through Eventstreams for real-time dashboards while the same data lands in Lakehouse Bronze for daily aggregation — no duplicate pipelines, no data reconciliation issues.
Demand forecasting without a separate ML platform. AutoML model endpoints train time-series forecasting models directly on Gold-layer sales data, producing daily or weekly demand predictions that feed inventory planning dashboards via Direct Lake.
Customer 360 without a CDP. By unifying POS, loyalty, e-commerce, and CRM data in the Lakehouse medallion pattern, retailers build a governed Customer 360 without purchasing a separate customer data platform. Sensitivity labels and pseudonymization protect PII.
Supply chain visibility across partners. Fabric's data sharing and Mirroring capabilities let retailers share filtered views of inventory and shipment data with CPG suppliers — enabling collaborative planning without raw data exposure.
Sub-second dashboards for store operations. Direct Lake semantic models give district and store managers Power BI dashboards that perform at import-mode speed while reading live from OneLake, eliminating overnight refresh windows.
🚀 Getting Started¶
- Build the medallion Lakehouse — Follow Medallion Deep Dive to set up Bronze/Silver/Gold layers for POS and inventory data.
- Stream POS transactions — Configure Eventstreams to ingest POS events from Event Hub for real-time sales dashboards.
- Apply PCI and privacy controls — Enable OneLake Security CLS for card masking and configure GDPR deletion workflows for loyalty data.
- Build Customer 360 — Create a Gold-layer star schema joining POS, loyalty, and clickstream data, then connect Direct Lake for unified customer analytics.
- Deploy demand forecasting — Use AutoML to train a time-series model on sales history and publish predictions to the Gold layer.
- Enable supply chain sharing — Use Data Sharing to provide filtered inventory views to CPG partners.
📚 References¶
| Resource | Link |
|---|---|
| Real-Time Intelligence | RTI Guide |
| Direct Lake connectivity | Direct Lake Guide |
| Mirroring | Mirroring Guide |
| AutoML Model Endpoints | AutoML Guide |
| Data Sharing & Federation | Sharing Guide |
| Power BI Best Practices | Power BI Guide |
| Medallion Architecture | Medallion Deep Dive |
| Data Governance | Governance Deep Dive |