Merge-Konnektor

Übersicht

Der Merge-Konnektor kombiniert Payloads aus mehreren Quellen mit verschiedenen Strategien.

Konnektor-Typ: MeddleMerge

Timed Release-Modus

Kombinierte Daten in regelmäßigen Abständen freigeben:

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

Sammelt Daten für 5 Sekunden und gibt dann das kombinierte Payload frei.

Wait For Keys-Modus

Warten, bis alle erforderlichen Schlüssel vorhanden sind:

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

Wartet auf alle drei Schlüssel, gibt frei, wenn vollständig oder nach 10 Sekunden.

Beispiel

Eingabe-Stream:

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

Ausgabe (WaitForKeys):

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

Konfigurationsparameter

mode: TimedRelease oder WaitForKeys
releaseInterval: (TimedRelease) Intervall in Millisekunden
requiredKeys: (WaitForKeys) Array erforderlicher Schlüssel
timeout: (WaitForKeys) Maximale Wartezeit in Millisekunden
maxRetained: (Optional) Maximale Payloads im Speicher

Anwendungsfälle

Mehrere Sensoren synchronisieren, die mit unterschiedlichen Geschwindigkeiten lesen
Daten batchen von Hochfrequenzquellen
Verwandte Messungen kombinieren von verschiedenen Systemen

Best Practices

Setzen Sie angemessenes maxRetained, um die Speichernutzung zu begrenzen
Verwenden Sie timeout, um fehlende Daten zu behandeln
Berücksichtigen Sie die Datenfrische bei Verwendung von TimedRelease