Package software.amazon.awscdk.services.medialive.alpha

@Stability(Experimental) package software.amazon.awscdk.services.medialive.alpha

AWS::MediaLive Construct Library

---

cdk-constructs: Experimental

The APIs of higher level constructs in this module are experimental and under active development. They are subject to non-backward compatible changes or removal in any future version. These are not subject to the Semantic Versioning model and breaking changes will be announced in the release notes. This means that while you may use them, you may need to update your source code when upgrading to a newer version of this package.

AWS Elemental MediaLive

AWS Elemental MediaLive is a real-time video service that lets you create live outputs for broadcast and streaming delivery.

This package contains constructs for working with AWS Elemental MediaLive, including Inputs, Input Security Groups, Channels, and MediaLive Anywhere resources (Networks, Clusters, Channel Placement Groups, SDI Sources).

For further information on AWS Elemental MediaLive, see the documentation. See supported codecs per output group.

The following example creates an SRT caller input, encodes it to H.264 + AAC, and outputs HLS segments to an S3 bucket: 

 Stack stack;
 IBucket bucket;
 
 
 Input input = Input.Builder.create(stack, "SrtInput")
         .inputName("my-srt-input")
         .input(InputConfiguration.srtCaller(List.of(SrtCallerSourceProps.builder()
                 .srtListenerAddress("203.0.113.10")
                 .srtListenerPort(5000)
                 .build())))
         .build();
 
 EncodeConfiguration video = EncodeConfiguration.video(VideoEncodeProps.builder()
         .name("video_720p")
         .codec(VideoCodecSettings.h264(H264SettingsProps.builder()
                 .rateControl(H264RateControl.cbr(CbrRateControlProps.builder().bitrate(Bitrate.mbps(3)).build()))
                 .framerate(Framerate.FPS_30)
                 .build()))
         .width(1280)
         .height(720)
         .build());
 
 EncodeConfiguration audio = EncodeConfiguration.audio(AudioEncodeProps.builder()
         .name("audio_aac")
         .codec(AudioCodecSettings.aac(AacSettingsProps.builder().bitrate(Bitrate.kbps(192)).build()))
         .build());
 
 Channel.Builder.create(stack, "Channel")
         .inputs(List.of(InputAttachment.builder().input(input).build()))
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video, audio)).outputName("hls_out").build()))
                 .build())))
         .build();

Input

An input represents the upstream source that feeds a MediaLive channel. Use InputConfiguration factory methods to create different input types.

SRT Caller

MediaLive connects to a remote SRT listener: 

 Stack stack;
 
 Input.Builder.create(stack, "SrtInput")
         .inputName("srt-caller")
         .input(InputConfiguration.srtCaller(List.of(SrtCallerSourceProps.builder()
                 .srtListenerAddress("203.0.113.10")
                 .srtListenerPort(5000)
                 .build())))
         .build();

SRT Listener

MediaLive listens for an incoming SRT connection. SRT listener inputs require an input security group. To receive encrypted content, supply a decryption block referencing a Secrets Manager secret that holds the passphrase — the secret is passed by reference, so MediaLive resolves the ARN at synth time: 

 Stack stack;
 ISecret passphrase;
 
 
 InputSecurityGroup sg = InputSecurityGroup.Builder.create(stack, "SrtSg")
         .allowlistRules(List.of("203.0.113.0/24"))
         .build();
 
 Input.Builder.create(stack, "SrtListenerInput")
         .inputName("srt-listener")
         .input(InputConfiguration.srtListener(SrtListenerInputProps.builder()
                 .inputSecurityGroups(List.of(sg))
                 .minimumLatency(Duration.millis(500))
                 .streamId("my-stream-id")
                 .decryption(SrtDecryptionProps.builder()
                         .algorithm(SrtDecryptionAlgorithm.AES256)
                         .passphraseSecret(passphrase)
                         .build())
                 .build()))
         .build();

AWS Elemental MediaConnect Router

Creates a MediaConnect Router Input with automatic encryption: 

 Stack stack;
 
 Input.Builder.create(stack, "RouterInput")
         .inputName("mc-router")
         .input(InputConfiguration.mediaConnectRouter())
         .build();

An input created this way is the only kind @aws-cdk/aws-mediaconnect-alpha's RouterOutputConfiguration.mediaLiveInput() can deliver to — pointing it at any other input type synths but fails at deploy.

MP4 File from S3

Use InputSource.fromBucket() to reference an S3 object: 

 Stack stack;
 IBucket bucket;
 
 
 Input.Builder.create(stack, "FileInput")
         .inputName("mp4-file")
         .input(InputConfiguration.mp4File(List.of(InputSource.fromBucket(bucket, "media/input.mp4"))))
         .build();

Importing an Existing Input

 Stack stack;
 
 IInput input = Input.fromInputArn(stack, "Imported", "arn:aws:medialive:us-east-1:123456789012:input:1234567");

Input Security Group

An input security group controls which IPv4 CIDR blocks can push content to a push-type input. 

 Stack stack;
 
 InputSecurityGroup sg = InputSecurityGroup.Builder.create(stack, "SG")
         .allowlistRules(List.of("203.0.113.0/24"))
         .build();

Importing an Existing Input Security Group

 Stack stack;
 
 IInputSecurityGroup sg = InputSecurityGroup.fromInputSecurityGroupArn(stack, "Imported", "arn:aws:medialive:us-east-1:123456789012:inputSecurityGroup:1234567");

Channel

A channel takes one or more inputs, encodes them, and produces output groups. If no role is provided, the channel auto-creates an IAM role with the medialive.amazonaws.com service principal.

Minimal example — single input, single HLS output: 

 Stack stack;
 IInput input;
 IBucket bucket;
 
 
 EncodeConfiguration video = EncodeConfiguration.video(VideoEncodeProps.builder()
         .name("video_720p")
         .codec(VideoCodecSettings.h264(H264SettingsProps.builder()
                 .rateControl(H264RateControl.cbr(CbrRateControlProps.builder().bitrate(Bitrate.mbps(3)).build()))
                 .framerate(Framerate.FPS_30)
                 .build()))
         .width(1280)
         .height(720)
         .build());
 
 EncodeConfiguration audio = EncodeConfiguration.audio(AudioEncodeProps.builder()
         .name("audio_aac")
         .codec(AudioCodecSettings.aac(AacSettingsProps.builder().bitrate(Bitrate.kbps(192)).build()))
         .build());
 
 Channel.Builder.create(stack, "Channel")
         .inputs(List.of(InputAttachment.builder().input(input).build()))
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video, audio)).outputName("hls_out").build()))
                 .build())))
         .build();

