_       _       _       _                     _                    _            _            
   ___ | |_ ___| |     | |_ ___| | ___ _ __ ___   ___| |_ _ __ _   _      | |_ ___  ___| |_ ___ _ __ 
  / _ \| __/ _ \ |_____| __/ _ \ |/ _ \ '_ ` _ \ / _ \ __| '__| | | |_____| __/ _ \/ __| __/ _ \ '__|
 | (_) | ||  __/ |_____| ||  __/ |  __/ | | | | |  __/ |_| |  | |_| |_____| ||  __/\__ \ ||  __/ |   
  \___/ \__\___|_|      \__\___|_|\___|_| |_| |_|\___|\__|_|   \__, |      \__\___||___/\__\___|_|   
                                                               |___/ hecho con ❤️ por Santiago Lator 

Herramienta CLI para probar implementaciones de OpenTelemetry enviando datos de telemetría (traces, métricas, logs) a backends compatibles.

• Envía 3 tipos de telemetría:
  • Traces con estructura compleja y errores simulados
  • Métricas tipo counter
  • Logs estructurados con múltiples niveles
• Soporte para protocolos gRPC y HTTP
• Modo continuo (tail) para pruebas de larga duración
• Paralelismo configurable para simulaciones de alta carga
• Conexiones seguras con TLS/SSL y autenticación flexible
• Compatibilidad con New Relic, Grafana, Jaeger, Datadog y otros backends OTLP

pip install otel-telemetry-tester-cli

otel-tester --endpoint production:4317 \
  --protocol grpc \
  --secure \
  --header "api-key=TU_API_KEY" \
  --trace-count 5 \
  --parallel 8

Para ver el listado de argumentos posibles:

otel-tester --help

• 3 spans jerárquicos por trace:

  Start Span: Inicialización del proceso
    └── Middle Span: Procesamiento principal
        └── End Span: Finalización y limpieza

• Atributos personalizados
• Errores simulados:
  • 30% de probabilidad de error en spans
  • Tipos: client, server, timeout
  • Registro de excepciones y códigos de estado

    span.set_status(StatusCode.ERROR)
    span.record_exception(ValueError("Simulated error"))

• Tipos soportados:

  • Counter: otel.tester.counter
  • Otros coming soon

• Atributos dinámicos:

  counter.add(value, {"environment": "prod", "metric_id": id})

• Niveles de log:

  • INFO: Mensajes operativos
  • WARN: Advertencias de sistema
  • ERROR: Errores críticos

• Dimensiones custom:

  {
    "log_id": 123,
    "service": "auth-service",
    "thread": 45678,
    "protocol": "grpc"
  }

Ejecuta la herramienta en segundo plano para monitoreo continuo:

otel-tester --tail \
  --endpoint otlp.nr-data.net:4317 \
  --protocol grpc \
  --trace-count 10 \
  ---metric-count 200 \
  --interval 1.5 \

🕹️ Control con Ctrl+C para detención limpia

📊 Estadísticas en tiempo real con --verbose

🔄 Reintentos automáticos en errores transitorios

📦 Optimización de recursos para ejecuciones prolongadas

• ThreadPoolExecutor para ejecución concurrente
• Barras de progreso con tqdm para monitoreo
• Locks para estadísticas thread-safe

with ThreadPoolExecutor(max_workers=args.parallel) as executor:
    futures = [executor.submit(task, i) for i in range(count)]

🚀 Enviando traces: 100%|██████| 500/500 [00:08<00:00, 58.23trace/s]
📈 Enviando métricas: 100%|████| 1000/1000 [00:02<00:00, 452.34metric/s]
📝 Enviando logs: 100%|██████| 2000/2000 [00:04<00:00, 487.12log/s]

Envio de traces y metricas en modo continuo:

otel-tester --tail \
  --endpoint collector:4317 \
  --protocol grpc \
  --trace-count 5 \
  --metric-count 100 \
  --interval 0.5 \
  --verbose

Enviar todos los tipos de telemetría:

otel-tester --endpoint localhost:4317 \
  --protocol grpc \
  --all 10 

"Prueba de stress" con logs:

otel-tester --tail \
  --log-count 5000 \
  --interval 0.1 \
  --parallel 16 \
  --service-name "stress-test"

Enviar con autenticación y seguridad:

otel-tester --endpoint https://observability.corp.com:443 \
  --protocol http \
  --secure \
  --header "X-API-Key=corp-key-123" \
  --header "X-Environment=prod" \
  -a 1000 \
  --parallel 24

Distribuido bajo licencia MIT. Ver LICENSE para más detalles.