Connettore Merge

Panoramica

Il connettore Merge combina payload da più fonti utilizzando diverse strategie.

Tipo Connettore: MeddleMerge

Modalità Timed Release

Rilascia dati combinati a intervalli regolari:

{
  "type": "MeddleMerge",
  "config": {
    "mode": "TimedRelease",
    "releaseInterval": 5000
  }
}

Raccoglie dati per 5 secondi, quindi rilascia il payload combinato.

Modalità Wait For Keys

Attendi finché tutte le chiavi richieste sono presenti:

{
  "type": "MeddleMerge",
  "config": {
    "mode": "WaitForKeys",
    "requiredKeys": ["temperature", "pressure", "humidity"],
    "timeout": 10000
  }
}

Attende tutte e tre le chiavi, rilascia quando completo o dopo 10 secondi.

Esempio

Stream di Input:

{"temperature": 25.5}
{"pressure": 101.3}
{"humidity": 60}

Output (WaitForKeys):

{
  "temperature": 25.5,
  "pressure": 101.3,
  "humidity": 60
}

Parametri di Configurazione

• mode: TimedRelease o WaitForKeys
• releaseInterval: (TimedRelease) Intervallo in millisecondi
• requiredKeys: (WaitForKeys) Array di chiavi richieste
• timeout: (WaitForKeys) Tempo massimo di attesa in millisecondi
• maxRetained: (Opzionale) Massimo payload da mantenere in memoria

Casi d’Uso

1. Sincronizza più sensori che leggono a velocità diverse
2. Batch di dati da fonti ad alta frequenza
3. Combina misurazioni correlate da sistemi diversi

Best Practice

• Imposta maxRetained appropriato per limitare l’uso della memoria
• Usa timeout per gestire dati mancanti
• Considera la freschezza dei dati quando usi TimedRelease

Connettori Correlati

• Cron - Rilascio basato su pianificazione
• Conveyor - Routing semplice