STANDARD Channel with MediaPackage V2

A STANDARD channel runs two pipelines for redundancy. Each output group needs two destinations — one per pipeline. 

 Stack stack;
 IInput input;
 IChannel mpChannel;
 
 
 EncodeConfiguration hdVideo = EncodeConfiguration.video(VideoEncodeProps.builder()
         .name("video_1080p")
         .codec(VideoCodecSettings.h265(H265SettingsProps.builder()
                 .rateControl(H265RateControl.qvbr(QvbrRateControlProps.builder()
                         .maxBitrate(Bitrate.mbps(8))
                         .qvbrQualityLevel(7)
                         .build()))
                 .framerate(Framerate.FPS_30)
                 .build()))
         .width(1920)
         .height(1080)
         .build());
 
 EncodeConfiguration sdVideo = EncodeConfiguration.video(VideoEncodeProps.builder()
         .name("video_480p")
         .codec(VideoCodecSettings.h265(H265SettingsProps.builder()
                 .rateControl(H265RateControl.qvbr(QvbrRateControlProps.builder()
                         .maxBitrate(Bitrate.mbps(2))
                         .qvbrQualityLevel(7)
                         .build()))
                 .framerate(Framerate.FPS_30)
                 .build()))
         .width(854)
         .height(480)
         .build());
 
 EncodeConfiguration audio = EncodeConfiguration.audio(AudioEncodeProps.builder()
         .name("audio_aac")
         .codec(AudioCodecSettings.aac(AacSettingsProps.builder().bitrate(Bitrate.kbps(192)).build()))
         .build());
 
 Channel.Builder.create(stack, "Channel")
         .channelClass(ChannelClass.STANDARD)
         .inputs(List.of(InputAttachment.builder().input(input).build()))
         .outputGroups(List.of(OutputGroupConfiguration.mediaPackageV2(MediaPackageV2OutputGroupProps.builder()
                 .name("emp")
                 .channel(mpChannel)
                 .outputs(List.of(MediaPackageV2OutputDefinition.builder().encode(hdVideo).outputName("hd").build(), MediaPackageV2OutputDefinition.builder().encode(sdVideo).outputName("sd").build(), MediaPackageV2OutputDefinition.builder().encode(audio).outputName("audio").build()))
                 .build())))
         .build();

Global Configuration

globalConfiguration sets channel-wide behaviour: how the pipelines are locked together and the output timing source. All fields are optional and fall back to MediaLive defaults. 

 Stack stack;
 IInput input;
 IBucket bucket;
 EncodeConfiguration video;
 EncodeConfiguration audio;
 
 
 Channel.Builder.create(stack, "Channel")
         .inputs(List.of(InputAttachment.builder().input(input).build()))
         .timecodeConfig(TimecodeConfig.builder()
                 .source(TimecodeSource.EMBEDDED)
                 .build())
         .globalConfiguration(GlobalConfiguration.builder()
                 .outputLocking(OutputLocking.epoch())
                 .outputTimingSource(OutputTimingSource.INPUT_CLOCK)
                 .build())
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video, audio)).outputName("hls_out").build()))
                 .build())))
         .build();

Output locking

outputLocking synchronises the frames emitted by a channel's two pipelines. Pick a strategy with the OutputLocking factory:

  • OutputLocking.pipeline() — synchronise each pipeline's output to the other. Choose how with method: PipelineLockingMethod.SOURCE_TIMECODE (default, needs reliable embedded timecodes) or PipelineLockingMethod.VIDEO_ALIGNMENT (visual content matching, no timecodes required).
  • OutputLocking.epoch() — synchronise to the Unix epoch (optionally a customEpoch/jamSyncTime). Requires outputTimingSource: OutputTimingSource.INPUT_CLOCK (enforced at synth).
  • OutputLocking.disabled() — no synchronisation.

 // Video-aligned pipeline locking — useful when sources lack reliable timecodes
 OutputLocking locking = OutputLocking.pipeline(PipelineOutputLockingProps.builder()
         .method(PipelineLockingMethod.VIDEO_ALIGNMENT)
         .build());

Input-loss behavior

inputLossBehavior controls what MediaLive emits when the input is lost: a black period, then a repeated frame, then either a solid colour or a slate image. Provide the slate as a FileLocation. 

 IBucket slateBucket;
 
 
 InputLossBehavior inputLoss = InputLossBehavior.builder()
         .blackFrame(Duration.seconds(1))
         .repeatFrame(Duration.seconds(5))
         .imageType(InputLossImageType.SLATE)
         .imageSlate(FileLocation.fromBucket(slateBucket, "slates/offline.png"))
         .build();

File locations

Several channel features reference a file MediaLive reads at runtime — an input-loss slate, an avail-blanking image, a blackout-slate image, or a burn-in caption font. These all take a FileLocation, created from an S3 bucket (which auto-grants the channel role read access) or a URL (with optional SSM-backed credentials): 

 import software.amazon.awscdk.services.ssm.StringParameter;
 
 IBucket bucket;
 StringParameter passwordParam;
 
 
 // From an S3 bucket — the channel role is granted read access automatically
 FileLocation fromS3 = FileLocation.fromBucket(bucket, "assets/slate.png");
 
 // From a URL with optional credentials (SSM parameter read access auto-granted)
 FileLocation fromUrl = FileLocation.url("https://origin.example.com/font.ttf", FileLocationOptions.builder()
         .username("ingest-user")
         .password(passwordParam)
         .build());

Color correction

A channel can apply one or more color-space conversions to its video, optionally using a 3D LUT to remap colors. Each ColorCorrection declares the inputColorSpace to match and the outputColorSpace to convert to. MediaLive reads the LUT from S3 at runtime, so it must be an S3 location — provide it via Lut.fromBucket() (which uses the secure s3ssl:// form and auto-grants the channel role read access) or Lut.url() with an s3:///s3ssl:// URL: 

 Stack stack;
 IBucket bucket;
 IInput input;
 EncodeConfiguration video;
 OutputDestination destination;
 
 
 Channel.Builder.create(stack, "Channel")
         .inputs(List.of(InputAttachment.builder().input(input).build()))
         .colorCorrections(List.of(ColorCorrection.builder()
                 .inputColorSpace(ColorSpace.REC_601)
                 .outputColorSpace(ColorSpace.REC_709)
                 .lut(Lut.fromBucket(bucket, "luts/rec601-to-rec709.cube"))
                 .build()))
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(destination))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video)).outputName("video").build()))
                 .build())))
         .build();

