observability

name	observability
description	Logging, metrics, and distributed tracing. OpenTelemetry, Prometheus, Grafana, and production debugging.
sasmp_version	2.0.0
bonded_agent	08-backend-observability
bond_type	PRIMARY_BOND
atomic_operations	["LOGGING_SETUP","METRICS_COLLECTION","TRACING_IMPLEMENTATION","ALERTING_CONFIGURATION"]
parameter_validation	{"query":{"type":"string","required":true,"minLength":5,"maxLength":2000},"pillar":{"type":"string","enum":["logs","metrics","traces","alerts"],"required":false}}
retry_logic	{"max_attempts":3,"backoff":"exponential","initial_delay_ms":1000}
logging_hooks	{"on_invoke":"skill.observability.invoked","on_success":"skill.observability.completed","on_error":"skill.observability.failed"}
exit_codes	{"SUCCESS":0,"INVALID_INPUT":1,"COLLECTION_ERROR":2}

Observability Skill

Bonded to: backend-observability-agent (Primary)

---

Quick Start

# Invoke observability skill
"Set up structured logging for my application"
"Configure Prometheus metrics"
"Implement distributed tracing with OpenTelemetry"

---

Three Pillars

Pillar	Purpose	Tools
Logs	What happened	ELK, Loki
Metrics	System state	Prometheus, Grafana
Traces	Request flow	Jaeger, OpenTelemetry

---

Examples

Structured Logging

import structlog

structlog.configure(
    processors=[
        structlog.processors.TimeStamper(fmt="iso"),
        structlog.processors.JSONRenderer()
    ]
)

logger = structlog.get_logger()

def process_request(request):
    log = logger.bind(
        correlation_id=request.headers.get("X-Correlation-ID"),
        user_id=request.user.id
    )
    log.info("request_started", method=request.method)

Prometheus Metrics

from prometheus_client import Counter, Histogram

REQUEST_COUNT = Counter('http_requests_total', 'Total requests', ['method', 'status'])
REQUEST_LATENCY = Histogram('http_request_duration_seconds', 'Request latency')

@REQUEST_LATENCY.time()
async def handle_request(request):
    response = await process(request)
    REQUEST_COUNT.labels(method=request.method, status=response.status_code).inc()
     response