Ingenieria del caos
Construye sistemas resilientes inyectando fallas intencionalmente y observando cómo responden y se recuperan tus servicios distribuidos.
Visión General
El chaos engineering es la disciplina de experimentar en sistemas distribuidos para construir confianza en su resiliencia. Al inyectar fallas intencionalmente — matar instancias, inyectar latencia, corromper paquetes — los equipos descubren debilidades antes que los clientes. Netflix fue novedoso con Chaos Monkey; hoy, herramientas como Litmus, Gremlin y AWS Fault Injection Simulator lo hacen accesible para cualquier equipo.
Cuándo Usar
Usa este recurso cuando:
- Operas sistemas distribuidos donde las fallas son inevitables. Consulta Event-Driven Microservices para arquitecturas resilientes.
- Te preparas para drills de disaster recovery y game days. Consulta Load Testing para verificación de capacidad.
- Validas auto-escalado, failover y mecanismos de auto-curación. Consulta Health Check Endpoint para configuración de probes.
- Construyes confianza antes de eventos de alto tráfico (lanzamientos, Black Friday). Consulta Retry Logic para manejar fallas gracefulmente.
Solución
Chaos de Pods en Kubernetes (Litmus)
apiVersion: litmuschaos.io/v1alpha1
kind: ChaosEngine
metadata:
name: pod-delete-experiment
spec:
appinfo:
appns: 'production'
applabel: 'app=payment-service'
appkind: 'deployment'
chaosServiceAccount: litmus-admin
experiments:
- name: pod-delete
spec:
components:
env:
- name: TOTAL_CHAOS_DURATION
value: '30'
- name: CHAOS_INTERVAL
value: '10'
- name: FORCE
value: 'false'
Inyección de Latencia de Red (tc + Bash)
#!/bin/bash
# Agregar 500ms de latencia al tráfico de salida en eth0
echo "Inyectando 500ms de latencia por 60 segundos..."
tc qdisc add dev eth0 root netem delay 500ms 50ms distribution normal
sleep 60
echo "Removiendo latencia..."
tc qdisc del dev eth0 root
# Verificar con ping
ping -c 5 api.example.com
AWS Fault Injection Simulator (Python)
import boto3
fis = boto3.client('fis')
response = fis.start_experiment(
experimentTemplateId='EXT-12345678',
tags={'Environment': 'staging'}
)
print(f"Experimento iniciado: {response['experiment']['id']}")
Explicación
Cinco tipos de experimentos de chaos:
- Infraestructura: Matar VMs, terminar contenedores, desacoplar volúmenes
- Red: Inyectar latencia, dropear paquetes, particionar zonas
- Aplicación: Lanzar excepciones, retornar 503s, activar memory leaks
- Estado: Llenar discos, corromper bases de datos, expirar certificados
- Dependencia: Hacer que APIs downstream hagan timeout o retornen errores
El principio del blast radius:
- Empieza en staging, luego mueve a producción con tráfico mínimo
- Siempre ten un botón de abortar (rollback automático ante violación de SLO)
- Ejecuta durante horas de oficina cuando el equipo esté disponible
- Mide contra SLOs, no solo “¿se cae?”
Variantes
| Herramienta | Plataforma | Tipos de Experimento |
|---|---|---|
| Chaos Monkey | AWS/Netflix | Terminación de instancias |
| Litmus | Kubernetes | Pod, red, disco, stress |
| Gremlin | Multi-cloud | CPU, memoria, red, estado |
| AWS FIS | AWS | Fallas EC2, ECS, EKS, RDS |
| Toxiproxy | Cualquiera | Latencia de red, timeouts |
Lo que funciona
- Define steady state primero: Conoce tu tasa de error normal, latencia y throughput
- Hipótesis-driven: “Si matamos la base de datos primaria, el failover completa en <30s”
- Automatiza rollback: Detén experimentos automáticamente si la tasa de error excede el 1%
- Corre game days: Eventos de chaos programados trimestralmente con todo el equipo
- Documenta hallazgos: Cada experimento produce una actualización de runbook o un fix arquitectónico
Errores Comunes
- Chaos sin monitoreo: No puedes observar efectos si los dashboards están incompletos
- Producción primero: Nunca corras chaos en producción antes de probarlo seguro en staging
- Sin plan de rollback: Experimentos que no se pueden detener rápidamente se convierten en outages
- Probar solo fallas: También prueba recuperación (¿el auto-healing realmente sana?)
- Ignorar blast radius: Un experimento no debería afectar a todos los clientes
Errores Comunes Adicionales
- Correr experimentos sin baselines. Necesitas métricas de steady-state antes del chaos para comparar:
# Registrar baseline antes del experimento
curl -s https://api.example.com/metrics > baseline-metrics.json
# Correr experimento
# Comparar después
curl -s https://api.example.com/metrics > post-experiment-metrics.json
diff <(jq '.latency_p99' baseline-metrics.json) <(jq '.latency_p99' post-experiment-metrics.json)
- No limpiar después de experimentos. Los toxics de Toxiproxy, reglas tc, y fallas inyectadas persisten si no se remueven:
# Siempre limpiar
tc qdisc del dev eth0 root 2>/dev/null
toxiproxy-cli toxic delete --all
kubectl delete chaosengine --all -n staging
Tips de Rendimiento
- Corre experimentos en horas valle. Incluso con blast radius reducido, los experimentos añaden carga:
# Programar a las 2am cuando el tráfico es menor
0 2 * * * /usr/local/bin/chaos-experiment.sh
- Usa duraciones cortas de experimento. 30-60 segundos son suficientes para observar comportamiento:
# Litmus: 30 segundos máximo
env:
- name: TOTAL_CHAOS_DURATION
value: '30'
- Cachéa resultados de escaneos. Si los experimentos de chaos dependen de resultados de escaneo, cachéalos:
import functools
@functools.lru_cache(maxsize=1)
def get_service_inventory():
return fetch_service_inventory() # Llamada costosa
- Paraleliza checks de steady-state. Verifica múltiples endpoints simultáneamente:
import concurrent.futures
def check_all_endpoints(urls):
with concurrent.futures.ThreadPoolExecutor(max_workers=10) as executor:
results = list(executor.map(check_endpoint, urls))
return all(results) Preguntas frecuentes
¿Esta solución está lista para producción?
Sí. Los ejemplos de código arriba muestran implementaciones probadas. Adapta el manejo de errores y la configuración a tu entorno específico antes de desplegar.
¿Cuáles son las características de rendimiento?
El rendimiento depende de tu volumen de datos e infraestructura. Las soluciones mostradas priorizan claridad. Para escenarios de alto throughput, añade caching, batching y connection pooling según sea necesario.
¿Cómo depuro problemas con este enfoque?
Empieza con el ejemplo mínimo de arriba. Añade logging en cada paso. Prueba con entradas pequeñas primero, luego escala. Usa el debugger de tu lenguaje para revisar los edge cases.
Ataque Gremlin (CPU Stress)
# Instalar Gremlin CLI
sudo apt-get install gremlin
# CPU stress en un contenedor específico por 60 segundos
gremlin attack cpu --percent 80 --length 60 --container <container-id>
# Blackhole de red (descartar todo el tráfico a una dependencia)
gremlin attack blackhole --ip 10.0.4.20 --length 30
# Consumo de memoria
gremlin attack memory --percent 75 --length 45
Toxiproxy (Chaos de Red para Dependencias)
# Iniciar Toxiproxy
docker run -p 8474:8474 -p 3306:3306 ghcr.io/shopify/toxiproxy:latest
# Crear un proxy para MySQL
toxiproxy-cli create mysql-proxy -l 0.0.0.0:3306 -u 127.0.0.1:3307
# Añadir 2000ms de latencia a conexiones MySQL
toxiproxy-cli toxic add mysql-proxy -n latency -t latency=2000
# Añadir timeout (conexiones caen después de 500ms)
toxiproxy-cli toxic add mysql-proxy -n timeout -t timeout=500
# Remover todos los toxics
toxiproxy-cli toxic delete mysql-proxy -n latency
Script de Verificación de Steady-State
import requests
import time
import sys
def check_steady_state():
"""Verifica SLOs antes, durante y después de experimentos de chaos."""
checks = [
("https://api.example.com/health", 200, 500),
("https://api.example.com/metrics", 200, 1000),
]
all_pass = True
for url, expected_status, max_latency in checks:
try:
start = time.time()
resp = requests.get(url, timeout=5)
latency_ms = (time.time() - start) * 1000
if resp.status_code != expected_status:
print(f"FAIL: {url} retornó {resp.status_code}, esperado {expected_status}")
all_pass = False
elif latency_ms > max_latency:
print(f"FAIL: {url} latencia {latency_ms:.0f}ms excede {max_latency}ms")
all_pass = False
else:
print(f"OK: {url} - {resp.status_code} en {latency_ms:.0f}ms")
except requests.RequestException as e:
print(f"FAIL: {url} inalcanzable: {e}")
all_pass = False
return all_pass
if __name__ == "__main__":
if not check_steady_state():
print("Steady state violado. Abortando experimento.")
sys.exit(1)
print("Steady state confirmado. Seguro proceder.")
Plantilla de Runbook para Game Day
# Game Day: <Fecha>
Recursos Relacionados
Guía de Pipelines CI/CD
Una guía práctica para construir pipelines CI/CD con GitHub Actions, testing, estrategias de deployment y procedimientos de rollback.
DocPlantilla de Página de Estado de API
Una plantilla para una página de estado de API pública que comunica uptime, incidentes y ventanas de mantenimiento a los consumidores.
DocPlantilla de Reporte de Bug
Plantilla estructurada de reporte de bugs para ayudar a equipos a reproducir, clasificar y resolver defectos más rápido con pasos claros y comportamiento esperado.
DocPlantilla de Planificación de Capacidad
Una plantilla reutilizable para planificar capacidad del sistema, estimar crecimiento y prevenir cuellos de botella de rendimiento antes de que ocurran.
DocPlantilla de Changelog
Plantilla de changelog estructurada siguiendo las convenciones de Keep a Changelog para registrar versiones del proyecto.
RecipeTestear a Través de Múltiples OS y Versiones con GitHub
Cómo usar GitHub Actions matrix strategy para testear a través de múltiples sistemas operativos, versiones de lenguajes y configuraciones con include, exclude y matrices dinámicas.