运行一个 ETL 流水线

准备好运行您的第一个 ETL 流水线了吗？我们开始吧！

这里已经为您定义好了 extract()、transform() 和 load() 这三个函数。要运行这条 ETL 数据流水线，您将依次执行这些函数。如果好奇，您可以先看看 extract() 函数的样子。

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

本练习是课程的一部分

使用 Python 的 ETL 和 ELT

查看课程

练习说明

使用 extract() 函数从 raw_data.csv 文件中抽取数据。
使用 transform() 函数转换 extracted_data DataFrame。
最后，将 transformed_data DataFrame 加载到 cleaned_data SQL 表中。

交互式实操练习

通过完成这段示例代码来试试这个练习。

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

编辑并运行代码