ETL Pipeline चलाना
क्या आप अपना पहला 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_dataDataFrame को ट्रांसफॉर्म करें.- अंत में,
transformed_dataDataFrame कोcleaned_dataSQL टेबल में लोड करें.
इंटरैक्टिव व्यावहारिक अभ्यास
इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।
# 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")