Encode Configuration

Use EncodeConfiguration.video(), EncodeConfiguration.audio(), and EncodeConfiguration.caption() to define encodes.

Video

 // H.264
 EncodeConfiguration h264 = EncodeConfiguration.video(VideoEncodeProps.builder()
         .name("h264_720p")
         .codec(VideoCodecSettings.h264(H264SettingsProps.builder()
                 .rateControl(H264RateControl.cbr(CbrRateControlProps.builder().bitrate(Bitrate.mbps(3)).build()))
                 .framerate(Framerate.FPS_30)
                 .profile(H264Profile.HIGH)
                 .build()))
         .width(1280)
         .height(720)
         .build());
 
 // H.265
 EncodeConfiguration h265 = EncodeConfiguration.video(VideoEncodeProps.builder()
         .name("h265_1080p")
         .codec(VideoCodecSettings.h265(H265SettingsProps.builder()
                 .rateControl(H265RateControl.qvbr(QvbrRateControlProps.builder()
                         .maxBitrate(Bitrate.mbps(5))
                         .qvbrQualityLevel(7)
                         .build()))
                 .framerate(Framerate.FPS_30)
                 .profile(H265Profile.MAIN)
                 .tier(H265Tier.HIGH)
                 .build()))
         .width(1920)
         .height(1080)
         .build());

Video codecs accept optional overrides for adaptive quantization, scene-change detection, color space, and more. See the props interfaces for the full list: 

 EncodeConfiguration hdr = EncodeConfiguration.video(VideoEncodeProps.builder()
         .name("h265_hdr")
         .codec(VideoCodecSettings.h265(H265SettingsProps.builder()
                 .rateControl(H265RateControl.qvbr(QvbrRateControlProps.builder().maxBitrate(Bitrate.mbps(8)).qvbrQualityLevel(8).build()))
                 .framerate(Framerate.FPS_30)
                 .sceneChangeDetect(H265SceneChangeDetect.ENABLED)
                 .colorSpaceSettings(H265ColorSpaceSettings.hlg2020())
                 .build()))
         .width(1920)
         .height(1080)
         .build());

Audio

 // AAC stereo
 EncodeConfiguration aac = EncodeConfiguration.audio(AudioEncodeProps.builder()
         .name("aac_stereo")
         .codec(AudioCodecSettings.aac(AacSettingsProps.builder()
                 .bitrate(Bitrate.kbps(192))
                 .codingMode(AacCodingMode.CODING_MODE_2_0)
                 .build()))
         .build());
 
 // AC3 5.1
 EncodeConfiguration ac3 = EncodeConfiguration.audio(AudioEncodeProps.builder()
         .name("ac3_surround")
         .codec(AudioCodecSettings.ac3(Ac3SettingsProps.builder()
                 .bitrate(Bitrate.kbps(384))
                 .codingMode(Ac3CodingMode.CODING_MODE_3_2_LFE)
                 .build()))
         .build());

Caption

A caption encode converts a source caption track (referenced by captionSelectorName) to an output format via the CaptionDestination factory. One selector can feed multiple encodes: 

 // Define a caption selector on the input attachment (see Input Attachment Settings below)
 CaptionSelector captionSelector = CaptionSelector.embedded("captions");
 
 // WebVTT captions — packaged alongside the video encode in the same output
 EncodeConfiguration webvtt = EncodeConfiguration.caption(CaptionEncodeProps.builder()
         .name("eng_webvtt")
         .captionSelectorName(captionSelector.getName())
         .languageCode("eng")
         .languageDescription("English")
         .destination(CaptionDestination.webvtt())
         .build());
 
 // Burned-in captions — rendered into the video, styled via the burn-in options
 EncodeConfiguration burnIn = EncodeConfiguration.caption(CaptionEncodeProps.builder()
         .name("eng_burnin")
         .captionSelectorName(captionSelector.getName())
         .destination(CaptionDestination.burnIn(BurnInDestinationProps.builder()
                 .alignment(CaptionAlignment.CENTERED)
                 .fontColor(CaptionFontColor.WHITE)
                 .outlineColor(CaptionOutlineColor.BLACK)
                 .fontSize(CaptionFontSize.AUTO)
                 .build()))
         .build());

Cross-service integrations

| Destination | MediaLive side | Other side | Package | |---|---|---|---| | MediaPackage V2 | medialive.OutputGroupConfiguration.mediaPackageV2() | mediapackagev2.Channel | @aws-cdk/aws-mediapackagev2-alpha | | MediaConnect Router (output) | medialive.OutputGroupConfiguration.mediaConnectRouter() | mediaconnect.RouterInputConfiguration.mediaLiveChannel() | @aws-cdk/aws-mediaconnect-alpha | | MediaConnect Router (input) | medialive.InputConfiguration.mediaConnectRouter() | mediaconnect.RouterOutputConfiguration.mediaLiveInput() | @aws-cdk/aws-mediaconnect-alpha |

AWS Elemental MediaPackage V2

Use mediaPackageV2() and pass a single channel — MediaLive maps each pipeline to a MediaPackage ingest endpoint automatically (one for SINGLE_PIPELINE, both for STANDARD). Each output contains a single encode (one track per output).

In-band captions (burn-in, embedded) ride alongside a video encode via the captions prop: 

 IChannel mpChannel;
 EncodeConfiguration hdVideo;
 EncodeConfiguration sdVideo;
 EncodeConfiguration audio;
 EncodeConfiguration burnIn;
 
 
 OutputGroupConfiguration.mediaPackageV2(MediaPackageV2OutputGroupProps.builder()
         .name("emp")
         .channel(mpChannel)
         .outputs(List.of(MediaPackageV2OutputDefinition.builder().encode(hdVideo).captions(List.of(burnIn)).outputName("hd").build(), MediaPackageV2OutputDefinition.builder().encode(sdVideo).outputName("sd").build(), MediaPackageV2OutputDefinition.builder().encode(audio).outputName("audio").build()))
         .build());

