Запуск ETL-конвейера

Готовы запустить свой первый ETL-конвейер? Приступим!

Функции extract(), transform() и load() уже определены за вас. Чтобы запустить этот ETL-конвейер обработки данных, вам нужно выполнить каждую из этих функций по очереди. Если интересно, загляните, как устроена функция extract().

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

Это упражнение является частью курса

ETL и ELT в Python

Посмотреть курс

Инструкции к упражнению

Используйте функцию extract(), чтобы извлечь данные из файла raw_data.csv.
Преобразуйте DataFrame extracted_data с помощью функции transform().
Наконец, загрузите DataFrame transformed_data в SQL-таблицу cleaned_data.

Интерактивное практическое упражнение

Попробуйте выполнить это упражнение, дополнив этот пример кода.

# 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")

Редактировать и запускать код