End-to-End-Data-Engineering-Project

KO | EN

gitlite — search

#python #hacktoberfest #golang #android #deep-learning #macos #nodejs #windows #awesome #cli #awesome-list #pytorch #mcp #ios

End-to-End-Data-Engineering-Project

(★ 9)

A complete End to End Data Engineering Project implemented using Azure Cloud provider. Pipeline are created to ingest data from SQL server database , transformed using azure Databricks service and finally data is stored in azure synapase analytics warehouse. Tableau is used to create report over this data.

End-to-End-Data-Engineering-Project Latest Version Download

Download Latest Version (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# End-to-End-Data-Engineering-Project
A complete End to End Data Engineering Project implemented using Azure Cloud provider. Pipeline are created to ingest data from SQL server database , transformed using azure Databricks service and finally data is stored in azure synapase analytics warehouse. Tableau is used to create report over this data.

# Final Pipeline Look
<img width="488" alt="image" src="https://github.com/crazylot/End-to-End-Data-Engineering-Project/assets/63306186/2109fb0d-394c-4e7f-bd33-a6edc5339d79">

## Services/Tools Used

### Azure Databricks
Databricks is spark based analytics platform. It integrates seamlessly with Azure Blob Storage, Azure Data lage, Azure SQL Data Warehouse. It creates a spark enviornment for teams to work efortlessly.

### Apace Spark
Apach Spark is a computational engine to analyze/process huge amount of data parallely. It is written in scala but can be accessed through API avaialble for Python , Scala ,R and Java

### PySpark
PySpark is all about using Python API to work with Apache Spark.
PySpark is a Python API for Spark released by the Apache Spark community to support Python with Spark.

## Concepts Learned

### Mount azure data lake storage to databricks using credentials passthrough
Credential passthrough allows you to authenticate automatically to Azure Data Lake Storage from Azure Databricks clusters using the identity that you use to log in to Azure Databricks.
Enable Azure Data Lake Storage credential passthrough for a High Concurrency cluster by clicking on checkmark that appear at cluster creation time under Advanced options.
Make sure that user which you have login to the databricks service has "Storage Blob Data Contributor" role assigned to it. That's it, you an now access content of azure data
lake storage account with the databricks cluster. 
Following article describes in more detail := https://learn.microsoft.com/en-us/azure/databricks/data-governance/credential-passthrough/adls-passthrough

### Data Transforamtion 
<img width="407" alt="image" src="https://github.com/crazylot/End-to-End-Data-Engineering-Project/assets/63306186/eb6d61bb-ae0d-4353-8d36-5c06a7767bf8">

I extracted data from Azure Data Lake Storage Gen2 into Azure Databricks, ran transformations on the data in Azure Databricks, and loaded the transformed data into Azure Synapse Analytics.

### Git Integration with Azure Data Factory

### 3 layer data cleaning with azure databricks service
Bronze Layer >> Silver Layer >> Gold LAYER
Data in bronze layer is in parquet format. It is cleaned by converting timestamp column to appropriate data format. This is implemented for all the tables which have columns in timestamp format.

It is then loaded to silver container in delta table format. In Silver layer, I have modified coumn names to include underscore ("_") between 2 words in column name.

Data in Gold layer is final and this is the dat which is going to be used for reporting purpose.

Dataframe is like a temporary view with table like structure.

### Azure Synapse Analytics Service
In order to connect with your serversql pool with azure data factory, you need to create a linked service connection for which type will be "Azure SQL Database" and not "Azure Synapse Analytics Service". Serverless SQL Endpoint in the properties of synapse anlaytics workspace will used as server name and databse will be your serverless SQL pool name.

End-to-End-Data-Engineering-Project

End-to-End-Data-Engineering-Project Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

End-to-End-Data-Engineering-Project

End-to-End-Data-Engineering-Project Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Download README