Introducción

Esta es la lección capstone del curso. Has aprendido a usar el nodo Code, el nodo Set, el nodo IF, el nodo Merge y a dar forma a los datos con expresiones. Ahora vas a conectar todas esas piezas en un único flujo de trabajo que hace algo real: extraer datos de dos fuentes, limpiarlos y filtrarlos, transformarlos a una forma objetivo, combinar los flujos y producir un resultado final listo para uso posterior.

El escenario utilizado a lo largo de esta lección es práctico y representativo de lo que encontrarás en producción: tienes una lista de pedidos desde un endpoint HTTP y una lista de clientes desde otro. El objetivo es producir un informe de pedidos enriquecido que contenga únicamente los pedidos pagados, adjunte el nombre y el correo del cliente, y formatee las fechas para su visualización.

Obtención de datos desde dos fuentes en paralelo

Comienza con dos nodos HTTP Request que se ejecutan en paralelo. Ambos son activados por el mismo nodo Manual Trigger o Schedule Trigger. El primero obtiene los pedidos, el segundo obtiene los clientes. En n8n, divides la ejecución conectando un trigger a ambos nodos HTTP Request.

Para el endpoint de pedidos, configura la URL y asegúrate de que el formato de respuesta sea JSON. La respuesta cruda suele verse así:

[
  {"id": 101, "customer_id": 5, "status": "paid", "amount": 149.99, "created_at": "2024-03-15T10:22:00Z"},
  {"id": 102, "customer_id": 8, "status": "pending", "amount": 89.00, "created_at": "2024-03-16T08:05:00Z"}
]

Para el endpoint de clientes:

[
  {"id": 5, "name": "Alice Martin", "email": "alice@example.com"},
  {"id": 8, "name": "Bob Chen", "email": "bob@example.com"}
]

Ambos nodos producen arrays de items. n8n divide automáticamente los arrays en items individuales, de modo que cada pedido y cada cliente se convierten en items propios que fluyen por el resto del flujo de trabajo.

Filtrado y transformación de cada flujo

Antes de combinar, limpia cada flujo de forma independiente. Esto mantiene la lógica aislada y más fácil de depurar.

Para los pedidos, conecta un nodo IF después del HTTP Request de pedidos. Configura la condición para comprobar que el campo status sea igual a la cadena paid. Solo la rama true continúa. Esto elimina los pedidos pendientes, cancelados o reembolsados antes de que lleguen al merge.

A continuación, conecta un nodo Code después de la salida true del IF para remodelar el item del pedido y formatear la fecha:

const items = $input.all();
return items.map(item => {
  const d = new Date(item.json.created_at);
  const formatted = d.toLocaleDateString('en-GB', { day: '2-digit', month: 'short', year: 'numeric' });
  return {
    json: {
      order_id: item.json.id,
      customer_id: item.json.customer_id,
      amount: item.json.amount,
      order_date: formatted
    }
  };
});

Para los clientes, conecta un nodo Set después del HTTP Request de clientes. Úsalo para conservar explícitamente solo los campos que necesitas y renómbralos para mayor claridad. Asigna customer_key a la expresión que referencia el campo id, mantén name y email. Esto recorta el ruido y deja la clave del merge inequívoca.

Combinación de los dos flujos

Conecta ambos flujos transformados a un nodo Merge. Usa el modo Merge by Key. Configura la clave del input 1 (orders) como customer_id y la clave del input 2 (customers) como customer_key. n8n emparejará cada pedido con su registro de cliente y producirá un item combinado que contiene campos de ambos.

El item combinado en este punto contiene order_id, customer_id, amount, order_date, customer_key, name y email todos en el nivel superior de item.json. Puede haber campos redundantes como customer_key que añadiste solo para la unión. Límpialos en el siguiente paso.

Modelado final y salida

Añade un nodo Code más después del nodo Merge. Este es el paso final de transformación donde produces el contrato de salida exacto que prometiste a los consumidores posteriores:

const items = $input.all();
return items.map(item => {
  return {
    json: {
      order_id: item.json.order_id,
      order_date: item.json.order_date,
      amount_usd: item.json.amount,
      customer_name: item.json.name,
      customer_email: item.json.email
    }
  };
});

Este nodo elimina las claves internas de unión, renombra amount a amount_usd para mayor explicitud y produce un array limpio de registros de pedidos enriquecidos. Conecta este nodo al nodo final que necesites: un HTTP Request para enviar los resultados a un webhook, un nodo Google Sheets para añadir filas, o simplemente déjalo como nodo terminal durante el desarrollo e inspecciona la salida en el editor de n8n.

Resumen

Has construido un flujo de trabajo que cubre todo el ciclo de vida de la transformación: ingesta paralela desde dos fuentes HTTP, filtrado independiente con IF, remodelado por flujo con nodos Code y Set, un merge basado en claves y un pase final de limpieza. Cada nodo tiene una única responsabilidad clara, lo que hace que el flujo sea legible y depurable. Cuando algo falla en producción, puedes fijar datos en cualquier nodo y volver a ejecutar desde ese punto sin tocar los nodos anteriores. Esa estructura componible, y no ningún nodo individual, es la habilidad central que este curso ha buscado desarrollar.