Seguir un trabajo lógico en todos los intentos
Mantenga un identificador de trabajo estable y separe los eventos a nivel de intento del resultado final para que la recuperación de reintentos siga siendo mensurable.
Marco de selección
Elige el límite que conoce el resultado.
Espera de cola separada de la ejecución
Las marcas de tiempo programadas, en cola, iniciadas y completadas distinguen la presión del trabajo pendiente del código de trabajo lento.
Definir estados terminales
Documente los resultados completados, fallidos permanentemente, cancelados, descartados y con mensajes no entregados antes de escribir consultas o alertas de trabajos estancados.
Contrato de evento compartido
Mantenga el primer esquema interoperable
- job_id, job_name, queue_name, estado, intento y liberación
- scheduled_at, started_at, completed_at, duration_ms y wait_ms
- error_type, worker_name, item_count, dead_lettered y account_id
Adapte estos campos al flujo de trabajo, pero mantenga explícitas las unidades, categorías de estado, identificadores y propiedad antes de que varios servicios dependan de la misma tabla.
Verificación
Ejercer rutas de falla antes de las alertas
- 1Ejecute un proceso exitoso, vuelva a intentar la recuperación, falla permanente y cancelación.
- 2Confirme que el mismo trabajo lógico permanezca correlacionado entre los intentos.
- 3Concilie la espera de la cola, la duración de la ejecución y la duración de un extremo a otro.
- 4Pruebe la entrega duplicada y el comportamiento descendente idempotente.
Guías de implementación
Haga coincidir el marco, el proveedor o el tiempo de ejecución
Guía de configuración con enlaces a las fuentes
Trabajo de Inngest y Trigger.dev Telemetry
Instrumente trabajadores asíncronos, trabajos programados, reintentos, fallas y eventos de mensajes no entregados con registros listos para SQL.
abrir guiaGuía de configuración con enlaces a las fuentes
Monitoreo de eventos estructurados de Django y Apio
Registra los estados de cada intento de una tarea Celery sin confundir los reintentos con fallos definitivos ni cambiar el resultado de la tarea.
abrir guiaGuía de configuración con enlaces a las fuentes
Observabilidad del flujo de trabajo temporal
Realice un seguimiento de los resultados del flujo de trabajo temporal, los reintentos de actividad, la latencia del inicio programado y los hitos comerciales sin registrar las cargas útiles del flujo de trabajo.
abrir guiaGuía de configuración con enlaces a las fuentes
Flujo de trabajo n8n Telemetry
Envíe los resultados de finalización, error, reintento, recuento de elementos y entrega posterior del flujo de trabajo n8n a un evento Telemetry limitado a través del nodo de solicitud HTTP.
abrir guiaGuía de configuración con enlaces a las fuentes
Monitoreo de cola BullMQ
Mida la espera de la cola de BullMQ, la duración de la ejecución, los reintentos, los fallos y el crecimiento de los mensajes no entregados con eventos del ciclo de vida preparados para SQL.
abrir guiaGuía de configuración con enlaces a las fuentes
Observabilidad de colas de AWS SQS
Realice un seguimiento de la antigüedad de los mensajes SQS, los intentos de recepción, los resultados del procesamiento, el comportamiento de los lotes y el enrutamiento de mensajes fallidos sin almacenar los cuerpos de los mensajes.
abrir guiaGuía de configuración con enlaces a las fuentes
Cola RabbitMQ Telemetry
Realice un seguimiento de la confirmación de publicación, entrega, acuse de recibo, reenvío, espera en cola, reintentos y resultados de mensajes fallidos de RabbitMQ con eventos estructurados.
abrir guiaGuía de configuración con enlaces a las fuentes
Pub/Sub de Google Cloud Telemetry
Realice un seguimiento de la publicación, entrega, acuse de recibo, reenvío, pedidos, antigüedad de la cola y resultados de mensajes fallidos de Pub/Sub con identificadores de mensajes estables.
abrir guiaGuía de configuración con enlaces a las fuentes
Bus de servicio de Azure Telemetry
Realice un seguimiento de los envíos, recepciones, renovación de bloqueos, liquidación, reenvío, aplazamiento y resultados de mensajes fallidos de Azure Service Bus sin recopilar cuerpos de mensajes.
abrir guiaGuía de configuración con enlaces a las fuentes
Análisis de procesamiento y retraso del consumidor de Kafka
Supervise los resultados del consumidor de Kafka, el retraso de la partición, la latencia del procesamiento, los reintentos y el manejo de mensajes dudosos con eventos estructurados.
abrir guiaGuía de configuración con enlaces a las fuentes
Trabajo de Sidekiq Telemetry
Registra los resultados y la duración del bloque de trabajo de Sidekiq sin cambiar el resultado del worker ni copiar los argumentos.
abrir guiaGuía de configuración con enlaces a las fuentes
Redis y nodo-redis Telemetry
Mida los resultados de los comandos de Redis, la latencia, el comportamiento de la caché, las reconexiones y las categorías de errores delimitadas junto con node-redis.
abrir guiaGuía de configuración con enlaces a las fuentes
Monitoreo de eventos estructurados de AWS Lambda
Realice un seguimiento de las invocaciones de Lambda, los arranques en frío, la duración, los reintentos y los resultados comerciales con eventos estructurados compactos.
abrir guiaGuía de configuración con enlaces a las fuentes
Gancho web Stripe Telemetry
Depure el comportamiento de sincronización de pagos, suscripciones, facturas, reintentos y facturación posterior sin almacenar cuerpos de webhooks.
abrir guiaGuía de configuración con enlaces a las fuentes
Flujo de trabajo de acciones GitHub Integración Telemetry
Envíe un resultado de flujo de trabajo de terminal delimitado desde acciones GitHub con ejecución, intento, trabajo, conclusión, duración y contexto de lanzamiento.
abrir guiaPrimero verifique un flujo de trabajo de un extremo a otro
Cree una clave API gratuita, elija la guía de tiempo de ejecución más cercana y envíe un éxito y un fracaso conocidos antes de ampliar la cobertura.