Business IntelligenceUnit 46 min read
ETL Processes: Extraction, Transformation, Loading & BI Pipelines
Unit 4 of Business Intelligence explores how raw data is cleaned, enriched, and moved into data warehouses—covering ETL architecture, tools, challenges, and real-world pipelines like those used by Ncell for customer analytics or Daraz for supply chain optimization.
What is ETL?
ETL stands for Extract, Transform, Load: the three-step process that moves raw data from source systems into a structured data warehouse for analysis.
The ETL Pipeline
flowchart LR
A["Source Systems\n(ERP, CRM, IoT, etc.)"] -->|"Extract"| B["Staging Area\n(Raw Data Lake)"]
B -->|"Transform"| C["Data Cleansing\nDeduplication\nData Enrichment"]
C -->|"Load"| D["Target\n(Data Warehouse/DB)"
D -->|"Query"| E["BI Tools\n(Power BI, Tableau)"]Key Idea: ETL is the backbone of BI—without it, data remains siloed and unusable.
In the Real World
Ncell’s Customer Churn Prediction Ncell extracts call logs and payment data from its CRM, transforms it to identify inactive users, and loads it into a dashboard to trigger retention campaigns.
Daraz’s Order Fulfillment Daraz’s ETL pipeline extracts order data from its e-commerce platform, transforms it to calculate delivery routes, and loads it into a logistics system to optimize Pathao driver assignments.
Nepal Rastra Bank’s Financial Monitoring NRB extracts transaction data from banks, transforms it to detect suspicious patterns (e.g., money laundering), and loads it into a fraud-detection system.
Step 1: Extract
How It Works
Extracting data involves pulling it from source systems (e.g., databases, APIs, flat files) into a staging area. Methods include:
- Batch Extraction: Scheduled pulls (e.g., nightly bank transactions).
- Real-time Extraction: Streaming data (e.g., IoT sensors in smart grids).
Example: Khalti’s Transaction Data
Worked Trace: Khalti extracts 10,000 daily transactions from its payment gateway. The ETL tool flags duplicates (e.g., same transaction ID) and converts foreign currencies to NPR before loading.
Step 2: Transform
Key Transformations
| Transformation | Example | Tool Used |
|---|---|---|
| Data Cleansing | Fixing typos in customer names | OpenRefine, Python (Pandas) |
| Data Enrichment | Adding geolocation to orders | Google Maps API |
| Aggregation | Summing monthly sales by region | SQL, Spark |
| Data Type Conversion | Converting text dates to timestamps | ETL tools (Talend, SSIS) |
Example: NTC’s Network Performance
NTC extracts raw call-drop logs from its towers. The ETL tool:
- Converts timestamps to UTC.
- Aggregates drops by tower location.
- Flags towers with >5% failure rates for maintenance.
Step 3: Load
Loading Strategies
| Method | Use Case | Pros | Cons |
|---|---|---|---|
| Full Load | Initial data warehouse setup | Simple, complete data | High storage cost |
| Incremental Load | Daily updates (e.g., stock prices) | Efficient, real-time | Complex error handling |
| Trickle Feed | IoT sensor data (e.g., traffic lights) | Low latency | High infrastructure cost |
Example: NEPSE’s Stock Data
NEPSE loads daily stock prices into its BI system via incremental load:
- Extracts only new trades from its database.
- Transforms to calculate moving averages.
- Loads into a dashboard for traders.
ETL Tools in Nepal
| Tool | Used By | Key Feature |
|---|---|---|
| Talend | Nabil Bank | Open-source, drag-and-drop pipelines |
| SSIS | Global IME Bank | Microsoft’s enterprise ETL |
| Apache NiFi | NTC | Real-time data flow monitoring |
| Python (Pandas) | Startups | Custom scripts for small-scale ETL |
Challenges & Solutions
| Challenge | Solution | Example |
|---|---|---|
| Data Silos | Use APIs to integrate systems | Daraz + Pathao for delivery tracking |
| Data Quality Issues | Automated cleansing rules | Ncell’s duplicate transaction filter |
| Scalability | Cloud-based ETL (AWS Glue, Azure Data Factory) | Himalayan Java’s supply chain analytics |
Exam Tip
- Diagram the ETL Flow: Always draw a pipeline (like the Mermaid above) in exams—it’s worth 5+ marks.
- Tool vs. Technique: Know when to use ETL tools (batch) vs. ELT (cloud, real-time).
- Real-World Tie: Link ETL to Nepal’s context (e.g., "How would NTC use ETL to reduce call drops?").
- SQL + ETL: Expect questions on SQL transformations (e.g.,
JOIN,CASE WHEN) in ETL scripts.
Case Study: Chaudhary Group’s Supply Chain
How ETL Helps:
- Extracts real-time stock levels from IoT sensors.
- Transforms to predict demand using historical sales.
- Loads alerts into the warehouse manager’s app to reorder before shortages.
Summary Table
| ETL Step | Action | Example in Nepal | Key Skill |
|---|---|---|---|
| Extract | Pull data from sources | Ncell extracts call logs | API/SQL queries |
| Transform | Clean, enrich, aggregate | Daraz converts INR to NPR | Python/Pandas |
| Load | Store in warehouse | NTC loads tower data for repairs | SQL INSERT, partitioning |
Final Note: ETL is the bridge between raw data and actionable insights. Master it, and you’ll ace BI implementation questions!
Based on the TU BITM syllabus for Business Intelligence (IT249), unit 4.
Discussion
Loading…