For per-pipeline control — for example pinning pipeline 0 to a specific endpoint, or delivering each pipeline to a different (cross-region) channel — use mediaPackageV2PerPipeline() with explicit destinations: 

 IChannel primary;
 EncodeConfiguration hdVideo;
 
 
 OutputGroupConfiguration.mediaPackageV2PerPipeline(MediaPackageV2PerPipelineOutputGroupProps.builder()
         .name("emp")
         .destinations(List.of(MediaPackageV2Destination.channel(primary, MediaPackageV2EndpointId.ENDPOINT_2), MediaPackageV2Destination.channel(primary, MediaPackageV2EndpointId.ENDPOINT_1)))
         .outputs(List.of(MediaPackageV2OutputDefinition.builder().encode(hdVideo).outputName("hd").build()))
         .build());

HLS

Use OutputDestination.url() for HTTP origins or OutputDestination.toBucket() for S3: 

 IBucket bucket;
 EncodeConfiguration video;
 EncodeConfiguration audio;
 
 
 // HLS to S3
 OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
         .name("hls_s3")
         .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
         .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video, audio)).outputName("hls_out").build()))
         .build());
 
 // HLS to an HTTPS CDN origin.
 OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
         .name("hls-http")
         .destinations(List.of(OutputDestination.url("https://203.0.113.10/ingest/stream")))
         .hlsCdnSettings(HlsCdnSettings.basicPut())
         .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video, audio)).outputName("hls_out").build()))
         .build());

Archive

Archive outputs write long-form recordings to S3: 

 IBucket bucket;
 EncodeConfiguration video;
 EncodeConfiguration audio;
 
 
 OutputGroupConfiguration.archive(ArchiveOutputGroupProps.builder()
         .name("archive")
         .destinations(List.of(S3OutputDestination.toBucket(bucket, "archive/recording")))
         .rolloverInterval(Duration.seconds(600))
         .outputs(List.of(ArchiveOutputDefinition.builder().encodes(List.of(video, audio)).outputName("archive_out").build()))
         .build());

RTMP

RTMP outputs support H.264 + AAC only. Each output takes one destination per channel pipeline (the console's "Destination A" / "Destination B") via RtmpDestination.url() — one for SINGLE_PIPELINE, two for STANDARD: 

 EncodeConfiguration video;
 EncodeConfiguration audio;
 
 
 OutputGroupConfiguration.rtmp(RtmpOutputGroupProps.builder()
         .name("social")
         .outputs(List.of(RtmpOutputDefinition.builder()
                 .encodes(List.of(video, audio))
                 .outputName("live")
                 .destinations(List.of(RtmpDestination.url("rtmp://rtmp.example.com/live", "your-stream-key")))
                 .build()))
         .build());

SRT

SRT outputs use SrtDestination.caller() for caller mode or SrtDestination.listener() for listener mode. When you already have a full SRT URL rather than a separate host and port, use SrtDestination.callerUrl(). SRT output is always encrypted, so every destination takes an encryptionPassphraseSecret (a Secrets Manager secret). Each output takes one destination per channel pipeline ("Destination A"/"Destination B") — one for SINGLE_PIPELINE, two for STANDARD: 

 EncodeConfiguration video;
 EncodeConfiguration audio;
 ISecret passphrase;
 
 
 // SRT caller to a remote listener
 OutputGroupConfiguration.srt(SrtOutputGroupProps.builder()
         .name("srt_out")
         .outputs(List.of(SrtOutputDefinition.builder()
                 .encodes(List.of(video, audio))
                 .outputName("srt_caller")
                 .destinations(List.of(SrtDestination.caller(SrtCallerDestinationProps.builder()
                         .address("203.0.113.20")
                         .port(5000)
                         .encryptionPassphraseSecret(passphrase)
                         .build())))
                 .build()))
         .build());
 
 // SRT listener — MediaLive waits for the downstream system to connect
 OutputGroupConfiguration.srt(SrtOutputGroupProps.builder()
         .name("srt_listen")
         .outputs(List.of(SrtOutputDefinition.builder()
                 .encodes(List.of(video, audio))
                 .outputName("srt_listener")
                 .destinations(List.of(SrtDestination.listener(SrtListenerDestinationProps.builder()
                         .listenerPort(5000)
                         .encryptionPassphraseSecret(passphrase)
                         .build())))
                 .build()))
         .build());

AWS Elemental MediaConnect Router

mediaConnectRouter() delivers each channel pipeline to an AWS Elemental MediaConnect Router. Transit encryption defaults to AUTOMATIC; CDK derives one destination per pipeline from the channel class, so the common case needs no per-pipeline configuration. You must specify availabilityZones — exactly one for a SINGLE_PIPELINE channel, or two (one per pipeline) for STANDARD. The downstream wiring — which router input each pipeline feeds — is configured on the MediaConnect side, referencing this group's output by name and pipeline id. 

 EncodeConfiguration video;
 EncodeConfiguration audio;
 ISecret passphrase;
 ISecret passphrase1;
 
 
 // AUTOMATIC encryption on every pipeline (MPEG-TS container, like UDP)
 OutputGroupConfiguration.mediaConnectRouter(MediaConnectRouterOutputGroupProps.builder()
         .name("router_out")
         .availabilityZones(List.of("us-east-1a"))
         .outputs(List.of(MediaConnectRouterOutputDefinition.builder().encodes(List.of(video, audio)).outputName("router_ts").build()))
         .build());
 
 // One shared Secrets Manager passphrase across all pipelines (SECRETS_MANAGER encryption)
 OutputGroupConfiguration.mediaConnectRouter(MediaConnectRouterOutputGroupProps.builder()
         .name("router_out")
         .availabilityZones(List.of("us-east-1a"))
         .routerSettings(MediaConnectRouterSettings.shared(MediaConnectRouterPipelineConfig.builder().encryptionSecret(passphrase).build()))
         .outputs(List.of(MediaConnectRouterOutputDefinition.builder().encodes(List.of(video, audio)).outputName("router_ts").build()))
         .build());
 
 // Distinct encryption per pipeline — an omitted pipeline stays AUTOMATIC (STANDARD channels)
 OutputGroupConfiguration.mediaConnectRouter(MediaConnectRouterOutputGroupProps.builder()
         .name("router_out")
         .availabilityZones(List.of("us-east-1a", "us-east-1b"))
         .routerSettings(MediaConnectRouterSettings.perPipeline(MediaConnectRouterPerPipelineSettings.builder()
                 .pipeline1(MediaConnectRouterPipelineConfig.builder().encryptionSecret(passphrase1).build())
                 .build()))
         .outputs(List.of(MediaConnectRouterOutputDefinition.builder().encodes(List.of(video, audio)).outputName("router_ts").build()))
         .build());

When a passphrase secret is supplied, the channel's IAM role is automatically granted read access to it.

UDP

UDP outputs deliver MPEG-TS over UDP or RTP. Use UdpOutputDestination.udp() for plain UDP or .rtp() for RTP (required if using FEC): 

 EncodeConfiguration video;
 EncodeConfiguration audio;
 
 
 OutputGroupConfiguration.udp(UdpOutputGroupProps.builder()
         .name("udp_out")
         .destinations(List.of(UdpOutputDestination.udp(TransportOutputDestinationProps.builder().address("203.0.113.5").port(5000).build())))
         .outputs(List.of(UdpOutputDefinition.builder().encodes(List.of(video, audio)).outputName("ts_out").build()))
         .build());

Frame Capture

Frame capture outputs write periodic JPEG snapshots to S3: 

 IBucket bucket;
 EncodeConfiguration video;
 
 
 OutputGroupConfiguration.frameCapture(FrameCaptureOutputGroupProps.builder()
         .name("thumbnails")
         .destinations(List.of(S3OutputDestination.toBucket(bucket, "thumbnails/live")))
         .outputs(List.of(FrameCaptureOutputDefinition.builder().encodes(List.of(video)).outputName("thumb").build()))
         .build());

Microsoft Smooth Streaming

MS Smooth outputs push fragmented MP4 to an IIS Smooth Streaming endpoint: 

 EncodeConfiguration video;
 EncodeConfiguration audio;
 
 
 OutputGroupConfiguration.msSmooth(MsSmoothOutputGroupProps.builder()
         .name("smooth")
         .destinations(List.of(OutputDestination.url("https://smooth.example.com/live")))
         .outputs(List.of(MsSmoothOutputDefinition.builder().encodes(List.of(video, audio)).outputName("smooth_out").build()))
         .build());

Per-output HLS settings

HLS outputs accept per-output hlsSettings via the HlsSettings factory — standard() for a video rendition (with optional M3u8Settings for the transport stream), audioOnly() for an audio rendition (with optional cover art as a FileLocation), fmp4(), or frameCapture(). 

 IBucket bucket;
 EncodeConfiguration video;
 EncodeConfiguration audio;
 
 
 OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
         .name("hls")
         .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
         .outputs(List.of(HlsOutputDefinition.builder()
                 .encodes(List.of(video))
                 .outputName("video")
                 .hlsSettings(HlsSettings.standard(StandardHlsSettingsProps.builder()
                         .m3u8Settings(M3u8Settings.of(M3u8SettingsProps.builder()
                                 .scte35Behavior(M3u8Scte35Behavior.PASSTHROUGH)
                                 .programNum(1)
                                 .build()))
                         .build()))
                 .build(), HlsOutputDefinition.builder()
                 .encodes(List.of(audio))
                 .outputName("audio")
                 .hlsSettings(HlsSettings.audioOnly(AudioOnlyHlsSettingsProps.builder()
                         .audioGroupId("program")
                         .audioOnlyImage(FileLocation.fromBucket(bucket, "art/cover.png"))
                         .build()))
                 .build()))
         .build());

