Skip to main content

ToPipelineDataEvent@1

Node ToPipelineDataEvent@1 is used to send data to the event hub of OctoMesh, enabling inter-pipeline communication within a DataFlow.

This node publishes data to a topic exchange named after the DataFlow. When a targetPipelineRtId is configured, the data is routed to a specific pipeline using the target pipeline's runtime entity ID as the routing key. This allows targeted communication between pipelines within the same DataFlow.

The event triggers the FromPipelineDataEvent@1 node of the target pipeline.

Adapter Prerequisites​

  • General availability: All adapters support this node type.

Node Configuration​

For fields path, targetPath, targetValueWriteMode, and targetValueKind, see Overview.

FieldTypeRequiredDescription
targetPipelineRtIdOctoObjectIdNoThe runtime entity ID of the target pipeline. When set, data is routed via the DataFlow topic exchange using this ID as the routing key. When omitted, the event is broadcast to all pipelines in the DataFlow.

Basic usage (broadcast to all pipelines in the DataFlow)​

transformations:
- type: ToPipelineDataEvent@1 # The complete content of the payload will be sent to the event hub
  description: Load to event hub

Targeted inter-pipeline communication​

transformations:
- type: ToPipelineDataEvent@1
  description: Send data to a specific pipeline within the DataFlow
  targetPipelineRtId: "67e132d6477e78e980bbb512"

In this example, the data is published to the DataFlow's topic exchange with the routing key set to the target pipeline's runtime entity ID. Only the pipeline with a matching FromPipelineDataEvent@1 trigger bound to that routing key will receive the data.