An ETL pipeline to efficiently extract, transform and load data into PostgresSQL table
Pipeline steps
- Extract data from upstream( using python request)
- Clean and transform data
- Define unique key, map data to table using SQLAlchemy
- Load data into PostgresSQL table
- Generate insights from data using SQL queries