Forward Error Correction (UDP)

UDP outputs accept optional fec settings (SMPTE 2022-1) — column-only or column-and-row FEC. FEC requires an rtp:// destination: 

 EncodeConfiguration video;
 
 
 OutputGroupConfiguration.udp(UdpOutputGroupProps.builder()
         .name("udp")
         .destinations(List.of(UdpOutputDestination.rtp(TransportOutputDestinationProps.builder().address("203.0.113.5").port(5000).build())))
         .outputs(List.of(UdpOutputDefinition.builder()
                 .encodes(List.of(video))
                 .outputName("ts")
                 .fec(FecOutputSettings.builder().mode(FecMode.COLUMN_AND_ROW).columnDepth(10).rowLength(10).build())
                 .build()))
         .build());

MPEG-TS Container Settings

The MPEG-TS output groups — udp(), archive(), srt(), and mediaConnectRouter() — accept optional per-output m2tsSettings via M2tsSettings.of(). Omit it to use MediaLive's service defaults. Bitrates use Bitrate, intervals use Duration, and closed-value fields use enums (e.g. M2tsRateMode, M2tsScte35Control); PID fields are strings that accept decimal, hexadecimal, ranges, or comma-separated lists. 

 EncodeConfiguration video;
 EncodeConfiguration audio;
 
 
 OutputGroupConfiguration.udp(UdpOutputGroupProps.builder()
         .name("udp_out")
         .destinations(List.of(UdpOutputDestination.udp(TransportOutputDestinationProps.builder().address("203.0.113.5").port(5000).build())))
         .outputs(List.of(UdpOutputDefinition.builder()
                 .encodes(List.of(video, audio))
                 .outputName("ts")
                 .m2tsSettings(M2tsSettings.of(M2tsSettingsProps.builder()
                         .bitrate(Bitrate.mbps(8))
                         .rateMode(M2tsRateMode.VBR)
                         .programNum(1)
                         .patInterval(Duration.millis(100))
                         .pmtInterval(Duration.millis(100))
                         .scte35Control(M2tsScte35Control.PASSTHROUGH)
                         .dvbSdtSettings(DvbSdtSettings.builder()
                                 .outputSdt(DvbSdtOutputMode.SDT_MANUAL)
                                 .serviceName("My Service")
                                 .repInterval(Duration.millis(2000))
                                 .build())
                         .build()))
                 .build()))
         .build());

Destinations

Each output group type uses a specific destination class. Destinations are created via static factory methods:

