antigravity-lite 0.1.2

Herramienta open-source para auditar despilfarros financieros en clústeres PySpark (AWS Glue) y manipular S3.

🚀 Antigravity Lite (FinOps & AWS Glue Tools)

Auditor Financiero de Nube y Gestor Inteligente de S3 para Ecosistemas PySpark

---

🛑 El Asesino Silencioso de AWS Glue: El "Catalyst Optimizer"

¿Alguna vez te has preguntado por qué un clúster gigantesco de PySpark se queda congelado horas enteras procesando sin emitir un solo byte de datos al intentar evaluar una tabla ancha (Wide Dataframe)?

Muchos culpan a la partición de datos y terminan escalando la capacidad del clúster por pánico hacia carísimas instancias G.4X o G.8X en AWS Glue. Pero inyectar dinero en memoria no es la salvación. La solución de ingeniería no es comprar más RAM, es aislar la matemática.

📦 Instalación

pip install antigravity-lite

🛠 Herramientas Incluidas (Open-Source)

1. Automator de Renombrado en S3 (S3Finalizer)

¿Odiar que PySpark genere basura como part-00000...csv y archivos _SUCCESS temporales que ensucian tu Datalake? S3Finalizer es una utilidad nativa en Boto3 que escanea la salida cruda de Spark y la renombra secuencialmente y elegantemente sin destruir la concurrencia.

from antigravity_lite.io.s3_finalizer import S3Finalizer

# Spark acaba de escribir archivos sucios en S3...
finalizador = S3Finalizer(bucket_name="mi-datalake-corporativo")

# Renombra automáticamente las salidas
finalizador.sequence_spark_outputs(
    s3_prefix="zona_cruda/ventas/",
    pattern="REPORTE_EMPRESA_DATA_{seq:04d}.parquet" 
)
# Magia: REPORTE_EMPRESA_DATA_0001.parquet

2. Auditor FinOps de Clústeres AWS Glue (AgAuditor)

Inyecta este comando directo en tu entorno para escanear a nivel de facturación y JVM Heap cuántos cientos de dólares estás desperdiciando al mes pagando servidores gigantes solo para evitar que los "Wide Dataframes" ahoguen el Catalyst Optimizer.

from antigravity_lite.auditor.finops import AgAuditor

# Escanea el clúster usando CloudWatch y el API de AWS
AgAuditor.run_aws_audit(region="us-east-1", dias_analisis=7)

Salida en consola: Te dirá con precisión tus tipos de Workers (G.1X, G.4X) frente a la memoria comprimida de uso real para revelar la fuga de capital.

---

💎 Licenciamiento Comercial (Antigravity PRO)

La versión Lite puede decirte que estás perdiendo miles de dólares... Pagar la Licencia Corporativa de Antigravity PRO lo soluciona.

Si tu reporte AgAuditor marca "⚠️ RIESGO AST" o sobrepasas el 85% de RAM, necesitas el motor matemático DataFrameChunker (Sólo disponible en la edición Pro B2B). La versión empresarial intercepta el planificador de Spark en bajo nivel y divide la matriz usando Árboles Binarios Logarítmicos (Tree Reduce) para truncar el Lineage algorítmico, permitiendo ejecutar clústeres diminutos G.1X procesando medio billón de operaciones sin riesgos de OutOfMemory.

💻 Solicita tu demostración técnica y Proof-of-Concept conectando a través de LinkedIn para un despliegue B2B.