Contrato de evento
Campos que espera la consulta
| Campo | Tipo | Por que existe |
|---|---|---|
| timestamp_utc | Timestamp | Cuando finalizó el intento de procesamiento. |
| delivery_id | Utf8 | Identificador estable compartido por reintentos. |
| provider | Utf8 | Proveedor de webhook. |
| event_type | Utf8 | Tipo de evento del proveedor. |
| attempt | Int64 | Intento de procesamiento basado en uno. |
| status | Utf8 | exitoso, fallido o deduplicado. |
Copiar la consulta
WITH delivery_outcomes AS (
SELECT
delivery_id,
provider,
event_type,
MAX(attempt) AS attempts,
SUM(CASE WHEN status = 'failed' THEN 1 ELSE 0 END) AS failed_attempts,
SUM(CASE WHEN status = 'success' THEN 1 ELSE 0 END) AS successful_attempts,
SUM(CASE WHEN status = 'deduplicated' THEN 1 ELSE 0 END) AS deduplicated_attempts
FROM webhook_deliveries
WHERE timestamp_utc >= now() - INTERVAL '7 days'
GROUP BY delivery_id, provider, event_type
)
SELECT
provider,
event_type,
COUNT(*) AS deliveries,
SUM(CASE
WHEN failed_attempts > 0 AND successful_attempts > 0 THEN 1 ELSE 0
END) AS recovered,
SUM(CASE
WHEN failed_attempts > 0 AND successful_attempts = 0 THEN 1 ELSE 0
END) AS permanent_failures,
SUM(deduplicated_attempts) AS duplicates_suppressed
FROM delivery_outcomes
GROUP BY provider, event_type
ORDER BY permanent_failures DESC, recovered DESC;Esta consulta de solo lectura se planifica y ejecuta en una tabla escrita vacía con Apache DataFusion 45.2.0. El resultado de la muestra determinista es sintético y se revisa por separado; valide tipos de campos, umbrales y definiciones comerciales con sus propios datos. Lea la metodología de prueba.
Resultado de la consulta
Fallos permanentes por evento de webhook
Los eventos recuperados permanecen visibles sin contarse como impacto permanente en el cliente.
| provider | event_type | deliveries | recovered | permanent_failures | duplicates_suppressed |
|---|---|---|---|---|---|
| stripe | invoice.payment_succeeded | 4 | 1 | 1 | 1 |
| github | push | 3 | 1 | 0 | 1 |
Salida de ejemplo sintético. Ejecute la consulta con su propio esquema de eventos y umbrales antes de utilizarla para decisiones operativas.
Reproducir el ejemplo
Descargar el accesorio público
El paquete JSON incluye el contrato de evento escrito, reproducible filas de entrada, SQL exacto, resultado esperado, notas de revisión y versión del motor. El CSV contiene el resultado mostrado.
Cómo funciona el SQL
- 1El primer CTE agrupa todos los intentos de una entrega en un único registro de resultados.
- 2Una entrega recuperada tiene al menos un intento fallido y al menos un intento exitoso. Un fracaso permanente nunca registró éxito.
- 3La supresión de duplicados se rastrea por separado porque la idempotencia correcta es un resultado saludable, no una falla de procesamiento.
Casos extremos para decidir
- Conserve los ID de entrega del proveedor para que los reintentos se puedan agrupar de manera confiable.
- Una entrega puede recuperarse después de la ventana de consulta; utilice una ventana lo suficientemente larga para cubrir el programa de reintentos del proveedor.
- Separe el recibo de los efectos secundarios posteriores cuando el éxito requiere algo más que reconocer al proveedor.
Panel recomendado
- Barras agrupadas: recuperadas y permanent_failures por event_type
- Estadística: tasa de supresión de duplicados
- Tabla: últimas fallas permanentes con contexto laboral aguas abajo
Guía de alerta
Alertar inmediatamente sobre fallos permanentes en caso de eventos críticos para los ingresos y sobre un aumento repentino de las entregas recuperadas como señal de alerta temprana.
Leer configuración de alertaPon la receta a trabajar
Instrumentación y guías relacionadas.
Definir los datos de origen
Esquemas de eventos para este análisis.
Continuar el análisis
Medir la latencia del webhook y la tasa de duplicados
Compare la latencia de procesamiento, las entregas duplicadas y las fallas por proveedor de webhook y tipo de evento.
Receta abiertaMedir la finalización del webhook de un extremo a otro
Siga cada webhook desde su recepción hasta su finalización y mida el porcentaje que finaliza dentro de un objetivo operativo.
Receta abiertaEjecútelo en eventos reales.
Crea una tabla, adapta los campos y guarda el resultado.
Comience gratis, envíe eventos estructurados y utilice el resultado de la consulta como un gráfico, un widget de panel compartido o una entrada de alerta.