Merge: Unisci branch paralleli

logic_merge · logic · Logica & Flow · Disponibile · v1.0.0

Descrizione

Operatore di fan-in/join enterprise che combina gli output di N nodi paralleli upstream in un singolo output strutturato — la primitiva fondamentale di tutte le architetture fan-out + fan-in del workflow orchestration moderno (Airflow XCom, Temporal Workflow, AWS Step Functions Parallel). Quando hai 3-10 rami che girano in parallelo per ottimizzare il tempo totale dell'esecuzione (es. 3 search API simultanei invece di sequenziali = 3× speedup), prima del passo successivo devi necessariamente unire i risultati in una struttura unica processabile — questo nodo lo fa con strategia configurabile per i 4 pattern di merge più comuni nei workflow business. Il merge è un fan-in che gira DOPO che i branch upstream sono completati (non controlla la loro esecuzione parallela). Quattro strategie: Strategia "all" — mappa output di ogni branch alla sua nodeId di provenienza: { branches: { "search_google": …, "search_bing": … }, branchCount } — il pattern più strutturato che preserva origin. Strategia "concat-arrays" — ogni branch ritorna un array (o una sua sub-property configurabile via "arrayProperty", default "results"), concatenati in uno solo: { results: [...], branchCount, totalItems }. Strategia "any"/"first" — usa l'output del PRIMO branch in ordine di sorgente (idx più basso); ritorna quell'output direttamente (fallback semplice, NON racing: i branch sono già eseguiti). Strategia "last" — usa l'output dell'ULTIMO branch in ordine. Sourcing dei branch: lista CSV esplicita di nodeId via "sourceNodeIds" (raccomandato per multi-branch complessi); se vuoto prende TUTTI i nodeOutputs disponibili al merge. I branch senza output (es. ramo skipato da logic_switch) vengono semplicemente esclusi. Chiavi nodeId tipo `__proto__` non inquinano il prototype (Object.create(null)). Use case ricchi della pipeline business: 3 web search paralleli (Google + Bing + DuckDuckGo) → 60 risultati uniti per dedup downstream + lead scoring; multi-API enrichment di un lead B2B (lookup CRM Odoo + social media LinkedIn + geo location da IP) in parallelo → object enriched complete per il sales team; ensemble AI agent voting su task di classificazione difficile (3 LLM provider diversi votano la stessa label, majority vote dello strategia "all" con post-processing); aggregazione status monitoring (uptime check su 5 endpoint concurrent) in unica dashboard view; fan-out su multi-channel notification (Slack + Telegram + Email + WhatsApp) con merge per audit di delivery status complessivo.

⚙️ Parametri di configurazione

Campi mostrati nell’editor quando si configura il nodo. Generati direttamente dal NodeDefconfigFields.

Campo	Tipo	Required	Default	Descrizione
`strategy` Strategia di merge	`enum` `allconcat-arraysanyfirstlast`	si	`all`	• all (default): output = { branches: {nodeId: output, ...} } • concat-arrays: estrae output.<arrayProperty>[] di ogni branch + concatena in 1 array unico (use case 3 search → 60 result) • any/first: prende il primo branch (idx più basso) • last: prende l'ultimo
`sourceNodeIds` Source node IDs (CSV, opzionale)	`string`	no	— search_yacht_it,search_distrib_eu,search_marina_med	CSV degli id dei nodi sorgente da combinare. Se vuoto, prende TUTTI i nodi precedentemente eseguiti (auto-discovery, OK per workflow lineari semplici). Riempire ESPLICITAMENTE per workflow con multi-branch complessi.
`arrayProperty` Property name (solo per strategy=concat-arrays)	`string`	no	`results` results	Nome del campo che contiene l'array da concatenare. Default "results" (matcha action_web_search.results). Cambialo se i tuoi nodi sorgente usano altro nome (es. "items", "rows").

💡 Esempio configurazione

Snippet JSON del nodo come compare nel workflow. I valori sono derivati daidefaultValue e dai parametri required.

{
  "id": "node-logic_merge-1",
  "defId": "logic_merge",
  "label": "Merge: Unisci branch paralleli",
  "config": {
    "strategy": "all",
    "arrayProperty": "results"
  }
}

🔗 Nodi correlati nella stessa categoria

Pronto a usare Merge: Unisci branch paralleli?

Disponibile da subito in tutti i piani FlowForge. Provalo gratis senza carta di credito.

Inizia gratis Sfoglia tutti i nodi