| Destination class | Factory methods | Used by | |---|---|---| | OutputDestination | url(), toBucket() | HLS, MS Smooth, CMAF Ingest | | S3OutputDestination | url(), toBucket() | Archive, Frame Capture | | UdpOutputDestination | udp(), rtp(), url() | UDP | | MediaPackageV2Destination | channel() | MediaPackage V2 | | RtmpDestination | url() | RTMP | | SrtDestination | caller(), callerUrl(), listener() | SRT |

OutputDestination.toBucket() (and S3OutputDestination.toBucket()) build canonical s3ssl:// URLs and automatically grant the channel's IAM role the required S3 permissions; InputSource.fromBucket() does the same for input reads. MediaPackageV2Destination.channel() automatically grants ingest permissions on the MediaPackage V2 channel.

The MediaConnect Router output group has no destination class — its delivery is configured on the MediaConnect side. Per-pipeline transit encryption is set via the group's routerSettings prop using MediaConnectRouterSettings.shared() / .perPipeline() (see MediaConnect Router above).

Additional Destinations

MediaPackage V2 and CMAF Ingest output groups support additionalDestinations for cross-region delivery or backup packaging. These are separate from pipeline redundancy — they fan out the same content to extra endpoints.

The region for each destination is resolved automatically from the channel's stack. For cross-region imports, pass the region explicitly: 

 IChannel primaryChannel;
 EncodeConfiguration video;
 EncodeConfiguration audio;
 
 
 // Import a channel from another region — the region travels with the channel
 IChannel backupChannel = Channel.fromChannelAttributes(this, "BackupChannel", ChannelAttributes.builder()
         .channelName("backup-channel")
         .channelGroupName("backup-group")
         .region("us-west-2")
         .build());
 
 OutputGroupConfiguration.mediaPackageV2(MediaPackageV2OutputGroupProps.builder()
         .name("emp")
         .channel(primaryChannel)
         .additionalDestinations(List.of(MediaPackageV2Destination.channel(backupChannel, MediaPackageV2EndpointId.ENDPOINT_1)))
         .outputs(List.of(MediaPackageV2OutputDefinition.builder().encode(video).outputName("video").build(), MediaPackageV2OutputDefinition.builder().encode(audio).outputName("audio").build()))
         .build());

Pipeline Redundancy

Channels default to SINGLE_PIPELINE. Set channelClass: ChannelClass.STANDARD for two-pipeline redundancy.

When using STANDARD:

  • Each output group's destinations array must have two entries — destinations[0] maps to Pipeline 0, destinations[1] maps to Pipeline 1.
  • For MediaPackage V2, use ENDPOINT_1 for Pipeline 0 and ENDPOINT_2 for Pipeline 1.
  • additionalDestinations are separate from pipeline redundancy — they fan out to extra endpoints.

 Stack stack;
 IInput input;
 IBucket bucket;
 EncodeConfiguration video;
 EncodeConfiguration audio;
 
 
 Channel.Builder.create(stack, "StandardChannel")
         .channelClass(ChannelClass.STANDARD)
         .inputs(List.of(InputAttachment.builder().input(input).build()))
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(OutputDestination.toBucket(bucket, "live/pipeline0"), OutputDestination.toBucket(bucket, "live/pipeline1")))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video, audio)).outputName("hls_out").build()))
                 .build())))
         .build();

Input Attachment Settings

Each entry in inputs is an input attachment, which can carry per-input extraction and connection settings beyond the input itself.

Selectors pick specific tracks out of the input. Use AudioSelector (byLanguage(), byPid(), byTrack(), hlsRendition(), default()), CaptionSelector (byLanguage(), embedded(), ancillary(), dvbSub(), scte27(), teletext(), arib()), and videoSelector (color space, HDR10 metadata, and program/PID selection via VideoSelection). A caption encode then references a caption selector by name. 

 Stack stack;
 IInput input;
 IBucket bucket;
 EncodeConfiguration video;
 
 
 Channel.Builder.create(stack, "Channel")
         .inputs(List.of(InputAttachment.builder()
                 .input(input)
                 .audioSelectors(List.of(AudioSelector.byLanguage("eng", "eng", AudioLanguageSelectionPolicy.STRICT)))
                 .captionSelectors(List.of(CaptionSelector.embedded("embedded")))
                 .videoSelector(VideoSelectorSettings.builder()
                         .colorSpace(VideoColorSpace.HDR10)
                         .colorSpaceUsage(VideoColorSpaceUsage.FORCE)
                         .selectBy(VideoSelection.byProgramId(1))
                         .build())
                 .build()))
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video)).outputName("hls_out").build()))
                 .build())))
         .build();

Network input settings apply to URL-pull and multicast inputs — HLS bandwidth/buffer/retry behaviour, the SCTE-35 source (HlsScte35Source.SEGMENTS or MANIFEST), HTTPS server validation, and a multicast source IP for source-specific multicast. logicalInterfaceNames maps the input to network interfaces on MediaLive Anywhere nodes. 

 Stack stack;
 IInput input;
 IBucket bucket;
 EncodeConfiguration video;
 
 
 Channel.Builder.create(stack, "Channel")
         .inputs(List.of(InputAttachment.builder()
                 .input(input)
                 .networkInputSettings(NetworkInputSettings.builder()
                         .serverValidation(ServerValidation.CHECK_CRYPTOGRAPHY_AND_VALIDATE_NAME)
                         .hlsInputSettings(HlsInputSettings.builder()
                                 .bandwidth(Bitrate.mbps(5))
                                 .scte35Source(HlsScte35Source.MANIFEST)
                                 .build())
                         .build())
                 .logicalInterfaceNames(List.of("eth0", "eth1"))
                 .build()))
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video)).outputName("hls_out").build()))
                 .build())))
         .build();

Automatic Input Failover

Automatic input failover gives you input-source redundancy: attach a secondary input, and MediaLive switches to it without restarting the channel when the active input meets a failover condition. This is separate from the pipeline redundancy of ChannelClass.STANDARD (which duplicates a single source across two pipelines).

