Flask and SQLAlchemy Telemetry: del límite a la fila verificada
Utilice Flask and SQLAlchemy Telemetry en un límite de aplicación controlado, mantenga el contrato de evento pequeño y verifique un resultado conocido antes de crear vistas agregadas.
- 1
Elige el resultado
Fiabilidad de la API del matraz
- 2
Definir el contrato
request_id, punto final, route_template, método y status_code
- 3
Instrumentar el límite
Utilice el url_rule coincidente de Flask en lugar de request.path para que los identificadores no creen problemas de cardinalidad o privacidad.
- 4
Verificar la evidencia
Exercise a known fixture, then inspect api_request_completed for one correctly typed terminal row.
Antes de empezar
Requisitos previos y límites
- telemetry-sh se inicializa una vez en cada proceso de trabajo de Flask
- Una taxonomía estable de puntos finales de Flask y un temporizador de solicitud monótono
- Oyentes de eventos de SQLAlchemy limitados a recuentos, duraciones y metadatos de operación segura
Configuración de entrega
Instalar e inicializar el lado del servidor
Inicialice Telemetry para código síncrono o TelemetryAsync para código asíncrono una vez por proceso con una clave del lado del servidor. Mantenga las credenciales de ingesta fuera de los paquetes de navegador, las variables de entorno visibles para el cliente, el control de fuente, los registros y los mensajes de excepción.
Instalación pip
python -m pip install telemetry-sh- 1Prepare un cliente de entrega del lado del servidor reutilizable con comportamiento de red limitado.
- 2Agregue el evento de resultado en el límite de éxito, error, reintento o tiempo de espera.
- 3Envíe accesorios controlados e inspeccione las filas almacenadas antes de habilitar una alerta.
Fragmento
Comience con un evento estructurado
Agregue esta forma donde el flujo de trabajo se completa, falla o se vuelve a intentar. Luego cree el panel a partir de campos reales.
Evento Flask and SQLAlchemy Telemetry
from flask import g, request
from time import monotonic
@app.before_request
def start_request_timer():
g.request_started_at = monotonic()
g.db_query_count = 0
@app.after_request
def record_request_outcome(response):
route = request.url_rule.rule if request.url_rule else "unmatched"
telemetry.log("api_request_completed", {
"request_id": request.headers.get("X-Request-ID"),
"endpoint": request.endpoint or "unmatched",
"route_template": route,
"method": request.method,
"status_code": response.status_code,
"status": "failed" if response.status_code >= 500 else "success",
"latency_ms": round((monotonic() - g.request_started_at) * 1000),
"db_query_count": g.db_query_count,
"release": app.config.get("APP_RELEASE"),
})
return responseContrato de evento
request_id, punto final, route_template, método y status_code
estado, latency_ms, db_query_count, rollback_count y error_type
servicio, entorno, versión y contexto de inquilino aprobado
Puntos de control de implementación
Punto de control 1
Utilice el url_rule coincidente de Flask en lugar de request.path para que los identificadores no creen problemas de cardinalidad o privacidad.
Punto de control 2
Almacene contadores por solicitud en flask.g y actualícelos desde los enlaces SQLAlchemy revisados; nunca envíe texto SQL, parámetros vinculados, cadenas de conexión u objetos ORM.
Punto de control 3
Puede ocurrir una excepción de desmontaje después de que se construye una respuesta, por lo que modela el resultado de la solicitud y la reversión de la transacción como eventos distintos cuando ambas preguntas son importantes.
Verificación
Demuestra que el evento llegó
Ejecute esto después de ejercitar casos conocidos de éxito y fracaso. Reemplace el nombre de la tabla alternativa si su contrato de evento final difiere del fragmento.
Consulta de verificación Flask and SQLAlchemy Telemetry
SELECT *
FROM api_request_completed
ORDER BY timestamp_utc DESC
LIMIT 20;Referencias de implementación
Revise el contrato del evento, la guía de seguridad de los datos y la documentación primaria previa antes de habilitar una nueva ruta de producción.
Límite de producción
Mantenga el evento de resultado pequeño y recuperable
Este patrón proporciona
- Un resultado limitado y listo para SQL junto al flujo de trabajo ascendente.
- Campos estables para paneles, alertas y correlación entre eventos.
- Una ruta basada en dispositivos para validar el comportamiento de éxito, fracaso, reintento y tiempo de espera.
Este patrón no proporciona
- Un exportador de OTLP, un canal de recopilación automática o un reemplazo para seguimientos detallados y registros de diagnóstico.
- Entrega exactamente una vez simplemente porque la carga útil contiene un ID de evento.
- Permiso para recopilar cargas útiles sin procesar del proveedor, contenido de usuario, credenciales o datos regulados.
Puntos de partida del esquema de eventos
Contratos de eventos para este flujo de trabajo
Revise el detalle de la fila, el límite de emisión, los tipos requeridos, las clases de privacidad, la carga útil de ejemplo y la lista de verificación de validación antes de adaptar una consulta o fragmento a producción.
Función relacionada del producto
Continúe este flujo de trabajo en Alertas
Promueva la consulta de confiabilidad revisada a un umbral propio y un flujo de trabajo de respuesta.
Recetas SQL relacionadas
Responde la siguiente pregunta con SQL
Ejecute la consulta en los campos estructurados de este flujo de trabajo, inspeccione el resultado del ejemplo y convierta una respuesta útil en un panel o alerta.
Calcular la tasa de errores de API por ruta
¿Qué rutas API tienen la tasa de error 5xx significativa más alta?
Receta abiertaCalcule la latencia API p50, p95 y p99
¿Qué puntos finales tienen la peor latencia de cola?
Receta abiertaEncuentre consultas lentas en bases de datos por huella digital
¿Qué operaciones de bases de datos son lo suficientemente lentas como para investigarlas?
Receta abiertaCalcular la tasa de reversión de transacciones de la base de datos
¿Qué servicios revierten una proporción inusual de transacciones de bases de datos?
Receta abiertaClasificar consultas de bases de datos por impacto en el tiempo total
¿Qué operación de base de datos consume la mayor cantidad de tiempo de solicitud acumulado?
Receta abiertaExplorar por familia de implementación
Comparar patrones de integración relacionados
Plantillas para combinar con esta integración
Plantilla de monitoreo de confiabilidad de la base de datos
Instrumente huellas digitales de operación lenta, contención de grupos, reversiones de transacciones, bloqueos, retrasos en la replicación y resultados de migración con eventos estructurados seguros.
Abrir plantillaMonitor de latencia y errores de API
Observe el volumen de solicitudes, los códigos de estado, la latencia de ruta, los puntos finales fallidos y los incidentes de API que afectan al cliente.
Abrir plantillaMás integraciones
Operación MongoDB Telemetry
Realice un seguimiento de las operaciones de MongoDB con nombre, la latencia, los recuentos de resultados, los reintentos, los resultados de las transacciones y las regresiones de lanzamiento sin recopilar documentos ni valores de consulta.
abrir guiaConsulta y grupo MySQL Telemetry
Realice un seguimiento de las operaciones normalizadas de MySQL, la espera del grupo, los resultados de las transacciones, las categorías de errores controladas y publique regresiones sin almacenar SQL ni parámetros sin formato.
abrir guiaBase de datos ORM de Prisma Telemetry
Mida las huellas digitales de las operaciones de Prisma, la latencia de los modelos y métodos, las fallas, los recuentos de resultados, las versiones y los flujos de trabajo dependientes de la base de datos sin recopilar parámetros de consulta sin procesar.
abrir guia