Ir al contenido
Datos y Bases de Datos

Reconciliación de contadores de clasificación entre índice invertido y fuente mediante fusión de ramas

10 nodos 94 4 Manual trigger
Descargar

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. 1.Ejecuta el disparador manual para emitir registros ficticios con dos sub-arreglos y un registro inválido
  2. 2.La rama A descompone por producto cruzado y descarta una fila para simular pérdida silenciosa
  3. 3.La rama B cuenta, por valor de categoría, cuántos registros fuente lo contienen
  4. 4.Un Merge append reúne ambas ramas, cada una en su propia entrada
  5. 5.Un nodo de código construye el índice invertido y compara cada conteo contra la referencia
  6. 6.IF envía los ítems con drift=0 al informe y los desviados por el checkpoint NoOp
  7. 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

  1. Importa el JSON en n8n y ejecuta 'Run Demo'
  2. Verifica que channel/phone aparezca con drift -1 (fila R-003 perdida)
  3. Prueba el camino sano eliminando la línea de simulación en la rama A; el estado será balanced
  4. 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

Manual Trigger Code Merge If No Op

Detalles

Disparador Manual trigger
Nodos 10
Aplicaciones 5
Vistas 94
Descargas 4

Cómo usar

  1. 1.Haz clic en "Descargar plantilla"
  2. 2.Abre tu panel de n8n
  3. 3.Ve a Workflows > Import from File
  4. 4.Selecciona el archivo descargado y configura las credenciales

Nodos utilizados (10)

/

Run Demo

Manual Trigger

#1

Emit Sample Records

Code

#2

Explode Subarrays (Branch A)

Code

#3

Tally Source Counts (Branch B)

Code

#4

Append Branches

Merge

#5

Reconcile Index vs Source

Code

#6

Balanced?

If

#7

Drift Report Checkpoint

No Op

#8

Join Report Branches

Merge

#9

Final Sorted Index Report

Code

#10

Note: Setup

Sticky Note

#11

Note: Reconciliation Rule

Sticky Note

#12

Note: Outputs

Sticky Note

#13
Mantente al día

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

Descubre las novedades primero

Tu nombre, tu correo y una confirmación.

Confirmación por correo · Cancela cuando quieras