Provide automaticInputFailover on the input attachment. If you don't specify conditions, a single input-loss condition is used: 

 Stack stack;
 IInput primaryInput;
 IInput secondaryInput;
 AudioSelector audioSelector;
 EncodeConfiguration video;
 EncodeConfiguration audio;
 IBucket bucket;
 
 
 Channel.Builder.create(stack, "Channel")
         .inputs(List.of(InputAttachment.builder()
                 .input(primaryInput)
                 .automaticInputFailover(AutomaticInputFailover.builder()
                         .secondaryInput(secondaryInput)
                         .inputPreference(InputPreference.PRIMARY_INPUT_PREFERRED)
                         .errorClearTime(Duration.seconds(3))
                         .failoverConditions(List.of(FailoverCondition.inputLoss(InputLossFailoverProps.builder().threshold(Duration.millis(1500)).build()), FailoverCondition.audioSilence(AudioSilenceFailoverProps.builder().audioSelector(audioSelector).threshold(Duration.seconds(2)).build()), FailoverCondition.videoBlack(VideoBlackFailoverProps.builder().blackDetectThreshold(0.1).threshold(Duration.seconds(1)).build())))
                         .build())
                 .build(), InputAttachment.builder()
                 // The secondary input must also be attached to the channel as its own input.
                 .input(secondaryInput)
                 .build()))
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video, audio)).outputName("hls_out").build()))
                 .build())))
         .build();

The primary and secondary inputs must have the same input class. The channel's IAM role is granted read access to the secondary input's sources automatically, just like the primary.

Ad Avail Handling

MediaLive can blank content during ad avails, insert blackout slates, and signal SCTE-35 ad avails to downstream systems. These are all channel-level props.

availBlanking replaces video/audio/captions with black (or an image) during an ad avail, and blackoutSlate shows a slate when a SCTE-35 blackout is signalled. Both image fields take a FileLocation. 

 Stack stack;
 IInput input;
 IBucket bucket;
 EncodeConfiguration video;
 
 
 Channel.Builder.create(stack, "Channel")
         .inputs(List.of(InputAttachment.builder().input(input).build()))
         .availBlanking(AvailBlanking.builder()
                 .state(AvailBlankingState.ENABLED)
                 .image(FileLocation.fromBucket(bucket, "slates/avail.png"))
                 .build())
         .blackoutSlate(BlackoutSlate.builder()
                 .state(BlackoutSlateState.ENABLED)
                 .image(FileLocation.fromBucket(bucket, "slates/blackout.png"))
                 .build())
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video)).outputName("hls_out").build()))
                 .build())))
         .build();

availSettings selects how SCTE-35 ad avails are handled — AvailSettings.spliceInsert(), AvailSettings.timeSignalApos(), or AvailSettings.esam() for Event Signaling and Management against an external POIS endpoint. scte35SegmentationScope controls which output groups receive the segmentation cues. The ESAM POIS password is supplied as an SSM parameter, and the channel role is granted read access to it automatically. 

 import software.amazon.awscdk.services.ssm.StringParameter;
 
 Stack stack;
 IInput input;
 IBucket bucket;
 EncodeConfiguration video;
 StringParameter poisPassword;
 
 
 Channel.Builder.create(stack, "Channel")
         .inputs(List.of(InputAttachment.builder().input(input).build()))
         .availSettings(AvailSettings.esam(EsamSettings.builder()
                 .pois(PoisEndpoint.builder()
                         .url("https://pois.example.com/esam")
                         .username("pois-user")
                         .password(poisPassword)
                         .build())
                 .acquisitionPointId("acquisition-point-1")
                 .adAvailOffset(Duration.millis(200))
                 .build()))
         .scte35SegmentationScope(Scte35SegmentationScope.SCTE35_ENABLED_OUTPUT_GROUPS)
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video)).outputName("hls_out").build()))
                 .build())))
         .build();

Auto-Created Role and Grants

When no role is provided, the channel auto-creates an IAM role with the medialive.amazonaws.com service principal and grants it only the permissions your configuration actually needs. These automatic grants apply only to the channel-managed role; if you bring your own role, none are added.

Channel role grants — wired based on what you configure (channel-managed role only):

| Configuration | Grant | Scope | |---|---|---| | OutputDestination.toBucket() | S3 read/write | The destination bucket/prefix | | InputSource.fromBucket() | S3 read | The input source bucket/prefix | | MediaPackageV2Destination.channel() | mediapackagev2:PutObject | The MediaPackage V2 channel | | SrtDestination with an encryption secret | Secrets Manager read | The secret | | URL pull input with a password parameter | SSM parameter read | The parameter | | Thumbnails (on by default) | s3:PutObject | * — uploads to an AWS service-owned bucket | | Channel logging (logLevel set) | CloudWatch Logs write | The ElementalMediaLive log group in your account/region | | VPC output (vpc set) | EC2 ENI create/delete + describe | Scoped to your subnets/SGs; Describe* requires * |

Input role grants — separate from the channel role, used at input create/delete time. Like the channel role, these are added only when the input auto-creates its role; pass a role to mediaConnect() or cdi() and no grants are added:

| Input type | Grant | Scope | |---|---|---| | InputConfiguration.mediaConnect() | mediaconnect:ManagedDescribeFlow, ManagedAddOutput, ManagedRemoveOutput | * — service rejects flow-scoped grants | | InputConfiguration.cdi() | EC2 ENI create/delete + describe | Scoped to your subnets/SGs; Describe* requires * |

Both channel and input auto-created roles include confused-deputy prevention (aws:SourceAccount + aws:SourceArn conditions). For the full list of trusted-entity requirements, see the documentation.

The auto-created role is available on channel.role if you need to add further permissions.

Bringing your pre-defined role

When you pass a role, the channel makes no automatic grants — you will need to add the permissions that role needs. That covers both the principal policy and any referenced resource policies: S3 output destinations and input sources, Secrets Manager and SSM reads, MediaPackage V2 ingest, CloudWatch Logs, and VPC output ENI management. See the trusted-entity requirements, or pass the account's MediaLiveAccessRole — an IAM role that MediaLive can assume.

CloudWatch Metrics

Channels expose CloudWatch metric helpers in the AWS/MediaLive namespace, dimensioned by ChannelId and Pipeline. Use the named helpers below for the most common metrics, or metric(metricName, pipeline) to access any metric documented by the MediaLive metrics reference.

