top of page
vecteezy_abstract-big-data-flow-technology-background-vector_3705383_edited.jpg

Streamlining Customer Data Processing for TeleNova Systems: A Scalable Dataflow Gen2 Solution in Microsoft Fabric

Project Overview​

TeleNova Systems, a leading telecommunications provider, launched its Customer 360  initiative to build a unified view of every customer. However, years of uncontrolled data ingestion had left the organization with fragmented, inconsistent, and incomplete records scattered across systems.

As a Data Engineer, I led the effort to rebuild trust in the data by designing a scalable and automated cleansing pipeline in Dataflow Gen2. This initiative produced the first refined Customer Silver dataset, laying the foundation for accurate analytics, targeted marketing, and consistent customer intelligence across the organization.

​​

Objective

Initial profiling of the Customer_Bronze table revealed multiple data quality challenges:

  • Address inconsistencies (e.g., “Street,” “St,” “Str.”, “Rd.”).

  • Mixed state values (abbreviations, full names, and varied capitalization).

  • Contaminated phone fields with non-numeric symbols or invalid entries.

This data inconsistency caused major issues across departments:

  • The Marketing team faced costly campaign failures due to undeliverable addresses.

  • The Data Science team struggled with unreliable features for churn prediction models.

The goal was clear — to deliver a trusted Customer_Silver table that could serve as a foundation for business-critical analytics and downstream models.

​

Solution Overview​

To ensure maintainability, scalability, and reusability, the solution was built using Microsoft Fabric Dataflow Gen2, leveraging its low-code ETL capabilities and native integration within the Fabric ecosystem. This architecture provided:

​

  • Low-Code Standardization: Utilized Dataflow Gen2’s declarative approach to build complex lookups and transformations without writing custom code, enabling faster development and easier maintenance .

  • Lookup Table-Driven Cleansing: Employing Merge/Join operations within Dataflow Gen2 with reference tables (state_lookup, address_suffix_lookup) to systematically standardize every inconsistent value.

  • Feature Engineering for Utility: Separating the address into Address_Street and Address_Unit components, and cleaning the Phone number to an all-numeric Phone_Clean format.

  • Establishing Trust via Governance: Implementing a Data_Quality_Flag (1 for clean, 0 for known issues) to provide immediate transparency and quantifiable proof of data quality improvement to stakeholders.

​

​​

What I Built
​

Screenshot 2025-10-31 200930.png

Data Ingestion

The process begins by connecting to the Lakehouse and importing the source CSV file (customer_bronze.csv). The headers are promoted, and appropriate data types are assigned to ensure consistency across fields.

​

Transformation

  • State : ​A left join with the State_Lookup table replaces inconsistent or abbreviated state names (Raw_State) with their standardized form (Standard_State).

  • Phone Number : extracting only digits using Text.Select. If the resulting string contains exactly 10 digits, it’s retained; otherwise, it’s set to null.

4.2.png
4.3.png
4.4.png
4.5.png

Address Parsing​

The Address column is split into two logical parts:

  • Unit Component – Extracts apartment, suite, or unit numbers (e.g., “Apt 5” or “Suite 12”).

  • Street Component – Removes the unit part and standardizes street suffixes (e.g., “Rd” → “Road”, “St” → “Street”) using a lookup table (Address_Lookup).
    Key transformations:

  • Text.BeforeDelimiter / Text.AfterDelimiter for string splitting.

  • Table.NestedJoin for suffix standardization.

  • Text.Trim for cleanup.

Data Quality Flag

​A new column, Data_Quality_Flag, is added to quickly assess data completeness. If any key fields (phone, address, or unit) are missing or invalid, the flag is set to 0; otherwise, it’s 1.
Key transformation: Conditional logic using Table.AddColumn.

4.6.png
4.9.png

The transformation framework built on Microsoft Fabric Dataflow Gen2 resulted in a clean, standardized, and analytics-ready customer dataset that significantly improved data reliability across the organization.

Business Impact:​

The adoption of Microsoft Fabric Dataflow Gen2 streamlined TeleNova Systems' customer data transformation process, improving both efficiency and reliability.

  • Data Reliability: Established a single source of truth, improving accuracy and consistency across departments.

  • Operational Efficiency: Automated daily refreshes, reducing manual intervention by over 90%.

  • Analytics Enablement: Delivered clean, standardized data to accelerate churn prediction and marketing insights.

  • Scalable Architecture: Created a reusable, low-code framework easily extendable to new data domains within Fabric.

bottom of page