Zum Hauptinhalt springen

FromPipelineDataEvent@1

Der Node FromPipelineDataEvent@1 wird verwendet, um Daten aus einem Pipeline-Data-Event zu empfangen und die Ausführung der Transformations-Pipeline auszulösen.

Dieser Node registriert automatisch zwei Consumer:

  • Pub/Sub-Consumer: Bindet sich an den DataFlow-Topic-Exchange und verwendet dabei die eigene Runtime-Entitäts-ID der Pipeline als Routing-Key, um Fire-and-Forget-Nachrichten von vorgelagerten ToPipelineDataEvent@1-Nodes zu empfangen.
  • Command-Consumer: Lauscht auf Command/Response-Anfragen von vorgelagerten ToPipelineDataEvent@1-Nodes, die awaitResult: true gesetzt haben. Führt die Pipeline aus und gibt das Ergebnis an den Aufrufer zurück.

Es ist keine Konfiguration nötig, um einen der beiden Modi zu aktivieren — der Node handhabt beide automatisch.

Architektur der Kommunikation zwischen Pipelines​

Die DataFlow-Entität etabliert einen gemeinsamen Topic-Exchange im Event Hub. Wenn Pipelines innerhalb desselben DataFlow kommunizieren müssen:

Fire-and-Forget-Modus​

  1. Die sendende Pipeline verwendet ToPipelineDataEvent@1 mit einer targetPipelineRtId, um Daten im Topic-Exchange des DataFlow zu veröffentlichen
  2. Die empfangende Pipeline verwendet FromPipelineDataEvent@1, das sich automatisch an den Exchange bindet und dabei die eigene Pipeline-Runtime-Entitäts-ID als Routing-Key verwendet
  3. Der Event Hub leitet die Nachricht anhand der Routing-Key-Übereinstimmung an die richtige Pipeline weiter

Command/Response-Modus (auf Ergebnis warten)​

  1. Die sendende Pipeline verwendet ToPipelineDataEvent@1 mit awaitResult: true, um eine Command-Anfrage zu senden
  2. Der Command-Consumer der empfangenden Pipeline führt die Pipeline aus und erfasst das Ergebnis
  3. Das Ergebnis wird an den Sender zurückgesendet, der es im Datenkontext unter resultTargetPath ablegt

Wenn im Command/Response-Modus die Ziel-Pipeline fehlschlägt, wird der Fehler an den Sender zurückgegeben — die Ausführung des Senders schlägt ebenfalls mit der Fehlermeldung des Ziels fehl.

Adapter-Voraussetzungen​

  • Allgemeine Verfügbarkeit: Alle Adapter unterstützen diesen Node-Typ.

Node-Konfiguration​

triggers:
  - type: FromPipelineDataEvent@1

Es ist keine zusätzliche Konfiguration nötig. Der Node führt automatisch Folgendes aus:

  • Verwendet die eigene Runtime-Entitäts-ID der Pipeline als Routing-Key beim Binden an den Topic-Exchange des DataFlow (Pub/Sub)
  • Registriert einen Command-Consumer an einer deterministischen Adresse, die aus den IDs von Tenant, DataFlow und Pipeline abgeleitet wird (Command/Response)