MediaLive publishes metrics per pipeline. Every helper takes a Pipeline argument so you make an explicit decision about which pipeline you're monitoring. STANDARD channels run two redundant pipelines (PIPELINE_0, PIPELINE_1) — alarm on both to cover the full channel. SINGLE_PIPELINE channels only publish on PIPELINE_0; passing PIPELINE_1 throws at synth time. 

 Channel channel;
 Stack stack;
 
 
 channel.metricDroppedFrames(Pipeline.PIPELINE_0).createAlarm(stack, "DroppedFrames", CreateAlarmOptions.builder()
         .threshold(1)
         .evaluationPeriods(2)
         .build());
 
 channel.metricSvqTime(Pipeline.PIPELINE_0).createAlarm(stack, "SvqTime", CreateAlarmOptions.builder()
         .threshold(0)
         .evaluationPeriods(1)
         .build());
 
 // Custom metric by name with sum statistic
 channel.metric("Output4xxErrors", Pipeline.PIPELINE_0, MetricOptions.builder().statistic("sum").build());

For STANDARD channels, alarm on both pipelines: 

 Channel standardChannel;
 Stack stack;
 
 
 standardChannel.metricDroppedFrames(Pipeline.PIPELINE_0).createAlarm(stack, "Drops0", CreateAlarmOptions.builder()
         .threshold(1)
         .evaluationPeriods(2)
         .build());
 standardChannel.metricDroppedFrames(Pipeline.PIPELINE_1).createAlarm(stack, "Drops1", CreateAlarmOptions.builder()
         .threshold(1)
         .evaluationPeriods(2)
         .build());

Channel metrics

| Helper | Metric name | Default statistic | Notes | |---|---|---|---| | metricActiveAlerts(pipeline) | ActiveAlerts | Max | Total active alerts on the channel | | metricNetworkIn(pipeline) | NetworkIn | Avg | Inbound traffic in Mbps | | metricNetworkOut(pipeline) | NetworkOut | Avg | Outbound traffic in Mbps | | metricInputVideoFrameRate(pipeline) | InputVideoFrameRate | Max | Source video frame rate | | metricFillMsec(pipeline) | FillMsec | Max | Time filled with fill frames — non-zero indicates input loss | | metricInputLossSeconds(pipeline) | InputLossSeconds | Sum | Seconds without packets (RTP / MediaConnect inputs) | | metricDroppedFrames(pipeline) | DroppedFrames | Sum | Frames dropped because the encoder fell behind | | metricSvqTime(pipeline) | SvqTime | Max | Percent of time MediaLive reduced quality to keep up | | metric(name, pipeline, props?) | (custom) | (caller-provided) | Build any metric in AWS/MediaLive |

The defaults match the AWS-recommended statistic for each metric. Pass props to override statistic, period, dimensions, or any other MetricOptions field.

MediaLive Anywhere

MediaLive Anywhere lets you run MediaLive channels on your own on-premises hardware.

Certain input types are only available with Anywhere channels (channels configured with anywhereSettings): SDI, SMPTE 2110 Receiver Group, and Multicast. Attempting to use these input types on a cloud channel will throw a validation error at synth time.

Network

A network defines IP address pools and routes for Anywhere resources: 

 Stack stack;
 
 Network network = Network.Builder.create(stack, "Network")
         .networkName("on-prem-network")
         .ipPools(List.of("10.0.0.0/24"))
         .routes(List.of(NetworkRoute.builder().cidr("0.0.0.0/0").gateway("10.0.0.1").build()))
         .build();

Cluster

A cluster represents a group of on-premises hardware nodes: 

 Stack stack;
 IRole instanceRole;
 
 
 Cluster cluster = Cluster.Builder.create(stack, "Cluster")
         .clusterName("on-prem-cluster")
         .clusterType(ClusterType.ON_PREMISES)
         .instanceRole(instanceRole)
         .build();

Channel Placement Group

A channel placement group assigns channels to specific nodes within a cluster. Associate it with a channel via anywhereSettings: 

 Stack stack;
 ICluster cluster;
 IInput input;
 EncodeConfiguration video;
 IBucket bucket;
 
 
 ChannelPlacementGroup cpg = ChannelPlacementGroup.Builder.create(stack, "CPG")
         .channelPlacementGroupName("my-cpg")
         .cluster(cluster)
         .build();
 
 Channel.Builder.create(stack, "AnywhereChannel")
         .inputs(List.of(InputAttachment.builder().input(input).build()))
         .anywhereSettings(AnywhereSettings.builder().cluster(cluster).channelPlacementGroup(cpg).build())
         .outputGroups(List.of(OutputGroupConfiguration.hls(HlsOutputGroupProps.builder()
                 .name("hls")
                 .destinations(List.of(OutputDestination.toBucket(bucket, "live/stream")))
                 .outputs(List.of(HlsOutputDefinition.builder().encodes(List.of(video)).outputName("hls_out").build()))
                 .build())))
         .build();

SDI Source

An SDI source represents a physical SDI input on Anywhere hardware: 

 Stack stack;
 
 SdiSource sdi = SdiSource.Builder.create(stack, "Sdi")
         .sdiSourceName("camera-1")
         .type(SdiType.SINGLE)
         .build();

On-premises input networking

For inputs that live in an on-premises network, set inputNetworkLocation to InputNetworkLocation.ON_PREMISES. On-premises inputs do not use input security groups. Push inputs (RTMP/RTP/UDP) can pin their destination to a Network, declare the networkRoutes to reach it on the local network, and request a staticIpAddress: 

 Stack stack;
 
 
 Network network = Network.Builder.create(stack, "Network")
         .networkName("on-prem-network")
         .ipPools(List.of("192.168.1.0/24"))
         .build();
 
 Input.Builder.create(stack, "OnPremInput")
         .inputName("on-prem-rtp")
         .inputNetworkLocation(InputNetworkLocation.ON_PREMISES)
         .input(InputConfiguration.rtpPush(PushInputProps.builder()
                 .destinations(List.of(PushInputDestination.builder()
                         .network(network)
                         .networkRoutes(List.of(NetworkRoute.builder().cidr("10.0.0.0/24").gateway("10.0.0.1").build()))
                         .staticIpAddress("192.168.1.50")
                         .build()))
                 .build()))
         .build();

SRT listener inputs accept a streamId that the upstream system uses when connecting: 

 Stack stack;
 IInputSecurityGroup sg;
 
 
 Input.Builder.create(stack, "SrtListener")
         .inputName("srt-listener")
         .input(InputConfiguration.srtListener(SrtListenerInputProps.builder()
                 .inputSecurityGroups(List.of(sg))
                 .streamId("my-stream-id")
                 .build()))
         .build();