error_logger.py

import psycopg2

DB_PARAMS = { "dbname": "error_db", "user": "postgres", "password": "password", "host": "localhost", "port": 5432 }

def log_error(component, message): conn = psycopg2.connect(**DB_PARAMS) cur = conn.cursor() cur.execute("INSERT INTO error_logs(component, message) VALUES (%s, %s);", (component, message)) conn.commit() cur.close() conn.close() print(f"Error logged: {message}")

if name == "main": log_error("ETL", "Null value found in required column") log_error("API", "Rate limit exceeded")