INNER CODE UNIT · Python
run_etl_pipeline
balapriyac/data-science-tutorials · build-with-python/etl-pipeline/main.py:99
def run_etl_pipeline():
"""Execute the complete ETL pipeline"""
print("Starting ETL Pipeline...")
print("=" * 50)
# Extract
raw_data = extract_data_from_csv('raw_transactions.csv')
# Transform
transformed_data = transform_data(raw_data)
# Load
load_result = load_data_to_sqlite(transformed_data)
print("=" * 50)
print("ETL Pipeline completed successfully!")
return transformed_data