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

  1. 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.

  2. 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.

  3. 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:

  1. Converts timestamps to UTC.
  2. Aggregates drops by tower location.
  3. 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

  1. Diagram the ETL Flow: Always draw a pipeline (like the Mermaid above) in exams—it’s worth 5+ marks.
  2. Tool vs. Technique: Know when to use ETL tools (batch) vs. ELT (cloud, real-time).
  3. Real-World Tie: Link ETL to Nepal’s context (e.g., "How would NTC use ETL to reduce call drops?").
  4. 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:

  1. Extracts real-time stock levels from IoT sensors.
  2. Transforms to predict demand using historical sales.
  3. 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…