Uruchamianie potoku ETL
Gotowy, żeby uruchomić swój pierwszy potok ETL? Do dzieła!
Funkcje extract(), transform() i load() zostały już dla ciebie zdefiniowane. Aby uruchomić ten potok ETL, wywołasz każdą z nich po kolei. Jeśli jesteś ciekawy, zajrzyj, jak wygląda funkcja extract().
def extract(file_name):
print(f"Extracting data from {file_name}")
return pd.read_csv(file_name)
To ćwiczenie jest częścią kursu
ETL i ELT w Pythonie
Instrukcje do ćwiczenia
- Użyj funkcji
extract(), aby wyodrębnić dane z plikuraw_data.csv. - Przetransformuj ramkę danych
extracted_dataza pomocą funkcjitransform(). - Na koniec załaduj ramkę danych
transformed_datado tabeli SQLcleaned_data.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
# 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")