Rularea unui pipeline ETL

Ești gata să rulezi primul tău pipeline ETL? Să începem!

Aici, funcțiile extract(), transform() și load() sunt deja definite pentru tine. Pentru a rula acest pipeline ETL, vei executa fiecare dintre aceste funcții. Dacă ești curios, aruncă o privire la cum arată funcția extract().

def extract(file_name):
    print(f"Extracting data from {file_name}")
    return pd.read_csv(file_name)

Acest exercițiu face parte din cursul

ETL și ELT în Python

Vezi cursul

Instrucțiuni pentru exercițiu

Folosește funcția extract() pentru a extrage date din fișierul raw_data.csv.
Transformă DataFrame-ul extracted_data folosind funcția transform().
În final, încarcă DataFrame-ul transformed_data în tabela SQL cleaned_data.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

# Extract data from the raw_data.csv file
extracted_data = ____(file_name="raw_data.csv")

# Transform the extracted_data
transformed_data = transform(data_frame=____)

# Load the transformed_data to cleaned_data.csv
____(data_frame=transformed_data, target_table="cleaned_data")

Editează și rulează codul