เริ่มต้นใช้งานเริ่มต้นใช้งานได้ฟรี

การรัน ETL Pipeline

พร้อมที่จะรัน ETL pipeline แรกหรือยัง? เริ่มกันเลย!

ในแบบฝึกหัดนี้ ฟังก์ชัน extract(), transform() และ load() ถูกกำหนดไว้ให้แล้ว ในการรัน data ETL pipeline นี้ จะต้องเรียกใช้ฟังก์ชันทั้งสามนี้ตามลำดับ หากสนใจ ลองดูโค้ดของฟังก์ชัน extract() ได้ที่นี่

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

แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร

ETL and 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")
แก้ไขและรันโค้ด