SolveConPython

import csv
def _email_valido_simple(email: str) -> bool:
    if " " in email:
        return False
    if email.count("@") != 1:
        return False
    usuario, dominio = email.split("@")
    if not usuario or not dominio:
        return False
    if "." not in dominio:
        return False
    return True
def etl_simple(ruta_entrada: str, ruta_salida_ok: str, ruta_salida_error: str) -> dict:
    """
    Pipeline ETL simple:
    - Lee CSV (email, edad, pais)
    - Limpia y valida
    - Exporta filas válidas e inválidas
    - Devuelve conteos
    """
    if ruta_entrada is None or ruta_salida_ok is None or ruta_salida_error is None:
        raise TypeError("Las rutas no pueden ser None.")
    if not isinstance(ruta_entrada, str) or not isinstance(ruta_salida_ok, str) or not isinstance(ruta_salida_error, str):
        raise TypeError("Las rutas deben ser cadenas (str).")
    ok = 0
    error = 0
    campos_salida_ok = ["email", "edad", "pais"]
    campos_salida_error = ["email", "edad", "pais", "error"]
    with open(ruta_entrada, mode="r", encoding="utf-8", newline="") as f_in, \
         open(ruta_salida_ok, mode="w", encoding="utf-8", newline="") as f_ok, \
         open(ruta_salida_error, mode="w", encoding="utf-8", newline="") as f_err:
        reader = csv.DictReader(f_in)
        # Validación mínima de cabecera
        requeridas = {"email", "edad", "pais"}
        if reader.fieldnames is None or not requeridas.issubset(set(reader.fieldnames)):
            raise ValueError("El CSV de entrada debe tener cabecera con: email, edad, pais.")
        w_ok = csv.DictWriter(f_ok, fieldnames=campos_salida_ok)
        w_err = csv.DictWriter(f_err, fieldnames=campos_salida_error)
        w_ok.writeheader()
        w_err.writeheader()
        for fila in reader:
            raw_email = (fila.get("email") or "").strip()
            raw_edad = (fila.get("edad") or "").strip()
            raw_pais = (fila.get("pais") or "").strip()
            email = raw_email.lower()
            pais = raw_pais
            # Validar email
            if email == "" or not _email_valido_simple(email):
                w_err.writerow({"email": email, "edad": raw_edad, "pais": pais, "error": "email_invalido"})
                error += 1
                continue
            # Validar edad
            try:
                edad_int = int(raw_edad)
            except ValueError:
                w_err.writerow({"email": email, "edad": raw_edad, "pais": pais, "error": "edad_invalida"})
                error += 1
                continue
            if edad_int < 0 or edad_int > 120:
                w_err.writerow({"email": email, "edad": str(edad_int), "pais": pais, "error": "edad_fuera_de_rango"})
                error += 1
                continue
            # Validar país
            if pais == "":
                w_err.writerow({"email": email, "edad": str(edad_int), "pais": pais, "error": "pais_vacio"})
                error += 1
                continue
            # Fila OK
            w_ok.writerow({"email": email, "edad": str(edad_int), "pais": pais})
            ok += 1
    return {"ok": ok, "error": error}