Reconciliación de contadores de clasificación entre índice invertido y fuente mediante fusión de ramas
Cargando flujo…
Descripción del flujo de trabajo
Flujo autónomo que descompone sub-arreglos en una rama de código (promoviendo cada clave de arreglo a columna de clasificación), calcula un conteo de referencia por valor en una segunda rama, concatena ambas ramas en un nodo Merge append con una entrada independiente por rama, construye un índice invertido y reconcilia el conteo pos-fusión de cada categoría contra su conteo en la fuente. Un nodo IF separa lo equilibrado de lo desviado, un NoOp marca el punto de control de desviación y un nodo final emite un informe con el índice ordenado descendente.
Cómo funciona
- 1.Ejecuta el disparador manual para emitir registros ficticios con dos sub-arreglos y un registro inválido
- 2.La rama A descompone por producto cruzado y descarta una fila para simular pérdida silenciosa
- 3.La rama B cuenta, por valor de categoría, cuántos registros fuente lo contienen
- 4.Un Merge append reúne ambas ramas, cada una en su propia entrada
- 5.Un nodo de código construye el índice invertido y compara cada conteo contra la referencia
- 6.IF envía los ítems con drift=0 al informe y los desviados por el checkpoint NoOp
- 7.Las ramas se unen y se emite un ítem final: índice ordenado, reconciliación, informe de desviación y estado
Casos de uso
- Auditar pérdida silenciosa de filas al descomponer arreglos en múltiples ramas fusionadas
- Construir un índice de clasificaciones confiable y ordenable antes de aceptar resultados
- Filtrar registros inválidos antes de la descomposición
Requisitos
- n8n 2.44.6 con nodos code, merge, if, noOp, stickyNote y manualTrigger
- Sin credenciales; la carga de prueba ficticia está incluida
- Para datos reales, sustituye el nodo de muestra por una fuente con esquema {record_id, <clave>: string[]}
Configuración y pruebas en n8n
- Importa el JSON en n8n y ejecuta 'Run Demo'
- Verifica que channel/phone aparezca con drift -1 (fila R-003 perdida)
- Prueba el camino sano eliminando la línea de simulación en la rama A; el estado será balanced
- Prueba casos límite con registros vacíos o sin record_id; aparecerán en invalid_records
Valor del servicio
Ideal como servicio de automatización operativa para conectar sistemas, reducir tareas manuales y acelerar la entrega de resultados a clientes o equipos internos.
Aplicaciones utilizadas
Detalles
Cómo usar
- 1.Haz clic en "Descargar plantilla"
- 2.Abre tu panel de n8n
- 3.Ve a Workflows > Import from File
- 4.Selecciona el archivo descargado y configura las credenciales
Nodos utilizados (10)
Run Demo
Manual Trigger
Emit Sample Records
Code
Explode Subarrays (Branch A)
Code
Tally Source Counts (Branch B)
Code
Append Branches
Merge
Reconcile Index vs Source
Code
Balanced?
If
Drift Report Checkpoint
No Op
Join Report Branches
Merge
Final Sorted Index Report
Code
Note: Setup
Sticky Note
Note: Reconciliation Rule
Sticky Note
Note: Outputs
Sticky Note
Nuevas automatizaciones, directamente en tu correo
Recibe los nuevos flujos de DROPIDEA, una descripción clara de su utilidad y un enlace para explorarlos.
- Nuevos flujos
- Explicaciones claras
- Guías de configuración