Mergeコネクタ

概要

Mergeコネクタは、さまざまな戦略を使用して複数のソースからペイロードを結合します。

コネクタタイプ: MeddleMerge

Timed Releaseモード

定期的な間隔で結合されたデータをリリース：

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

5秒間データを収集し、結合されたペイロードをリリースします。

Wait For Keysモード

すべての必要なキーが存在するまで待機：

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

3つすべてのキーを待ち、完了時または10秒後にリリースします。

例

入力ストリーム:

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

出力（WaitForKeys）:

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

設定パラメータ

mode: TimedReleaseまたはWaitForKeys
releaseInterval: （TimedRelease）ミリ秒単位の間隔
requiredKeys: （WaitForKeys）必要なキーの配列
timeout: （WaitForKeys）ミリ秒単位の最大待機時間
maxRetained: （オプション）メモリに保持する最大ペイロード

ユースケース

異なる速度で読み取る複数のセンサーを同期
高頻度ソースからデータをバッチ処理
異なるシステムから関連する測定値を結合

ベストプラクティス

メモリ使用量を制限するために適切なmaxRetainedを設定
欠落データを処理するためにtimeoutを使用
TimedReleaseを使用する場合はデータの鮮度を考慮