Моніторинг і сповіщення в межах конвеєра даних
Час зібрати все докупи! Ви могли здогадатися, але оброблення помилок за допомогою try-except і логування працюють пліч-о-пліч. Ці дві практики є необхідними, щоб конвеєр був стійким і прозорим, а також слугують основою для більш просунутих рішень моніторингу та сповіщень.
pandas імпортовано як pd, а модуль logging завантажено та налаштовано для вас. Датафрейм raw_sales_data уже витягнуто й готовий до трансформацій.
Ця вправа є частиною курсу
ETL та ELT у Python
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
def transform(raw_data):
return raw_data.loc[raw_data["Total Price"] > 1000, :]
try:
# Attempt to transform DataFrame, log an info-level message
clean_sales_data = transform(raw_sales_data)
logging.____("Successfully filtered DataFrame by 'Total Price'")
except Exception:
# Log a warning-level message
____.____("Cannot filter DataFrame by 'Total Price'")