java.lang.Object
software.amazon.jsii.JsiiObject
software.constructs.Construct
software.amazon.awscdk.Resource
software.amazon.awscdk.services.pipes.alpha.Pipe
All Implemented Interfaces:
IEnvironmentAware, IResource, IPipe, software.amazon.jsii.JsiiSerializable, software.constructs.IConstruct, software.constructs.IDependable

@Generated(value="jsii-pacmak/1.133.0 (build 0f43e37)", date="2026-07-02T13:33:03.828Z") @Stability(Experimental) public class Pipe extends Resource implements IPipe
(experimental) Amazon EventBridge Pipes connects sources to targets.

Pipes are intended for point-to-point integrations between supported sources and targets, with support for advanced transformations and enrichment.

Example:

 Queue sourceQueue;
 ApiDestination dest;
 ApiDestinationTarget apiTarget = ApiDestinationTarget.Builder.create(dest)
         .inputTransformation(InputTransformation.fromObject(Map.of("body", "👀")))
         .build();
 Pipe pipe = Pipe.Builder.create(this, "Pipe")
         .source(new SqsSource(sourceQueue))
         .target(apiTarget)
         .build();
 

See Also:
  • Field Details

    • PROPERTY_INJECTION_ID

      @Stability(Experimental) public static final String PROPERTY_INJECTION_ID
      (experimental) Uniquely identifies this class.
  • Constructor Details

    • Pipe

      protected Pipe(software.amazon.jsii.JsiiObjectRef objRef)
    • Pipe

      protected Pipe(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
    • Pipe

      @Stability(Experimental) public Pipe(@NotNull software.constructs.Construct scope, @NotNull String id, @NotNull PipeProps props)
      Parameters:
      scope - This parameter is required.
      id - This parameter is required.
      props - This parameter is required.
  • Method Details

    • fromPipeName

      @Stability(Experimental) @NotNull public static IPipe fromPipeName(@NotNull software.constructs.Construct scope, @NotNull String id, @NotNull String pipeName)
      (experimental) Creates a pipe from the name of a pipe.

      Parameters:
      scope - This parameter is required.
      id - This parameter is required.
      pipeName - This parameter is required.
    • getPipeArn

      @Stability(Experimental) @NotNull public String getPipeArn()
      (experimental) The ARN of the pipe.
      Specified by:
      getPipeArn in interface IPipe
    • getPipeName

      @Stability(Experimental) @NotNull public String getPipeName()
      (experimental) The name of the pipe.
      Specified by:
      getPipeName in interface IPipe
    • getPipeRole

      @Stability(Experimental) @NotNull public IRole getPipeRole()
      (experimental) The role used by the pipe.

      For imported pipes it assumes that the default role is used.

      Specified by:
      getPipeRole in interface IPipe